README.md
pyproject.toml
data_transfer_lib/__init__.py
data_transfer_lib/_bootstrap.py
data_transfer_lib/registry.py
data_transfer_lib.egg-info/PKG-INFO
data_transfer_lib.egg-info/SOURCES.txt
data_transfer_lib.egg-info/dependency_links.txt
data_transfer_lib.egg-info/requires.txt
data_transfer_lib.egg-info/top_level.txt
data_transfer_lib/api/__init__.py
data_transfer_lib/api/engine_pipeline.py
data_transfer_lib/api/reader.py
data_transfer_lib/api/writer.py
data_transfer_lib/connections/__init__.py
data_transfer_lib/connections/clickhouse.py
data_transfer_lib/connections/kafka.py
data_transfer_lib/connections/postgres.py
data_transfer_lib/core/__init__.py
data_transfer_lib/core/connection.py
data_transfer_lib/core/dq.py
data_transfer_lib/core/exceptions.py
data_transfer_lib/core/io.py
data_transfer_lib/core/lifecycle.py
data_transfer_lib/core/logging.py
data_transfer_lib/core/metrics.py
data_transfer_lib/extensions/__init__.py
data_transfer_lib/extensions/logging.py
data_transfer_lib/schema/__init__.py
data_transfer_lib/schema/canonical.py
data_transfer_lib/schema/inspector.py
data_transfer_lib/schema/mapper.py
data_transfer_lib/schema/validator.py
data_transfer_lib/schema/inspectors/__init__.py
data_transfer_lib/schema/inspectors/clickhouse_jdbc.py
data_transfer_lib/schema/inspectors/postgres_jdbc.py
data_transfer_lib/schema/mappers/__init__.py
data_transfer_lib/schema/mappers/clickhouse.py
data_transfer_lib/schema/mappers/kafka.py
data_transfer_lib/schema/mappers/postgres.py
data_transfer_lib/schema/mappers/spark.py
data_transfer_lib/strategies/__init__.py
data_transfer_lib/strategies/batch/__init__.py
data_transfer_lib/strategies/batch/clickhouse_jdbc.py
data_transfer_lib/strategies/batch/postgres_jdbc.py
data_transfer_lib/strategies/micro_batch/__init__.py
data_transfer_lib/strategies/micro_batch/clickhouse_jdbc.py
data_transfer_lib/strategies/micro_batch/kafka.py