transferia
Open Source Cloud Native Ingestion engine
File Explorer
Download Latest Version (.zip)Showing a partial file list โ download the zip above to see everything.
- build_and_test.yml
- release-chart.yml
- release-docker-branch.yml
- release-docker-latest.yml
- release-docker.yml
- release-website.yml
- release.yml
- demo_grafana_dashboard.png
- grafana.tmpl.json
- logo.png
- transferring-data-1.png
- transferring-data-3.png
- transferring-data-4.png
- pg_init.sql
- ch_init.sql
- pg2ch_test.go
- transfer.yaml
- activate.go
- pg_init.sql
- pg2ch_test.go
- transfer.yaml
- check.go
- config.go
- config_test.go
- model.go
- describe.go
- pg_init.sql
- ch_init.sql
- pg2ch_test.go
- transfer.yaml
- replicate.go
- pg_init.sql
- ch_init.sql
- pg2pg_test.go
- tables.yaml
- transfer.yaml
- upload.go
- validate.go
- main.go
- consent-popup.css
- fonts.css
- theme.css
- yfm.css
- architecture.png
- asterisk.svg
- bench_key_metrics.png
- bench_pprof_lens.png
- bench_pprof_prifle.png
- bench_results.png
- bench_s3_vs_airbyte.png
- bench_speedscope_init.png
- cancel.svg
- cqrs_cdc_arch.png
- data.png
- demo_grafana_dashboard.png
- dp_architecture.png
- external-link.svg
- favicon.ico
- horizontal-ellipsis.svg
- main.png
- outbox_cdc.png
- plus-sign.svg
- plus.svg
- proveders_deps.svg
- schema_consistency.png
- snapshot_replica_sequence.png
- tables.png
- transferring-data-1.png
- transferring-data-3.png
- transferring-data-4.png
- replication-configuration.md
- snapshot-configuration.md
- regular-expressions.md
- snapshot-settings.md
- data_types.md
- transfer_types.md
- data-integrity.md
- data-model.md
- data-type-system.md
- extensibility.md
- index.md
- logs.md
- monitoring-alerting.md
- replication-techniques.md
- runtimes.md
- scaling.md
- schema-management.md
- testing.md
- transfer-types.md
- transformations.md
- airbyte.md
- clickhouse.md
- delta.md
- elasticsearch.md
- index.md
- kafka.md
- kinesis.md
- mongodb.md
- mysql.md
- object-storage.md
- opensearch.md
- postgres_source.md
- postgresql.md
- ytsaurus.md
- advanced.md
- architecture.md
- core-concepts.md
- data-loading.md
- development.md
- getting-started.md
- plugins.md
- transformers.md
- connect-prometheus-to-transfer.md
- index.md
- content.yaml
- about.md
- howto.md
- index.md
- roadmap_2024.md
- roadmap_2025.md
- airbyte.md
- index.md
- pg2yt.md
- data_model_transformer.png
- transformer_data_flow.png
- convert_to_string.md
- dbt.md
- filter_columns.md
- index.md
- lambda.md
- mask_field.md
- raw_cdc_doc_grouper.md
- raw_doc_grouper.md
- README.md
- rename_tables.md
- replace_primary_key.md
- sql.md
- data-migration.md
- data-warehousing.md
- event-driven-updates.md
- index.md
- log-delivery.md
- card-layout-block-trasnfer-service-horizontal-2.png
- card-layout-block-trasnfer-service-vertical-2.png
- cdc-from-zero-to-hero-index.jpg
- cdc-into-mysql.png
- doublecloud-transfer-airflow-3-3.png
- doublecloud-transfer-clickhouse-1-3.png
- doublecloud-transfer-kafka-2-3.png
- doublecloud-transfer-viz-4-3.png
- logo-cropped.svg
- migrate-from-elasticsearch-to-clickhouse-index.png
- native-s3-connector-vs-airbyte-s3-connector-index.png
- transfer-cost-comparison-6.png
- transfer-service-card-1.png
- transfer-service-card-2.png
- transfer-service-card-4.png
- transfer-service-card-5.png
- transfer-service-card-6.png
- transfer-service-clickhouse-cta.png
- transfer-service-doublecloud-architecture-4.png
- transfer-service-new-header.png
- website-sharing-datatransfer.png
- index.html
- manifest.json
- index.ts
- Wrapper.scss
- Wrapper.tsx
- globals.scss
- overrides.css
- variables.scss
- App.tsx
- content.yaml
- index.tsx
- .eslintignore
- .eslintrc
- .gitignore
- .nvmrc
- .prettierignore
- .prettierrc.js
- .stylelintrc
- package.json
- README.md
- tsconfig.json
- .yfm
- architecture-overview.md
- benchmarks.md
- build-and-serve.sh
- contributor-guide.md
- deploy_k8s.md
- getting_started.md
- index.yaml
- presets.yaml
- scale_horisontal.md
- scale_vertical.md
- toc.yaml
- transfer-faq.md
- transfer-self-help.md
- docker-compose.yml
- README.md
- transfer.yaml
- demo.tape
- docker-compose.yml
- init.sql
- mysql.conf
- README.md
- transfer.yaml
- Dockerfile
- go.mod
- go.sum
- main.go
- docker-compose.yml
- init.sql
- mysql.conf
- README.md
- transfer.yaml
- demo.tape
- docker-compose.yml
- init.sql
- transfer.yaml
- data.png
- main.png
- tables.png
- Dockerfile
- go.mod
- go.sum
- main.go
- docker-compose.yml
- init.sql
- README.md
- transfer_cdc_embed.yaml
- transfer_dynamic.yaml
- transfer_static.yaml
- img.png
- .terraform.lock.hcl
- docker-compose.yml
- main.tf
- README.md
- transfer.yaml
- variables.tf
- README.md
- _helpers.tpl
- _replication-statefulset.tpl
- _snapshot-job.tpl
- _snapshot-regular-cronjob.tpl
- _transfer_spec.tpl
- configmap.yaml
- deployment-type.yaml
- podmonitor.yaml
- serviceaccount.yaml
- Chart.yaml
- values.yaml
- README.md
- values.demo.yaml
- config.go
- nirvana.go
- abstract.go
- buffered_writer.go
- leaky_writer.go
- common.go
- json_truncator.go
- json_truncator_test.go
- kafka_push_client.go
- log.go
- log_test.go
- logger.go
- mutable_registry.go
- mutable_registry_test.go
- sanitizer_encoder.go
- sanitizer_encoder_test.go
- yt_log_bundle.go
- metrics.go
- pidstat.go
- psutil.go
- README.md
- static_creds.go
- main.go
- buildinfo.go
- not_arcadia.go
- inflight.go
- inflight_opts.go
- collect.go
- system.go
- buckets.go
- registryutil.go
- counter.go
- gauge.go
- histogram.go
- int_gauge.go
- registry.go
- registry_getters.go
- registry_opts.go
- timer.go
- vec.go
- counter.go
- gauge.go
- histogram.go
- int_gauge.go
- registry.go
- timer.go
- compat.go
- counter.go
- gauge.go
- histogram.go
- registry.go
- registry_opts.go
- timer.go
- vec.go
- counter.go
- gauge.go
- histogram.go
- int_gauge.go
- registry.go
- registry_opts.go
- stream.go
- timer.go
- vec.go
- base.go
- converter.go
- counter.go
- func_counter.go
- func_gauge.go
- func_int_gauge.go
- gauge.go
- histogram.go
- int_gauge.go
- metrics.go
- metrics_opts.go
- registry.go
- registry_opts.go
- series.go
- spack.go
- spack_compression.go
- stream.go
- timer.go
- vec.go
- buckets.go
- metrics.go
- resource.go
- assertxerrors.go
- benchxerrors.go
- stack_frames_count.go
- stack_trace_mode.go
- error.go
- doc.go
- errorf.go
- forward.go
- mode.go
- new.go
- README.md
- sentinel.go
- stacktrace.go
- pool.go
- pool_opts.go
- ptr.go
- chunk.go
- contains.go
- dedup.go
- doc.go
- equal.go
- filter.go
- group_by.go
- intersects.go
- join.go
- map.go
- map_async.go
- merge_sorted.go
- reverse.go
- shuffle.go
- sort.go
- subtract.go
- sum.go
- union.go
- zip.go
- canon.go
- dctest.go
- gotest.go
- recipe.go
- recurse.go
- remove_lines.go
- arcadia.go
- dctest.go
- env.go
- go.go
- assign.go
- stacktrace.go
- singleinflight.go
- grammar.go
- errors.go
- filters.go
- README.md
- something.txt
- .arcadia.root
- ya
- ya.bat
- .goat.toml
- root.go
- ya.go
- extracted
- extracted.0
- extracted
- extracted.0
- result.json
- strictify.go
- strictify_errors.go
- strictify_test.go
- change_item.go
- change_item_collapse.go
- change_item_dump.go
- change_item_test.go
- col_schema.go
- const.go
- db_schema.go
- event_size.go
- kind.go
- mirror.go
- old_keys.go
- partition.go
- queue_meta.go
- system_table.go
- table_columns.go
- table_id.go
- table_part_id.go
- table_schema.go
- tx_bound.go
- utils.go
- coordinator.go
- coordinator_fake_client.go
- coordinator_inmemory.go
- coordinator_inmemory_test.go
- editor.go
- fake_pkey.go
- operation.go
- operation_tables_parts.go
- status_message.go
- status_message_test.go
- transfer.go
- transfer_state.go
- error.go
- error_test.go
- errors_test_helper.go
- extracted
- extracted.0
- extracted
- extracted.0
- result.json
- endpoint.go
- endpoint_cleanup_type.go
- endpoint_common.go
- endpoint_common_test.go
- endpoint_registry.go
- endpoint_rotator_config.go
- endpoint_rotator_config_test.go
- includeable.go
- model_mock_destination.go
- model_mock_destination_test.go
- model_mock_source.go
- serialization.go
- serialization_test.go
- transfer.go
- transfer_dataobjects.go
- transfer_labels.go
- transfer_operation.go
- transfer_operation_progress.go
- transfer_operation_worker.go
- transfer_operation_worker_funcs.go
- transfer_operation_worker_funcs_test.go
- transfer_status.go
- transformation.go
- type_checkers.go
- CHANGELOG.md
- fallback.go
- fallback_registry.go
- README.md
- schema.go
- schema_doc.go
- async_sink.go
- async_source.go
- async_v2_sink.go
- change_item.go
- change_item_builders.go
- change_item_builders_test.go
- closeable.go
- committable.go
- errors.go
- expirer.go
- filter.go
- filter_test.go
- homo_valuer.go
- includeable.go
- k8s_runtime.go
- local_runtime.go
- metrics.go
- middleware.go
- movable.go
- operation_table_part.go
- operation_table_part_funcs.go
- operation_table_part_test.go
- operations.go
- operations_test.go
- parsers.go
- provider_type.go
- regular_snapshot.go
- replacable.go
- restore.go
- restore_test.go
- runtime.go
- runtime_fake.go
- shared_memory.go
- sink.go
- slot_monitor.go
- source.go
- storage.go
- storage_incremental.go
- storage_test.go
- strictify.go
- table_id_parser.go
- task_type.go
- test_result.go
- transfer.go
- transfer_type.go
- transformer.go
- type.go
- typed_change_item.go
- typed_change_item_test.go
- validator.go
- legacy_table_adapter.go
- cleanup.go
- common.go
- delete.go
- insert.go
- insert_builder.go
- insert_builder_test.go
- synchronize.go
- table_events.go
- table_events_test.go
- table_load.go
- transaction.go
- update.go
- compose.go
- descriptions_filter.go
- filters.go
- tableid_filter.go
- big_float.go
- bool.go
- bytes.go
- composite.go
- date.go
- date_time.go
- decimal.go
- double.go
- float.go
- int16.go
- int32.go
- int64.go
- int8.go
- interval.go
- json.go
- string.go
- timestamp.go
- timestamp_tz.go
- uint16.go
- uint32.go
- uint64.go
- uint8.go
- eventbatch_test.go
- schema.go
- transfer.go
- closeable.go
- cobraaux.go
- common.go
- environment.go
- connection.go
- host.go
- connection.go
- host.go
- connection.go
- connection.go
- connection.go
- host.go
- connections.go
- resolver.go
- stub_resolver.go
- client.go
- container.go
- container_opts.go
- context_reader.go
- context_reader_test.go
- docker.go
- docker_mocks.go
- docker_options.go
- docker_test.go
- kubernetes.go
- kubernetes_mocks.go
- kubernetes_options.go
- kubernetes_test.go
- README.md
- contextutil.go
- coordinator_s3.go
- coordinator_s3_recipe.go
- coordinator_s3_test.go
- creds.go
- static_creds.go
- error.go
- reader.go
- reader_test.go
- splitter.go
- splitter_test.go
- common.go
- glue.go
- providers.go
- transformer.go
- abstract.go
- host_port.go
- init.go
- roles.go
- storage.go
- table_query.go
- utils_test.go
- incremental_async_sink.go
- incremental_iterator.go
- mock_signal_table.go
- signal_table.go
- utils.go
- main.go
- stat.go
- debezium_schema.go
- error.go
- field_receiver.go
- field_receiver_default.go
- field_receiver_yt.go
- kafka_types.go
- key_value.go
- original_type_info.go
- test.go
- type.go
- values.go
- emitter_chain_test__canon_change_item_final_not_wiped.txt
- emitter_chain_test__canon_change_item_final_wiped.txt
- emitter_chain_test__canon_change_item_original.txt
- emitter_chain_test__canon_change_item_original_v8.txt
- emitter_chain_test__canon_change_item_recovered.txt
- emitter_vals_test__canon_change_item.txt
- emitter_vals_test__canon_change_item_v8.txt
- params__decimal.txt
- chain_special_values_test.go
- emitter_chain_test.go
- emitter_meta_test.go
- emitter_vals_test.go
- params_test.go
- emitter.go
- emitter_test.go
- receiver.go
- lightning_cache.go
- packer_lightning_cache.go
- session_packers_lightning_cache.go
- session_packers_lightning_cache_test.go
- factory.go
- packer.go
- packer_cache_final_schema.go
- packer_cache_final_schema_test.go
- packer_include_schema.go
- packer_renewable_on_expiration.go
- packer_renewable_on_expiration_test.go
- packer_schema_registry.go
- packer_schema_registry_test.go
- packer_skip_schema.go
- packer_skip_schema_test.go
- readme.md
- session_packers.go
- util.go
- util_test.go
- parameters.go
- readme.md
- validate.go
- validate_test.go
- extracted
- extracted
- result.json
- extracted
- extracted
- result.json
- emitter_chain_test__canon_change_item_final_not_wiped.txt
- emitter_chain_test__canon_change_item_final_wiped.txt
- emitter_chain_test__canon_change_item_original.txt
- emitter_chain_test__canon_change_item_recovered.txt
- emitter_crud_test__debezium_delete.txt
- emitter_crud_test__debezium_insert.txt
- emitter_crud_test__debezium_update0val.txt
- emitter_crud_test__debezium_update1val.txt
- emitter_crud_test__debezium_update2val0.txt
- emitter_crud_test__debezium_update2val2.txt
- emitter_crud_test__delete.txt
- emitter_crud_test__insert.txt
- emitter_crud_test__update0.txt
- emitter_crud_test__update1.txt
- emitter_crud_test__update2.txt
- emitter_replica_identity__canon_change_item_delete.txt
- emitter_replica_identity__canon_change_item_update.txt
- emitter_replica_identity__debezium_delete_key.txt
- emitter_replica_identity__debezium_delete_val.txt
- emitter_replica_identity__debezium_update_key.txt
- emitter_replica_identity__debezium_update_val.txt
- emitter_vals_test__canon_after.txt
- emitter_vals_test__canon_change_item.txt
- emitter_vals_test__canon_change_item_arr.txt
- emitter_vals_test__change_item_with_user_defined_type.txt
- params__decimal.txt
- README.md
- chain_special_values_test.go
- emitter_chain_test.go
- emitter_crud_test.go
- emitter_replica_identity_test.go
- emitter_vals_test.go
- original_type_info_test.go
- params_test.go
- receiver_bench_test.go
- receiver_test.go
- emitter.go
- receiver.go
- supported_sources.go
- test.go
- field_descr.go
- field_descr_test.go
- helpers.go
- helpers_test.go
- include_schema.go
- schema_registry.go
- unpacker.go
- emitter_vals_test__canon_change_item.txt
- chain_special_values_test.go
- emitter_chain_test.go
- emitter_meta_test.go
- emitter_vals_test.go
- stub.go
- emitter.go
- receiver.go
- emitter_common.go
- emitter_sr_subject_name_strategy_test.go
- emitter_sr_test.go
- emitter_value_converter.go
- emitter_value_converter_test.go
- fields_descr.go
- fields_descr_source.go
- kind.go
- readme.md
- receiver.go
- receiver_engine.go
- receiver_engine_test.go
- receiver_test.go
- validator.go
- category.go
- error.go
- registry.go
- error_codes.go
- categorized.go
- equal_causes.go
- equal_causes_test.go
- fatal_errors.go
- README.md
- to_transfer_status_message.go
- to_transfer_status_message_test.go
- traceback.go
- traceback_test.go
- size.go
- cloud_functions.go
- cloud_functions_test.go
- metadata_service.go
- yt_dyn_table_kv_wrapper.go
- yt_dyn_table_kv_wrapper_test.go
- batching_logger.go
- batching_logger_funcs.go
- throttler.go
- throttler_test.go
- factory.go
- writer.go
- agent.go
- agent_stub.go
- initializer_os.go
- metric.go
- rows_metric.go
- asynchronizer.go
- middleware.go
- offset_store.go
- offsetdedup.go
- offsetdedup_test.go
- push_action.go
- util.go
- measurer_test.go
- buffer.go
- bufferable.go
- bufferer.go
- bufferer_test.go
- README.md
- measurer.go
- README.md
- synchronizer.go
- config.go
- error_tracker.go
- fallback.go
- fallback_test.go
- filter.go
- interval_throttler.go
- metering.go
- nonrow_separator.go
- nonrow_separator_test.go
- pluggable_transformer.go
- README.md
- retrier.go
- statistician.go
- transformation.go
- type_strictness_tracker.go
- parsequeue.go
- parsequeue_test.go
- README.md
- abstract.go
- parsequeue.go
- parsequeue_test.go
- README.md
- waitable_parsequeue.go
- waitable_parsequeue_test.go
- result.json
- parse_base64_packed.jsonl
- parser_numbers_test.jsonl
- parser_unescape_test.jsonl
- parser_unescape_test.tskv
- generic_parser.go
- generic_parser_v2.go
- lookup.go
- lookup_test.go
- parser_test.go
- extracted
- extracted
- result.json
- ingest_pipeline.go
- ingest_pipeline.json
- ingest_pipeline_test.go
- parser.go
- parser_test.go
- parser_test.jsonl
- parser_audittrailsv1.go
- parser_config_audittrailsv1_common.go
- parser_blank.go
- parser_config_blank_lb.go
- extracted
- result.json
- message-name-from-any.bin
- test_schemas.json
- topic-profile.bin
- topic-shot.bin
- testutils.go
- cloud_events_proto.go
- parser.go
- parser_test.go
- protobuf.go
- utils.go
- utils_test.go
- parser_cloud_events.go
- parser_config_cloud_events_common.go
- parser_config_cloud_events_lb.go
- readme.md
- result.json
- parser.go
- parser_test.go
- parser_test.jsonl
- parser_cloudlogging.go
- parser_config_cloudlogging_common.go
- result.json
- protobuf_extractor.go
- protobuf_extractor_test.go
- util.go
- my_file1.pb.go
- my_file1.proto
- my_file2.pb.go
- my_file2.proto
- test_schemas.json
- my_file1.proto
- my_file2.proto
- test_schemas.json
- std_data_types.pb.go
- std_data_types.proto
- test_protobuf_0.bin
- test_protobuf_1.bin
- test_raw_json_messages
- test_schemas.json
- builtin_os.go
- format_json.go
- format_json_test.go
- format_protobuf.go
- format_protobuf_test.go
- md_builder.go
- md_builder_test.go
- parser.go
- parser_test.go
- types_json.go
- types_protobuf.go
- types_protobuf_test.go
- utils_json.go
- utils_json_test.go
- utils_protobuf.go
- utils_protobuf_test.go
- table_name_policy.go
- parser_config_confluent_schema_registry_common.go
- parser_config_confluent_schema_registry_lb.go
- parser_confluent_schema_registry.go
- multithreadig_test.md
- parser_bench_test.go
- parser_test.jsonl
- result.json
- parser.go
- parser_test.go
- parser_test.jsonl
- parser_config_debezium_common.go
- parser_config_debezium_lb.go
- parser_debezium.go
- fallback_timestamp_as_datetime.go
- fallback_timestamp_as_datetime_test.go
- parser_config_json_common.go
- parser_config_json_lb.go
- parser_json.go
- lib.go
- lib_no_cgo.go
- parser_config_native_lb.go
- parser_native.go
- extracted
- extracted
- extracted
- result.json
- metrika_hit_log.desc
- metrika_hit_log.proto
- metrika_hit_log_data.bin
- metrika_hit_protoseq.desc
- metrika_hit_protoseq.proto
- metrika_hit_protoseq_data.bin
- std_data_types.pb.go
- std_data_types.proto
- extract_message.desc
- proto_parser.go
- proto_parser_config.go
- proto_parser_config_test.go
- proto_parser_lazy.go
- proto_parser_lazy_builder.go
- proto_parser_test.go
- messages.proto
- proto_scanner.go
- repeated_scanner.go
- splitter_scanner.go
- parser_config_proto_common.go
- parser_config_proto_lb.go
- parser_proto.go
- parser.go
- parser_test.go
- doc.go
- parser_config_raw_to_table_common.go
- parser_config_raw_to_table_lb.go
- parser_raw_to_table.go
- parser_config_tskv_common.go
- parser_config_tskv_lb.go
- parser_tskv.go
- registry.go
- abstract.go
- embedded_resources.go
- factory.go
- no_resources.go
- donotsplit_scanner.go
- donotsplit_scanner_test.go
- event_scanner.go
- linebreak_scanner.go
- linebreak_scanner_test.go
- protoseq_scanner.go
- protoseq_scanner_test.go
- _type_check_rules.yaml
- json_sample
- json_sample.json
- json_sample_yql.json
- kikimr-log-2.yaml
- kikimr-log.yaml
- kikimr-new-log.yaml
- kikimr.json
- kikimr_new.json
- kikimr_sample
- kikimr_sample_new
- lf_timestamps.json
- logfeller-timestamps-test-log.json
- logfeller_timestamps_sample
- mdb
- mdb.json
- metrika.json
- metrika_complex.json
- metrika_complex_sample
- metrika_small_sample
- nel_sample
- nel_sample.json
- samples.go
- sensitive.json
- sensitive_disabled.json
- sensitive_sample
- taxi.json
- taxi_sample
- taxi_yql.json
- tm-5249.json
- tm-5249.tskv
- tm_280.json
- tm_280_yql.json
- tskv_sample
- tskv_sample.json
- tskv_sample_yql.json
- yql_complex_primary_key.json
- generic_parser_test.go
- utils_test.go
- abstract.go
- constants.go
- readme.md
- registry.go
- resource_wrapper.go
- utils.go
- utils_test.go
- ysrable_parser.go
- ysrable_parser_test.go
- pg.go
- ast.go
- extractor.go
- parser.go
- predicate_test.go
- token.go
- known_endpoint_types.go
- messages.go
- models.go
- provider.go
- provider_model.go
- README.md
- record_batch.go
- rows_record.go
- source.go
- storage.go
- storage_incremental.go
- typesystem.go
- typesystem.md
- typesystem_test.go
- destination_model.go
- provider.go
- sink.go
- sink_test.go
- sink_value_saver.go
- typesystem.go
- ddl.go
- parts.go
- errors_test_init.sql
- client.go
- ddl.go
- streaming.go
- part.go
- cluster.go
- errors_test.go
- marshaller.go
- marshaller_bench_test.go
- middleware.go
- part.go
- shard_part.go
- sink.go
- streamer.go
- chrecipe.go
- columntypes.go
- columntypes_test.go
- types.go
- conn_params.go
- connection.go
- connection_test.go
- tls.go
- check_distributed.go
- ddl_error.go
- error.go
- error_test.go
- csv_event.go
- csv_validator.go
- csv_validator_test.go
- factory.go
- json_compact_event.go
- json_compact_validator.go
- dump.sql
- http_client.go
- http_client_impl.go
- http_client_impl_test.go
- http_client_mock.go
- bench_test.go
- grisha_fast_map.go
- marshal.go
- marshal_test.go
- query.go
- query_test.go
- stats.go
- uploader.go
- connection_hosts.go
- connection_hosts_test.go
- connection_params.go
- doc_destination_example.yaml
- doc_destination_usage.md
- doc_source_example.yaml
- doc_source_usage.md
- model_ch_destination.go
- model_ch_destination_test.go
- model_ch_source.go
- model_ch_source_test.go
- model_sink_params.go
- model_storage_params.go
- resolver.go
- shard_resolver.go
- shard_resolver_test.go
- clickhouse_lexer.go
- lexer.go
- readme.md
- ddl_parser.go
- ddl_parser_test.go
- any_engine.go
- build_ddl_for_sink.go
- build_ddl_for_sink_test.go
- build_ddl_for_sink_utils.go
- build_ddl_for_sink_utils_test.go
- const.go
- fix_engine.go
- fix_engine_test.go
- replicated_engine.go
- replicated_engine_params.go
- util.go
- build_ddl_for_sink.go
- ddl.go
- ddl_batch.go
- ddl_source.go
- describe.go
- sharder.go
- sharding_model.go
- db_test.go
- init.sql
- check_db_test.go
- init.sql
- connman_test.go
- init.sql
- incremental.sql
- storage_incremental_test.go
- src_shard1.sql
- src_shard2.sql
- src_shard3.sql
- storage_test.go
- init.sql
- too_many_partitions_test.go
- endpoints.go
- fitting_test.go
- init.sql
- upcast_test.go
- extracted
- result.json
- init.sql
- transformer_test.go
- cluster.go
- topology.go
- topology_test.go
- a2_cluster_tables.go
- a2_data_provider.go
- a2_data_provider_test.go
- a2_table.go
- a2_table_part.go
- a2_target.go
- a2_target_test.go
- buf_with_pos.go
- buf_with_pos_test.go
- fallback_timestamp_as_datetime.go
- http_events_batch.go
- http_source.go
- http_source_utils.go
- http_source_utils_test.go
- provider.go
- query_builder.go
- query_builder_test.go
- schema.go
- server_pool.go
- server_pool_test.go
- sink.go
- sink_cluster.go
- sink_server.go
- sink_shard.go
- sink_table.go
- sink_table_test.go
- sink_test.go
- sources_chain.go
- storage.go
- storage_incremental.go
- storage_sampleable.go
- storage_sharding.go
- tasks.go
- toast.go
- toast_test.go
- typesystem.go
- typesystem.md
- typesystem_test.go
- utils.go
- utils_test.go
- api.go
- model_destination.go
- provider.go
- sink.go
- model_destination.go
- provider.go
- sink.go
- action.go
- add.go
- cdc.go
- commit_info.go
- format.go
- job_info.go
- metadata.go
- notebook_info.go
- protocol.go
- remove.go
- trx.go
- checkpoint.go
- checkpoint_reader.go
- history.go
- log_segment.go
- name_checker.go
- protocol_golden_test.go
- replayer.go
- snapshot.go
- snapshot_reader.go
- table_config.go
- table_log.go
- store.go
- store_file_meta.go
- store_local.go
- store_s3.go
- type_array.go
- type_map.go
- type_parser.go
- type_parser_test.go
- type_primitives.go
- type_struct.go
- golden_storage_test.go
- model_source.go
- provider.go
- README.md
- storage.go
- storage_sharding.go
- storage_snapshotable.go
- typesystem.go
- typesystem.md
- typesystem_test.go
- extracted
- extracted.0
- result.json
- change_item_fetcher.go
- client.go
- client_test.go
- dump_index.go
- logger.go
- model_destination.go
- model_response.go
- model_source.go
- provider.go
- schema.go
- schema_test.go
- sharding_storage.go
- sink.go
- sink_funcs.go
- sink_funcs_test.go
- storage.go
- typesystem.go
- unmarshaller.go
- eventhub.go
- eventhub_test.go
- model.go
- provider.go
- ddl_executor.go
- external_table_tx.go
- gpfdist.go
- gpfdist_test.go
- params.go
- try_function.go
- lines_splitter.go
- pipe_reader.go
- pipe_writer.go
- README.md
- util.go
- dump.sql
- check_db_test.go
- README.md
- connection.go
- connection_test.go
- context_val.go
- coordinator_model.go
- ddl_operations.go
- flavour.go
- gpfdist_sink.go
- gpfdist_storage.go
- gpfdist_table_sink.go
- gpfdist_table_sink_test.go
- gptx.go
- liveness_monitor.go
- model_gp_destination.go
- model_gp_source.go
- model_gp_source_test.go
- mutexed_postgreses.go
- object_transfer.go
- object_transfer_test.go
- pg_sink_params_regulated.go
- pg_sinks.go
- progress.go
- progress_test.go
- provider.go
- README.md
- segpointerpool.go
- sink.go
- sink_test.go
- storage.go
- storage_test.go
- client.go
- common.go
- group_reader.go
- manual_group.go
- manual_group_test.go
- partition_reader.go
- check_db_test.go
- abstract.go
- writer_factory.go
- writer_impl.go
- writer_mock.go
- compression_test.go
- ensure_topic.go
- ensure_topic_test.go
- fallback_generic_parser_timestamp.go
- kafka_test.go
- model_connection.go
- model_destination.go
- model_encoding.go
- model_source.go
- model_source_test.go
- partition_lister.go
- partition_lister_test.go
- partition_source.go
- partition_source_test.go
- provider.go
- provider_test.go
- recipe.go
- resolver.go
- resolver_test.go
- sink.go
- sink_test.go
- source.go
- source_common.go
- source_multi_topics.go
- source_test.go
- consumer.go
- group.go
- group_all.go
- options.go
- store.go
- store_coordinator.go
- kinesis_recipe.go
- model_source.go
- provider.go
- source.go
- stream_writer.go
- fallback_generic_parser_timestamp.go
- model_destination.go
- model_lb_source.go
- model_lf_source.go
- multi_dc_source.go
- native_source.go
- one_dc_source.go
- provider.go
- sink.go
- source.go
- batcher.go
- batcher_test.go
- bson.go
- bson_test.go
- bulk_splitter.go
- bulk_splitter_test.go
- change_stream.go
- change_stream_watcher.go
- client.go
- convert.go
- database_document_key_watcher.go
- database_full_document_watcher.go
- deep_copy.go
- deep_copy_test.go
- document.go
- document_test.go
- fallback_dvalue_json_repack.go
- local_oplog_rs_watcher.go
- model_mongo_connection_options.go
- model_mongo_destination.go
- model_mongo_source.go
- model_mongo_storage_params.go
- mongo_recipe.go
- namespace_only_watcher.go
- oplog_v2_parser.go
- parallelization_unit.go
- parallelization_unit_database.go
- parallelization_unit_oplog.go
- provider.go
- sampleable_storage.go
- schema.go
- schema_test.go
- shard_key.go
- shard_key_test.go
- sharded_collection.go
- sharding_storage.go
- sharding_storage_test.go
- sink.go
- sink_bulk_operations.go
- source.go
- source_test.go
- storage.go
- storage_test.go
- time.go
- typesystem.go
- typesystem.md
- typesystem_test.go
- utils.go
- version.go
- write_models.go
- adapter.go
- container.go
- binlog_missing_test.go
- connection_integration_test.go
- source.sql
- storage_sharding_test.go
- hetero.go
- homo.go
- hetero.go
- homo.go
- unmarshal.go
- json.go
- null_uint64.go
- temporal.go
- canal.go
- canal_test.go
- cast.go
- cast_replication.go
- cast_test.go
- config.go
- connection.go
- error.go
- error_test.go
- expr.go
- handler.go
- master.go
- model_destination.go
- model_source.go
- model_source_test.go
- model_storage_params.go
- mysql_connection_params.go
- parser_utf8mb3_test.go
- provider.go
- queries.go
- queries_builder.go
- queries_builder_test.go
- queries_test.go
- rows.go
- rows_test.go
- sampleable_storage.go
- schema.go
- schema_copy.go
- schema_copy_test.go
- schema_test.go
- schematized_rows.go
- sink.go
- sink_test.go
- source.go
- storage.go
- storage_sharding.go
- storage_test.go
- sync.go
- sync_binlog_position.go
- table_progress.go
- tasks.go
- tracker.go
- typesystem.go
- typesystem.md
- typesystem_test.go
- utils.go
- utils_test.go
- model_destination.go
- model_destination_test.go
- model_source.go
- provider.go
- readme.md
- sharding_storage.go
- sink.go
- storage.go
- connection.go
- log_position.go
- table_id.go
- transaction_info.go
- utils.go
- utils_test.go
- embedded.go
- in_memory.go
- internal.go
- log_tracker.go
- adapter.go
- container.go
- exec.go
- activate.go
- log_tracker.go
- provider.go
- replication_source.go
- sharding_storage.go
- storage.go
- batch.go
- errors.go
- source.go
- sql_cast.go
- sql_parse.go
- sql_parse_test.go
- transaction_store.go
- transaction_store_test.go
- column.go
- database.go
- index.go
- schema.go
- table.go
- yt_types.go
- cast.go
- common.go
- data_object.go
- data_objects.go
- loader.go
- table_source.go
- model_source.go
- readme.md
- all_datatypes_tables.sql
- check_all_types_test.go
- dump.sql
- changing_chunk_test.go
- update_pk_test.go
- composite_key_table.sql
- check_composite_key_test.go
- dump.sql
- check_fault_tolerance_test.go
- dump.sql
- check_mvp_test.go
- signal_table.go
- storage.go
- supported_key_type.go
- pgerrors.go
- pgerrors_test.go
- postgres_recipe.go
- lsn_transaction.go
- lsn_transaction_test.go
- progress_info.go
- progress_info_test.go
- sequencer.go
- sequencer_test.go
- abstract.go
- factory.go
- table_full.go
- table_full_test.go
- table_increment.go
- table_increment_test.go
- utils.go
- utils_test.go
- view.go
- view_test.go
- parse.go
- parse_test.go
- hits_binary_data.json
- hits_data.json
- dump.sql
- parent_child.sql
- sequence_test.sql
- coded_errors_test.go
- incremental_storage_test.go
- partition_source_q2s3_test.go
- sequence_test.go
- sharding_storage_test.go
- slot_test.go
- storage_size_test.go
- toast_value_test.go
- unparsed_bytes_test.go
- utils.go
- utils_test.go
- array.go
- change_processor.go
- change_processor_test.go
- changeitems_fetcher.go
- changeitems_fetcher_test.go
- changeitems_rows_stub.go
- client.go
- client_test.go
- complex_type.go
- composite.go
- conn.go
- create_replication_slot.go
- date.go
- default_value_test.go
- drop_replication_slot.go
- fallback_bit_as_bytes.go
- fallback_date_as_string.go
- fallback_not_null_as_null.go
- fallback_timestamp_utc.go
- flavour.go
- generic_array.go
- generic_array_test.go
- hstore.go
- hstore_test.go
- incremental_storage.go
- keeper.go
- keywords.go
- keywords_test.go
- list_names.go
- list_names_test.go
- logger.go
- lsn_slot.go
- model.go
- model_pg_destination.go
- model_pg_sink_params.go
- model_pg_source.go
- model_pg_source_test.go
- model_pg_storage_params.go
- models_test.go
- mutexed_pgconn.go
- mutexed_pgconn_test.go
- parent_resolver.go
- partition_lister.go
- partition_lister_test.go
- partition_source.go
- partition_source_q2s3_test.go
- partition_source_test.go
- pg_dump.go
- pg_dump_test.go
- postgres_keywords.txt
- provider.go
- publisher.go
- publisher_polling.go
- publisher_replication.go
- publisher_test.go
- queries.go
- queries_test.go
- represent.go
- represent_test.go
- schema.go
- schema_dump.go
- schema_dump_test.go
- schema_test.go
- sequence.go
- sharding_partition_storage.go
- sharding_storage.go
- sharding_storage_sequence.go
- sink.go
- sink_funcs.go
- sink_funcs_test.go
- sink_test.go
- skips.go
- slot.go
- slot_monitor.go
- source_specific_properties.go
- source_specific_properties_test.go
- source_wrapper.go
- storage.go
- storage_partition_expander.go
- storage_util.go
- storage_util_test.go
- table_information.go
- timestamp.go
- timestamptz.go
- timetz.go
- tracker.go
- transcoder_adapter.go
- txutils.go
- type.go
- type_test.go
- typesystem.go
- typesystem.md
- typesystem_test.go
- unmarshaller.go
- unmarshaller_hetero.go
- user_defined_types.go
- user_defined_types_test.go
- verify_tables.go
- version.go
- wal2json_item.go
- wal2json_parser.go
- wal2json_parser_test.go
- fallback_add_underscore_to_tablename_if_namespace_empty.go
- model_destination.go
- model_source.go
- provider.go
- abstract.go
- factory.go
- parsequeue_pusher.go
- pusher_state.go
- README.md
- synchronous_pusher.go
- estimate_bytes.go
- estimate_bytes_test.go
- estimate_rows.go
- data.log
- contractor_errors.go
- contractor_retry.go
- contractor_retry_test.go
- handle_data_error.go
- handle_data_error_test.go
- reader_error.go
- reader_error_funcs.go
- s3_not_found.go
- s3_not_found_test.go
- s3raw_transport_contract_test.go
- schema_sample_policy.go
- test_util.go
- wrap_contractor_test.go
- csv_config.go
- csv_schema_resolver.go
- csv_schema_resolver_funcs.go
- data_error_matrix_test.go
- reader_csv.go
- reader_csv_funcs.go
- reader_csv_test.go
- all_line_read.go
- all_line_read_test.go
- json_line_schema_resolver.go
- json_parser_schema_resolver.go
- jsonline_data_error_test.go
- reader_json_line.go
- reader_json_line_funcs.go
- reader_json_line_test.go
- reader_json_parser.go
- reader_json_parser_funcs.go
- reader_json_parser_test.go
- reader_json_parser_unparsed_retry_test.go
- data.log
- line_schema_resolver.go
- reader_line.go
- reader_line_funcs.go
- reader_line_test.go
- README.md
- strictify_unparsed_test.go
- data_error_matrix_test.go
- nginx_format.go
- nginx_format_test.go
- nginx_schema_resolver.go
- reader_nginx.go
- reader_nginx_funcs.go
- corrupt_read_path_test.go
- data_error_contract_test.go
- parquet_schema_resolver.go
- reader_parquet.go
- reader_parquet_funcs.go
- metrika_hit_protoseq_data.bin
- data_error_contract_test.go
- estimation.go
- parse.go
- parse_stream.go
- proto_schema_resolver.go
- proto_schema_resolver_funcs.go
- reader.go
- reader_funcs.go
- reader_test.go
- readfile_unparsed_policy_test.go
- utils.go
- utils_test.go
- registry.go
- abstract.go
- factory.go
- factory_test.go
- fake_s3_raw_reader.go
- s3_fetcher.go
- s3_fetcher_test.go
- s3_reader.go
- s3_wrapped_reader.go
- util.go
- all_test.go
- abstract.go
- chunk_reader.go
- chunk_reader_test.go
- factory.go
- reader_contractor.go
- reader_contractor_test.go
- registry_error_contract_test.go
- util.go
- recipe.go
- build_sharding_context.go
- main_secondary_synchronization.go
- main_secondary_synchronization_test.go
- transfer_state_adapter.go
- transfer_state_adapter_test.go
- trasfer_state_adapter_funcs.go
- batch.go
- delete.go
- dispatcher.go
- dispatcher_immutable_part.go
- dispatcher_immutable_part_funcs.go
- dispatcher_immutable_part_test.go
- task.go
- effective_worker_num.go
- effective_worker_num_funcs.go
- effective_worker_num_test.go
- file.go
- list.go
- stat.go
- l_window.go
- l_window_test.go
- README.md
- serde.go
- r_window.go
- r_window_funcs.go
- r_window_funcs_test.go
- r_window_test.go
- fake_s3_client.go
- fake_s3_session.go
- file.go
- abstract.go
- factory.go
- object_fetcher_contractor.go
- object_fetcher_poller.go
- object_fetcher_poller_test.go
- object_fetcher_sqs.go
- ordered_multimap.go
- ordered_multimap_test.go
- s3sess.go
- session_resolver.go
- transport.go
- synthetic_partition.go
- synthetic_partition_test.go
- util.go
- extracted
- result.json
- fake_cp_client.go
- fake_s3_client.go
- README.md
- writer.go
- file_cache.go
- file_cache_test.go
- file_splitter.go
- file_splitter_test.go
- object_range.go
- replication_sink.go
- replication_sink_test.go
- s3_client.go
- s3_object_ref.go
- s3_object_ref_test.go
- snapshot_sink.go
- snapshot_sink_test.go
- snapshot_writer.go
- snapshot_writer_test.go
- uploader.go
- util.go
- util_test.go
- README.md
- sharded_replication_test.go
- source.go
- source_test.go
- extracted
- extracted
- extracted
- result.json
- factory.go
- s3_shared_memory_main_worker.go
- s3_shared_memory_secondary_worker.go
- s3_shared_memory_single_worker.go
- storage.go
- storage_test.go
- s3_test.go
- model_destination.go
- replication_config.go
- serializers.go
- recipe.go
- abstract.go
- factory.go
- replace_s3_api.go
- s3_client.go
- partitioner.go
- partitioner_test.go
- README.md
- replication_sink_async.go
- replication_sink_async_test.go
- rotator.go
- rotator_test.go
- fake_cp_client.go
- fake_s3_client.go
- README.md
- writer.go
- file_cache.go
- file_cache_test.go
- file_splitter.go
- file_splitter_test.go
- object_range.go
- replace.go
- replace_test.go
- s3_object_ref.go
- snapshot_sink.go
- snapshot_sink_test.go
- snapshot_writer.go
- snapshot_writer_test.go
- util.go
- util_test.go
- provider.go
- typesystem.go
- typesystem.go
- iot-data.json
- user-activities.json
- iot.go
- model_source.go
- provider.go
- recipe.go
- sharded_storage.go
- source.go
- storage.go
- streaming_data.go
- user_activities.go
- model_destination.go
- model_source.go
- provider.go
- sink.go
- parse.go
- result.json
- adapter.go
- fields.go
- traces.go
- connection.go
- connection_test.go
- result.json
- config.go
- sink.go
- sink_test.go
- commit_latency_logger.go
- committable_batch.go
- source.go
- abstract.go
- read_event.go
- start_event.go
- stop_event.go
- abstract.go
- handler.go
- partition_event_reader.go
- partition_event_reader_test.go
- README.md
- topic_event_reader.go
- topic_event_reader_test.go
- partition_lister.go
- partition_lister_test.go
- partition_source.go
- partition_source_test.go
- source.go
- source_test.go
- config.go
- auth.go
- cdc_converter.go
- cdc_converter_test.go
- cdc_event.go
- client.go
- fallback_date_and_datetime_as_timestamp.go
- messages_batch.go
- model_destination.go
- model_source.go
- model_source_test.go
- model_storage_params.go
- provider.go
- reader_threadsafe.go
- schema.go
- schema_test.go
- schema_wrapper.go
- schema_wrapper_test.go
- sink.go
- sink_test.go
- source.go
- source_tasks.go
- source_tasks_test.go
- source_test.go
- storage.go
- storage_incremental.go
- storage_query.go
- storage_sampleable.go
- storage_sharded.go
- storage_sharded_test.go
- storage_test.go
- tasks_cleanup_test.go
- typesystem.go
- typesystem.md
- typesystem_test.go
- utils.go
- utils_test.go
- ydb_path_relativizer.go
- common.go
- config.go
- model_ydbtopic_source.go
- model_yds_source.go
- model_yds_source_test.go
- partition_source.go
- source.go
- provider.go
- batch.go
- nodeevent.go
- dataobjects.go
- source.go
- target.go
- list.go
- model.go
- add_underscore_to_tablename_with_empty_namespace.go
- bytes_as_string_go_type.go
- provider.go
- singleshot.go
- aggregator.go
- changeitems.go
- changeitems_test.go
- close_gaps.go
- close_gaps_test.go
- intermediate_writer.go
- intermediate_writer_test.go
- logbroker_metadata.go
- logbroker_metadata_test.go
- rows.go
- sink.go
- sink_test.go
- staging_writer.go
- staging_writer_test.go
- yt_state.go
- yt_utils.go
- yt_utils_test.go
- main.go
- merge.go
- arena.go
- converter.go
- eface.go
- README.md
- objectpresharded.go
- objects.go
- objects_test.go
- objectsharding.go
- part.go
- partkey.go
- schema.go
- column.go
- table.go
- cast.go
- resolve.go
- batch.go
- converter.go
- converter_test.go
- discovery_test.go
- events.go
- reader.go
- row_decoder.go
- snapshot.go
- source.go
- docker-compose.yml
- env.go
- main.go
- README.md
- test_container.go
- test_container_test.go
- yt_helpers.go
- sorted_table_bench_test.go
- snapshot_test.go
- snapshot_test.go
- commit.go
- commit_client.go
- init.go
- static_test.go
- util.go
- writer.go
- main_tx_client.go
- state_storage.go
- transaction_pinger.go
- README.md
- sink_state.go
- static_sink.go
- static_sink_test.go
- static_to_dynamic_wrapper.go
- big_value_test.go
- change_item_view.go
- common.go
- common_test.go
- data_batch.go
- main_test.go
- ordered_table.go
- ordered_table_test.go
- schema.go
- schema_test.go
- sink.go
- sink_test.go
- sorted_table.go
- sorted_table_test.go
- static_table.go
- static_table_test.go
- table_columns.go
- versioned_table.go
- versioned_table_test.go
- wal.go
- sampleable_storage.go
- storage.go
- storage_test.go
- utils.go
- util_test.go
- conn_params.go
- yt_client_wrapper.go
- codec_errors.go
- codec_errors_test.go
- cypress.go
- cypress_test.go
- executable.go
- model_lfstaging_destination.go
- model_storage_params.go
- model_yt_copy_destination.go
- model_yt_destination.go
- model_yt_source.go
- model_ytsaurus_dynamic_destination.go
- model_ytsaurus_source.go
- model_ytsaurus_static_destination.go
- provider.go
- spec.go
- spec_test.go
- table_id_parser_test.go
- util.go
- version.go
- provider.go
- provider_tasks.go
- README.md
- randutil.go
- abstract.go
- basic_strategy.go
- partition_runner.go
- partitioned_strategy.go
- partitioned_strategy_test.go
- logger_injestor.go
- replication.go
- replication_sync_runtime.go
- task_sync_runtime.go
- params.go
- limits.go
- nojob.go
- dummy_url_resolver.go
- http_client.go
- http_client_test.go
- load_balancer.go
- load_balancer_test.go
- schema.go
- schema_reference.go
- schema_type.go
- schemas_container.go
- schemas_container_test.go
- ysr.go
- ysr_connection_params.go
- ysr_test.go
- result.json
- common.go
- full_confluent_json_schema_arr_test.json
- full_confluent_json_schema_test.json
- full_kafka_json_schema_arr_test.json
- full_kafka_json_schema_test.json
- json_schema_format.go
- json_schema_format_test.go
- warmup.go
- pool.go
- extracted
- extracted.0
- extracted
- extracted
- result.json
- debezium_chain_test.go
- debezium_multithreading.go
- debezium_multithreading_test.go
- debezium_serializer.go
- debezium_serializer_test.go
- factory.go
- infer_test.go
- json_batcher.go
- json_batcher_test.go
- json_serializer.go
- json_serializer_test.go
- logging.go
- mirror_serializer.go
- mirror_serializer_test.go
- native_batcher.go
- native_batcher_test.go
- native_serializer.go
- native_serializer_test.go
- raw_column_serializer.go
- raw_column_serializer_test.go
- readme.md
- serializer.go
- split.go
- stat.go
- test.go
- result
- result
- result
- result
- result
- result
- result
- result
- result
- result
- result
- result
- result
- result
- result
- result
- result.json
- reference_test.go
- batch.go
- batch_factory.go
- batch_test.go
- csv.go
- csv_format.go
- interface.go
- json.go
- json_format.go
- json_test.go
- parquet.go
- parquet_format.go
- parquet_test.go
- raw.go
- readme.md
- strictify.go
- endpoint.go
- sink_factory.go
- source.go
- source_factory.go
- auth.go
- ch.go
- client.go
- fallbacks.go
- metric_types.go
- middleware_bufferer.go
- middleware_error_tracker.go
- middleware_filter.go
- middleware_transformer.go
- notifications.go
- other.go
- pool.go
- replication.go
- repository.go
- server.go
- sink_wrapper.go
- sink_wrapper_util.go
- sink_wrapper_util_test.go
- sinker.go
- source.go
- stopper.go
- table.go
- type_strictness.go
- worker.go
- storage_factory.go
- stringutil.go
- stringutil_test.go
- eventtarget.go
- common.go
- generator.go
- config.go
- fed_ydb_writer.go
- writer.go
- ydb_writer.go
- provider.go
- source.go
- transfer_params.go
- batch_splitter.go
- plugable_transformer.go
- README.md
- clickhouse_local.go
- clickhouse_local_test.go
- README.md
- filter_strm_access_log.go
- filter_strm_access_log_test.go
- adapter.go
- pluggable_transformer.go
- runner.go
- supported_target.go
- transformer.go
- filter.go
- filter_columns_transformer.go
- filter_columns_transformer_test.go
- filter_test.go
- skip_events.go
- skip_events_test.go
- transformer_common.go
- filter_rows.go
- filter_rows_test.go
- util.go
- filter_rows_by_ids.go
- parser.go
- lambda.go
- lambda_test.go
- logger.go
- result.json
- hmac_hasher.go
- hmac_hasher_test.go
- mask.go
- mongo_pk_extender.go
- mongo_pk_extender_test.go
- number_to_float.go
- pluggable_transformer.go
- pluggable_transformer_test.go
- README.md
- transformer.go
- transformer_test.go
- raw_cdc_doc_grouper.go
- raw_cdc_doc_grouper_test.go
- raw_data_utils.go
- raw_data_utils_test.go
- raw_doc_grouper.go
- raw_doc_grouper_test.go
- raw_doc_test_utils.go
- transformer.go
- transformer_test.go
- rename.go
- rename_test.go
- replace_primary_key.go
- replace_primary_key_test.go
- result.json
- sharder.go
- sharder_test.go
- table_splitter.go
- table_splitter_test.go
- result.json
- to_datetime.go
- to_datetime_test.go
- result.json
- to_string.go
- to_string_test.go
- dict_upserter.go
- yt_dict.go
- registry.go
- abstract.go
- README.md
- registry.go
- transformation.go
- transformation_test.go
- backoff.go
- backoff_test.go
- batcher.go
- batcher_test.go
- caste.go
- caste_test.go
- spinner.go
- diff.go
- diff_test.go
- common_dlq_maker.go
- common_dlq_maker_test.go
- malformed_row.go
- queue_dlq_maker.go
- splitter.go
- constraints.go
- glob.go
- glob_test.go
- gobwrapper.go
- grpc.go
- calculate.go
- calc_size_wrapper.go
- iter.go
- iter_blob.go
- iter_map.go
- iter_slice.go
- default_decoder.go
- json_null.go
- traverse.go
- value_decoder.go
- pooledmultibuf.go
- oneof_value.go
- coherence_check_test.go
- coherence_check.go
- common.go
- common_test.go
- converter.go
- offsets_source_validator.go
- wait_skipped_msgs.go
- bool.go
- channel.go
- channel_reader.go
- coalesce.go
- comparison.go
- comparison_test.go
- concurrent_map.go
- concurrent_map_test.go
- context.go
- crc32.go
- delayed_func.go
- encode_json.go
- errors.go
- file.go
- generics.go
- generics_test.go
- hash.go
- line_splitter.go
- line_splitter_test.go
- make_chan_with_error.go
- map_keys_in_order.go
- map_typed_value.go
- map_typed_value_test.go
- marshal.go
- ports.go
- .gitignore
- .goreleaser.yaml
- .mapping.json
- .piglet-meta.json
- CONTRIBUTING.md
- Dockerfile
- GLOSSARY.md
- go.mod
- go.sum
- LICENSE
- Makefile
- README.md
// repository documentation
Was this content helpful?
(0 ratings)