Path	Lines of Code
CONTRIBUTING.md	42
CONTRIBUTORS.md	26
README.md	183
SECURITY.md	4
checkstyle/checkstyle.xml	155
checkstyle/suppressions.xml	19
cicd/cmd/run-terraform-schema/README.md	105
cicd/go.mod	28
contributor-docs/add-flex-template.md	448
contributor-docs/add-integration-or-load-test.md	504
contributor-docs/cicd.md	79
contributor-docs/code-contributions.md	340
contributor-docs/code-owners.md	8
contributor-docs/maintainers-guide.md	107
contributor-docs/release-process.md	50
it/README.md	29
it/google-cloud-platform/src/main/resources/test-artifact.json	1
plugins/core-plugin/src/main/resources/README-template.md	223
plugins/core-plugin/src/main/resources/site-template.md	166
python/README_Streaming_LLM.md	114
python/README_Word_Count_Python.md	107
python/README_Yaml_Template.md	147
python/default_base_python_requirements.txt	3
python/default_base_yaml_requirements.txt	3
python/src/main/python/job-builder-server/requirements.txt	2192
python/src/main/python/streaming-llm/base_requirements.txt	6
python/src/main/python/streaming-llm/requirements.txt	2071
python/src/main/python/word-count-python/requirements.txt	1687
python/src/main/python/yaml-template/requirements.txt	2192
python/src/test/resources/the_sonnets.txt	30
session.json	2701
test-infra/requirements.txt	2
v1/README_Bulk_Compress_GCS_Files.md	166
v1/README_Bulk_Decompress_GCS_Files.md	155
v1/README_Cassandra_To_Cloud_Bigtable.md	197
v1/README_Cloud_BigQuery_to_Cloud_Datastore.md	169
v1/README_Cloud_BigQuery_to_GCS_TensorFlow_Records.md	177
v1/README_Cloud_Bigtable_to_GCS_Avro.md	163
v1/README_Cloud_Bigtable_to_GCS_Json.md	172
v1/README_Cloud_Bigtable_to_GCS_Parquet.md	168
v1/README_Cloud_Bigtable_to_GCS_SequenceFile.md	184
v1/README_Cloud_Bigtable_to_Vector_Embeddings.md	208
v1/README_Cloud_PubSub_to_Avro.md	188
v1/README_Cloud_PubSub_to_Cloud_PubSub.md	156
v1/README_Cloud_PubSub_to_Datadog.md	218
v1/README_Cloud_PubSub_to_GCS_Text.md	189
v1/README_Cloud_PubSub_to_Splunk.md	238
v1/README_Cloud_Spanner_to_GCS_Avro.md	207
v1/README_Cloud_Spanner_vectors_to_Cloud_Storage.md	194
v1/README_Datastore_to_Datastore_Delete.md	175
v1/README_Datastore_to_GCS_Text.md	171
v1/README_Firestore_to_Firestore_Delete.md	175
v1/README_Firestore_to_GCS_Text.md	171
v1/README_GCS_Avro_to_Cloud_Bigtable.md	158
v1/README_GCS_Avro_to_Cloud_Spanner.md	193
v1/README_GCS_CSV_to_BigQuery.md	176
v1/README_GCS_Parquet_to_Cloud_Bigtable.md	158
v1/README_GCS_SequenceFile_to_Cloud_Bigtable.md	163
v1/README_GCS_Text_to_BigQuery.md	194
v1/README_GCS_Text_to_Cloud_PubSub.md	148
v1/README_GCS_Text_to_Cloud_Spanner.md	207
v1/README_GCS_Text_to_Datastore.md	172
v1/README_GCS_Text_to_Firestore.md	172
v1/README_Jdbc_to_BigQuery.md	205
v1/README_PubSub_Subscription_to_BigQuery.md	172
v1/README_PubSub_to_BigQuery.md	172
v1/README_Spanner_to_GCS_Text.md	183
v1/README_Stream_DLP_GCS_Text_to_BigQuery.md	177
v1/README_Stream_GCS_Text_to_BigQuery.md	214
v1/README_Stream_GCS_Text_to_Cloud_PubSub.md	155
v1/README_Word_Count.md	139
v1/src/main/java/com/google/cloud/teleport/spanner/README.md	4
v1/src/main/resources/checkstyle/checkstyle.xml	155
v1/src/main/resources/checkstyle/suppressions.xml	16
v1/src/main/resources/schema/pubsubmessage_deadletter_table_schema.json	46
v1/src/main/resources/schema/streaming_source_deadletter_table_schema.json	46
v1/src/test/resources/AvroToBigtableLT/schema.json	9
v1/src/test/resources/BulkCompressorIT/compress.txt	38
v1/src/test/resources/BulkCompressorIT/lipsum.txt	15
v1/src/test/resources/CSVToBigQueryIT/bq_destination_table_schema.json	12
v1/src/test/resources/ImportPipelineIT/googlesql/EmptyTable-manifest.json	6
v1/src/test/resources/ImportPipelineIT/googlesql/Float32Table-manifest.json	6
v1/src/test/resources/ImportPipelineIT/googlesql/Identity-manifest.json	6
v1/src/test/resources/ImportPipelineIT/googlesql/ModelStruct-manifest.json	6
v1/src/test/resources/ImportPipelineIT/googlesql/Sequence1-manifest.json	6
v1/src/test/resources/ImportPipelineIT/googlesql/Sequence2-manifest.json	6
v1/src/test/resources/ImportPipelineIT/googlesql/Singers-manifest.json	6
v1/src/test/resources/ImportPipelineIT/googlesql/UuidTable-manifest.json	6
v1/src/test/resources/ImportPipelineIT/googlesql/spanner-export-uuid.json	6
v1/src/test/resources/ImportPipelineIT/googlesql/spanner-export.json	34
v1/src/test/resources/ImportPipelineIT/postgres/EmptyTable-manifest.json	6
v1/src/test/resources/ImportPipelineIT/postgres/Float32Table-manifest.json	6
v1/src/test/resources/ImportPipelineIT/postgres/Identity-manifest.json	6
v1/src/test/resources/ImportPipelineIT/postgres/Sequence1-manifest.json	6
v1/src/test/resources/ImportPipelineIT/postgres/Sequence2-manifest.json	6
v1/src/test/resources/ImportPipelineIT/postgres/Singers-manifest.json	6
v1/src/test/resources/ImportPipelineIT/postgres/UuidTable-manifest.json	6
v1/src/test/resources/ImportPipelineIT/postgres/spanner-export-uuid.json	7
v1/src/test/resources/ImportPipelineIT/postgres/spanner-export.json	32
v1/src/test/resources/TextIOToBigQueryTest/input.txt	1
v1/src/test/resources/TextIOToBigQueryTest/schema.json	27
v2/astradb-to-bigquery/README.md	8
v2/astradb-to-bigquery/README_AstraDB_To_BigQuery.md	178
v2/astradb-to-bigquery/src/main/resources/astradb-to-bigquery-command-spec.json	7
v2/azure-eventhub-to-pubsub/README.md	91
v2/azure-eventhub-to-pubsub/README_Azure_Eventhub_to_PubSub.md	148
v2/azure-eventhub-to-pubsub/src/main/resources/azure-eventhub-to-pubsub-command-spec.json	9
v2/azure-eventhub-to-pubsub/src/main/resources/azure-eventhub-to-pubsub-metadata.json	36
v2/bigquery-to-bigtable/README.md	145
v2/bigquery-to-bigtable/README_BigQuery_to_Bigtable.md	223
v2/bigquery-to-bigtable/src/main/resources/bigquery-to-bigtable-command-spec.json	7
v2/bigquery-to-parquet/README.md	127
v2/bigquery-to-parquet/README_BigQuery_to_Parquet.md	157
v2/bigquery-to-parquet/src/main/resources/bigquery-to-parquet-command-spec.json	7
v2/bigtable-changestreams-to-hbase/README.md	85
v2/bigtable-changestreams-to-hbase/src/main/resources/bigtable-changestreams-to-hbase-command-spec.json	7
v2/cdc-parent/README.md	298
v2/cdc-parent/cdc-change-applier/README_Cdc_To_BigQuery_Template.md	178
v2/cdc-parent/cdc-embedded-connector/src/main/resources/dataflow_cdc.properties	8
v2/cdc-parent/cdc-embedded-connector/src/main/resources/gcp_test_password.properties	1
v2/cdc-parent/cdc-embedded-connector/src/main/resources/simplelogger.properties	3
v2/checkstyle/checkstyle.xml	155
v2/checkstyle/suppressions.xml	20
v2/common/src/main/resources/schema/pubsubmessage_deadletter_table_schema.json	46
v2/common/src/main/resources/schema/streaming_source_deadletter_table_schema.json	46
v2/common/src/main/resources/udf-samples/README.md	18
v2/common/src/test/resources/AvroConvertersTest/test_schema.json	19
v2/common/src/test/resources/CsvConvertersTest/testAvroSchema.json	19
v2/common/src/test/resources/CsvConvertersTest/testAvroSchemaTwo.json	23
v2/common/src/test/resources/CsvConvertersTest/testSchema.json	14
v2/common/src/test/resources/JsonConvertersTest/array_of_records.json	1
v2/common/src/test/resources/JsonConvertersTest/json_records.json	3
v2/common/src/test/resources/JsonConvertersTest/nested_fields_record.json	1
v2/common/src/test/resources/JsonConvertersTest/numeric_fields_record.json	1
v2/common/src/test/resources/JsonConvertersTest/one_field_record.json	1
v2/common/src/test/resources/JsonConvertersTest/one_not_null_field.json	1
v2/common/src/test/resources/JsonConvertersTest/one_null_field_explicit.json	1
v2/common/src/test/resources/JsonConvertersTest/one_null_field_implicit.json	1
v2/common/src/test/resources/ParquetConvertersTest/test_schema.json	19
v2/common/src/test/resources/SchemaUtilsTest/avro_schema.json	15
v2/common/src/test/resources/SchemaUtilsTest/proto_definition_as_bq_schema.json	121
v2/common/src/test/resources/SchemaUtilsTest/proto_definition_as_bq_schema_preserved_names.json	121
v2/dataplex/README_Dataplex_BigQuery_to_GCS.md	186
v2/dataplex/README_Dataplex_File_Format_Conversion.md	156
v2/dataplex/README_Dataplex_JDBC_Ingestion.md	229
v2/dataplex/src/main/resources/dataplex-bigquery-to-gcs-command-spec.json	7
v2/dataplex/src/main/resources/dataplex-file-format-conversion-command-spec.json	7
v2/dataplex/src/main/resources/dataplex-jdbc-ingestion-command-spec.json	7
v2/dataplex/src/test/resources/DataplexFileFormatConversionTest/entity2.existing/1.json	1
v2/dataplex/src/test/resources/DataplexFileFormatConversionTest/entity2/1.json	1
v2/dataplex/src/test/resources/DataplexFileFormatConversionTest/entity2/2.json	2
v2/datastream-to-bigquery/README.md	304
v2/datastream-to-bigquery/src/main/resources/datastream-to-bigquery-command-spec.json	7
v2/datastream-to-mongodb/readme.md	144
v2/datastream-to-mongodb/src/main/resources/datastream-to-mongodb-command-spec.json	7
v2/datastream-to-postgres/README.md	134
v2/datastream-to-postgres/src/main/resources/datastream-to-postgres-command-spec.json	7
v2/datastream-to-spanner/src/main/resources/datastream-to-spanner-command-spec.json	7
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/README_Load_Testing.md	127
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerFileOverridesIT/override.json	10
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerIT/mysql-session.json	443
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerLoadTesting/datagenerator-schema.json	6
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerMixedIT/mysql-session.json	506
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerSessionIT/mysql-session.json	456
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerShardedMigrationWithMigrationShardIdColumnIT/mysql-session.json	657
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerShardedMigrationWithMigrationShardIdColumnIT/transformation-context-shard1.json	1
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerShardedMigrationWithMigrationShardIdColumnIT/transformation-context-shard2.json	1
v2/datastream-to-spanner/src/test/resources/DatastreamToSpannerSingleDFShardedMigrationIT/mysql-session.json	223
v2/datastream-to-spanner/src/test/resources/DatastreamToSpannerSingleDFShardedMigrationIT/sharding-context.json	6
v2/datastream-to-spanner/terraform/samples/README.md	33
v2/datastream-to-spanner/terraform/samples/mysql-end-to-end/README.md	515
v2/datastream-to-spanner/terraform/samples/mysql-end-to-end/main.tf	269
v2/datastream-to-spanner/terraform/samples/mysql-end-to-end/outputs.tf	33
v2/datastream-to-spanner/terraform/samples/mysql-end-to-end/schema-overrides.json	13
v2/datastream-to-spanner/terraform/samples/mysql-end-to-end/terraform.tf	43
v2/datastream-to-spanner/terraform/samples/mysql-end-to-end/terraform.tfvars	97
v2/datastream-to-spanner/terraform/samples/mysql-end-to-end/terraform_simple.tfvars	57
v2/datastream-to-spanner/terraform/samples/mysql-end-to-end/variables.tf	113
v2/datastream-to-spanner/terraform/samples/mysql-sharded-end-to-end/README.md	609
v2/datastream-to-spanner/terraform/samples/mysql-sharded-end-to-end/main.tf	294
v2/datastream-to-spanner/terraform/samples/mysql-sharded-end-to-end/outputs.tf	50
v2/datastream-to-spanner/terraform/samples/mysql-sharded-end-to-end/session.json	7
v2/datastream-to-spanner/terraform/samples/mysql-sharded-end-to-end/terraform.tf	43
v2/datastream-to-spanner/terraform/samples/mysql-sharded-end-to-end/terraform.tfvars	111
v2/datastream-to-spanner/terraform/samples/mysql-sharded-end-to-end/terraform_simple.tfvars	44
v2/datastream-to-spanner/terraform/samples/mysql-sharded-end-to-end/transformationContext.json	6
v2/datastream-to-spanner/terraform/samples/mysql-sharded-end-to-end/variables.tf	117
v2/datastream-to-spanner/terraform/samples/mysql-sharded-single-df-job/README.md	568
v2/datastream-to-spanner/terraform/samples/mysql-sharded-single-df-job/main.tf	273
v2/datastream-to-spanner/terraform/samples/mysql-sharded-single-df-job/outputs.tf	56
v2/datastream-to-spanner/terraform/samples/mysql-sharded-single-df-job/session.json	7
v2/datastream-to-spanner/terraform/samples/mysql-sharded-single-df-job/shardingContext.json	6
v2/datastream-to-spanner/terraform/samples/mysql-sharded-single-df-job/terraform.tf	43
v2/datastream-to-spanner/terraform/samples/mysql-sharded-single-df-job/terraform.tfvars	95
v2/datastream-to-spanner/terraform/samples/mysql-sharded-single-df-job/terraform_simple.tfvars	39
v2/datastream-to-spanner/terraform/samples/mysql-sharded-single-df-job/variables.tf	97
v2/datastream-to-spanner/terraform/samples/postgresql-end-to-end/README.md	525
v2/datastream-to-spanner/terraform/samples/postgresql-end-to-end/main.tf	273
v2/datastream-to-spanner/terraform/samples/postgresql-end-to-end/outputs.tf	33
v2/datastream-to-spanner/terraform/samples/postgresql-end-to-end/terraform.tf	43
v2/datastream-to-spanner/terraform/samples/postgresql-end-to-end/terraform.tfvars	109
v2/datastream-to-spanner/terraform/samples/postgresql-end-to-end/terraform_simple.tfvars	67
v2/datastream-to-spanner/terraform/samples/postgresql-end-to-end/variables.tf	118
v2/datastream-to-spanner/terraform/samples/pre-configured-conn-profiles/README.md	400
v2/datastream-to-spanner/terraform/samples/pre-configured-conn-profiles/main.tf	176
v2/datastream-to-spanner/terraform/samples/pre-configured-conn-profiles/outputs.tf	30
v2/datastream-to-spanner/terraform/samples/pre-configured-conn-profiles/terraform.tf	43
v2/datastream-to-spanner/terraform/samples/pre-configured-conn-profiles/terraform.tfvars	90
v2/datastream-to-spanner/terraform/samples/pre-configured-conn-profiles/terraform_simple.tfvars	46
v2/datastream-to-spanner/terraform/samples/pre-configured-conn-profiles/variables.tf	84
v2/datastream-to-sql/README.md	137
v2/datastream-to-sql/README_Cloud_Datastream_to_SQL.md	217
v2/datastream-to-sql/src/main/resources/datastream-to-sql-command-spec.json	7
v2/file-format-conversion/README.md	96
v2/file-format-conversion/README_File_Format_Conversion.md	209
v2/file-format-conversion/src/main/resources/file-format-conversion-command-spec.json	7
v2/file-format-conversion/src/test/resources/FileFormatConversionTest/avro_schema.json	19
v2/file-format-conversion/src/test/resources/FileFormatConversionTest/avro_schema_two.json	19
v2/flex-wordcount-python/README.md	68
v2/flex-wordcount-python/spec/python_command_spec.json	3
v2/gcs-to-sourcedb/README.md	84
v2/gcs-to-sourcedb/README_GCS_to_Sourcedb.md	219
v2/gcs-to-sourcedb/src/main/resources/gcs-to-sourcedb-command-spec.json	7
v2/gcs-to-sourcedb/src/test/resources/GCSToSourceDbInterleaveIT/session.json	832
v2/gcs-to-sourcedb/src/test/resources/GCSToSourceDbInterleaveMultiShardIT/session.json	995
v2/gcs-to-sourcedb/src/test/resources/GCSToSourceDbWithReaderIT/session.json	135
v2/gcs-to-sourcedb/src/test/resources/GCSToSourceDbWithoutReaderIT/events.txt	6
v2/gcs-to-sourcedb/src/test/resources/GCSToSourceDbWithoutReaderIT/session.json	864
v2/gcs-to-sourcedb/src/test/resources/MultiColmPKSession.json	196
v2/gcs-to-sourcedb/src/test/resources/SpannerToMySql100TpsLT/datagenerator-schema.json	9
v2/gcs-to-sourcedb/src/test/resources/SpannerToMySql100TpsLT/session.json	330
v2/gcs-to-sourcedb/src/test/resources/TimezoneIT/session.json	132
v2/gcs-to-sourcedb/src/test/resources/allDatatypeSession.json	1149
v2/gcs-to-sourcedb/src/test/resources/allMatchSession.json	754
v2/gcs-to-sourcedb/src/test/resources/bitSession.json	207
v2/gcs-to-sourcedb/src/test/resources/bufferInput.json	17
v2/gcs-to-sourcedb/src/test/resources/bufferInputAllDatatypes.json	14
v2/gcs-to-sourcedb/src/test/resources/coulmnNameTypeMismatchSession.json	754
v2/gcs-to-sourcedb/src/test/resources/customTransformation.json	169
v2/gcs-to-sourcedb/src/test/resources/primarykeyMismatchSession.json	754
v2/gcs-to-sourcedb/src/test/resources/quotesSession.json	211
v2/gcs-to-sourcedb/src/test/resources/shard.json	18
v2/gcs-to-sourcedb/src/test/resources/sourceColumnAbsentInSpannerSession.json	775
v2/gcs-to-sourcedb/src/test/resources/sourceNoPkSession.json	748
v2/gcs-to-sourcedb/src/test/resources/spannerColumnAbsentInSourceSession.json	766
v2/gcs-to-sourcedb/src/test/resources/tableNameMismatchSession.json	754
v2/gcs-to-sourcedb/src/test/resources/timeZoneSession.json	721
v2/google-ads-to-googlecloud/README_Google_Ads_to_BigQuery.md	189
v2/google-ads-to-googlecloud/src/main/resources/google-ads-to-bigquery-command-spec.json	7
v2/googlecloud-to-elasticsearch/README.md	9
v2/googlecloud-to-elasticsearch/src/main/resources/bigquery-to-elasticsearch-command-spec.json	7
v2/googlecloud-to-elasticsearch/src/main/resources/gcs-to-elasticsearch-command-spec.json	7
v2/googlecloud-to-elasticsearch/src/main/resources/pubsub-to-elasticsearch-command-spec.json	7
v2/googlecloud-to-elasticsearch/src/main/resources/requirements.txt	2192
v2/googlecloud-to-elasticsearch/src/test/resources/EventMetadataBuilder/inputGCPAuditlogMessage.json	72
v2/googlecloud-to-elasticsearch/src/test/resources/EventMetadataBuilder/inputGCPAuditlogMessageInvalid.json	41
v2/googlecloud-to-elasticsearch/src/test/resources/GCSToElasticsearch/testSchema.json	14
v2/googlecloud-to-googlecloud/README.md	10
v2/googlecloud-to-googlecloud/README_Cloud_PubSub_to_Avro_Flex.md	200
v2/googlecloud-to-googlecloud/README_Cloud_PubSub_to_GCS_Text_Flex.md	202
v2/googlecloud-to-googlecloud/README_Cloud_Spanner_to_BigQuery_Flex.md	189
v2/googlecloud-to-googlecloud/README_Firestore_to_BigQuery_Flex.md	192
v2/googlecloud-to-googlecloud/README_Firestore_to_BigQuery_Xlang.md	185
v2/googlecloud-to-googlecloud/README_GCS_Text_to_BigQuery_Flex.md	178
v2/googlecloud-to-googlecloud/README_GCS_Text_to_BigQuery_Xlang.md	171
v2/googlecloud-to-googlecloud/README_PubSub_to_BigQuery_Auto.md	199
v2/googlecloud-to-googlecloud/README_PubSub_to_BigQuery_Flex.md	194
v2/googlecloud-to-googlecloud/README_PubSub_to_BigQuery_Xlang.md	182
v2/googlecloud-to-googlecloud/README_Spanner_Change_Streams_to_Google_Cloud_Storage.md	236
v2/googlecloud-to-googlecloud/README_Spanner_Change_Streams_to_PubSub.md	232
v2/googlecloud-to-googlecloud/README_Stream_DLP_GCS_Text_to_BigQuery_Flex.md	194
v2/googlecloud-to-googlecloud/README_Stream_GCS_Text_to_BigQuery_Flex.md	213
v2/googlecloud-to-googlecloud/README_Stream_GCS_Text_to_BigQuery_Xlang.md	196
v2/googlecloud-to-googlecloud/src/main/resources/bigtable-changestreams-to-bigquery-command-spec.json	7
v2/googlecloud-to-googlecloud/src/main/resources/bigtable-changestreams-to-gcs-command-spec.json	7
v2/googlecloud-to-googlecloud/src/main/resources/bigtable-changestreams-to-pubsub-command-spec.json	7
v2/googlecloud-to-googlecloud/src/main/resources/bigtable-changestreams-to-vector-embeddings-command-spec.json	7
v2/googlecloud-to-googlecloud/src/main/resources/dlptext-to-bigquery-command-spec.json	7
v2/googlecloud-to-googlecloud/src/main/resources/firestore-to-bigquery-command-spec.json	7
v2/googlecloud-to-googlecloud/src/main/resources/pubsub-to-avro-command-spec.json	7
v2/googlecloud-to-googlecloud/src/main/resources/pubsub-to-bigquery-command-spec.json	7
v2/googlecloud-to-googlecloud/src/main/resources/pubsub-to-text-command-spec.json	7
v2/googlecloud-to-googlecloud/src/main/resources/requirements.txt	2192
v2/googlecloud-to-googlecloud/src/main/resources/spanner-changestreams-to-bigquery-command-spec.json	7
v2/googlecloud-to-googlecloud/src/main/resources/spanner-changestreams-to-gcs-command-spec.json	7
v2/googlecloud-to-googlecloud/src/main/resources/spanner-changestreams-to-pubsub-command-spec.json	7
v2/googlecloud-to-googlecloud/src/main/resources/spanner-to-bigquery-command-spec.json	7
v2/googlecloud-to-googlecloud/src/main/resources/text-to-bigquery-command-spec.json	7
v2/googlecloud-to-googlecloud/src/main/resources/text-to-bigquery-streaming-command-spec.json	7
v2/googlecloud-to-googlecloud/src/test/proto/README.txt	1
v2/googlecloud-to-googlecloud/src/test/resources/TextIOToBigQueryLT/schema.json	40
v2/googlecloud-to-googlecloud/src/test/resources/TextIOToBigQueryTest/input.txt	1
v2/googlecloud-to-googlecloud/src/test/resources/TextIOToBigQueryTest/schema.json	27
v2/googlecloud-to-googlecloud/src/test/resources/TextToBigQueryStreamingIT/input.txt	1
v2/googlecloud-to-googlecloud/src/test/resources/TextToBigQueryStreamingIT/schema.json	12
v2/googlecloud-to-mongodb/README.md	8
v2/googlecloud-to-mongodb/README_BigQuery_to_MongoDB.md	150
v2/googlecloud-to-mongodb/src/main/resources/bigquery-to-mongodb-command-spec.json	7
v2/googlecloud-to-neo4j/README_Google_Cloud_to_Neo4j.md	172
v2/googlecloud-to-neo4j/src/main/resources/googlecloud-to-neo4j-command-spec.json	7
v2/googlecloud-to-neo4j/src/main/resources/schemas/connection.v1.0.json	147
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/auradb-free-connection.json	7
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/constraints-indices/edge-spec.json	51
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/constraints-indices/node-spec.json	40
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/constraints-indices/reset-database.json	51
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/custom-query/northwind-jobspec.json	91
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/cypher-generator-test/multi-distinct-keys-single-pass-import.json	56
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/cypher-generator-test/multi-label-single-pass-import.json	57
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/cypher-generator-test/single-target-relation-import-create-rels-merge-nodes.json	51
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/cypher-generator-test/single-target-relation-import-merge-all.json	51
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/cypher-generator-test/single-target-relation-import-with-keys-spec.json	54
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/cypher-generator-test/single-target-relation-import-without-keys-spec.json	52
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/data-conversion/bq-spec-map.json	16
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/data-conversion/bq-spec.json	47
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/data-conversion/empty-strings-spec.json	28
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/data-conversion/externalcsv-spec.json	44
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/data-conversion/inlinecsv-spec.json	54
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/escaping/bq-spec.json	36
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/escaping/externalcsv-spec.json	37
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/escaping/inlinecsv-spec.json	42
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/import-spec/movie-import/spec.json	168
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/inline-data/northwind-jobspec-single-pass-merge-all.json	2211
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/inline-data/northwind-jobspec.json	2274
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/inline-data/northwind-subset-jobspec-single-pass-create-edge-merge-nodes.json	95
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/job-spec-mapper-test/invalid-json.json	3
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/job-spec-mapper-test/valid-json-import-spec.json	102
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/job-spec-mapper-test/valid-json-legacy-spec.json	51
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/job-spec-mapper-test/valid-json-wrong-format-import-spec.json	104
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/job-spec-mapper-test/valid-json-wrong-format-legacy-spec.json	51
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/property-mappings/booleans-bq-spec.json	27
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/property-mappings/booleans-text-spec.json	34
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/property-mappings/mapping-clash-bq-spec.json	35
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/secret-manager/spec.json	30
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/text-northwind-jobspec.json	150
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/validation/spec.json	73
v2/googlecloud-to-splunk/README_GCS_To_Splunk.md	251
v2/googlecloud-to-splunk/README_GCS_To_Splunk_Xlang.md	244
v2/googlecloud-to-splunk/src/main/resources/gcs-to-splunk-command-spec.json	7
v2/googlecloud-to-splunk/src/main/resources/requirements.txt	2192
v2/googlecloud-to-splunk/src/test/resources/testSchema.json	14
v2/jdbc-and-googlecloud/README_Jdbc_to_BigQuery_Flex.md	267
v2/jdbc-and-googlecloud/README_Jdbc_to_PubSub.md	185
v2/jdbc-and-googlecloud/README_Jdbc_to_PubSub_Auto.md	197
v2/jdbc-and-googlecloud/README_Pubsub_to_Jdbc.md	190
v2/jdbc-and-googlecloud/src/main/resources/jdbc-to-bigquery-command-spec.json	7
v2/jdbc-and-googlecloud/src/main/resources/jdbc-to-pubsub-command-spec.json	7
v2/jdbc-and-googlecloud/src/main/resources/pubsub-to-jdbc-command-spec.json	7
v2/jms-to-pubsub/README.md	95
v2/jms-to-pubsub/README_Jms_to_PubSub.md	159
v2/jms-to-pubsub/src/main/resources/jms-to-pubsub-command-spec.json	9
v2/jms-to-pubsub/src/main/resources/jms-to-pubsub-metadata.json	52
v2/kafka-to-bigquery/README.md	74
v2/kafka-to-bigquery/README_Kafka_to_BigQuery.md	225
v2/kafka-to-bigquery/src/main/resources/kafka-to-bigquery-command-spec.json	7
v2/kafka-to-gcs/README.md	70
v2/kafka-to-gcs/README_Kafka_to_GCS.md	161
v2/kafka-to-gcs/README_Kafka_to_GCS_2.md	194
v2/kafka-to-gcs/src/main/resources/kafka-to-gcs-command-spec.json	7
v2/kafka-to-pubsub/README.md	163
v2/kafka-to-pubsub/src/main/resources/kafka_to_pubsub_metadata.json	75
v2/kinesis-to-pubsub/README.md	117
v2/kinesis-to-pubsub/README_Kinesis_To_Pubsub.md	155
v2/kinesis-to-pubsub/src/main/resources/kinesis-to-pubsub-command-spec.json	9
v2/kinesis-to-pubsub/src/main/resources/kinesis-to-pubsub-image-spec.json	48
v2/kudu-to-bigquery/README.md	114
v2/kudu-to-bigquery/src/main/resources/kudu-to-bigquery-command-spec.json	7
v2/mongodb-to-googlecloud/README.md	9
v2/mongodb-to-googlecloud/README_MongoDB_to_BigQuery.md	190
v2/mongodb-to-googlecloud/README_MongoDB_to_BigQuery_CDC.md	206
v2/mongodb-to-googlecloud/src/main/resources/mongodb-to-bigquery-cdc-command-spec.json	7
v2/mongodb-to-googlecloud/src/main/resources/mongodb-to-bigquery-command-spec.json	7
v2/mqtt-to-pubsub/README.md	93
v2/mqtt-to-pubsub/README_Mqtt_to_PubSub.md	156
v2/mqtt-to-pubsub/src/main/resources/mqtt-to-pubsub-command-spec.json	9
v2/mqtt-to-pubsub/src/main/resources/mqtt-to-pubsub-metadata.json	45
v2/mysql-to-googlecloud/README_Jdbc_to_PubSub.md	185
v2/mysql-to-googlecloud/README_Jdbc_to_PubSub_Auto.md	197
v2/mysql-to-googlecloud/README_MySQL_to_BigQuery.md	255
v2/mysql-to-googlecloud/src/main/resources/mysql-to-bigquery-command-spec.json	7
v2/oracle-to-googlecloud/README_Jdbc_to_PubSub.md	185
v2/oracle-to-googlecloud/README_Jdbc_to_PubSub_Auto.md	197
v2/oracle-to-googlecloud/README_Oracle_to_BigQuery.md	255
v2/oracle-to-googlecloud/src/main/resources/oracle-to-bigquery-command-spec.json	7
v2/postgresql-to-googlecloud/README_Jdbc_to_PubSub.md	185
v2/postgresql-to-googlecloud/README_Jdbc_to_PubSub_Auto.md	197
v2/postgresql-to-googlecloud/README_PostgreSQL_to_BigQuery.md	255
v2/postgresql-to-googlecloud/src/main/resources/postgresql-to-bigquery-command-spec.json	7
v2/pubsub-binary-to-bigquery/README.md	6
v2/pubsub-binary-to-bigquery/README_PubSub_Avro_to_BigQuery.md	181
v2/pubsub-binary-to-bigquery/README_PubSub_Proto_to_BigQuery.md	226
v2/pubsub-binary-to-bigquery/README_PubSub_Proto_to_BigQuery_Flex.md	226
v2/pubsub-binary-to-bigquery/README_PubSub_Proto_to_BigQuery_Xlang.md	214
v2/pubsub-binary-to-bigquery/src/main/resources/pubsub-avro-to-bigquery-command-spec.json	7
v2/pubsub-binary-to-bigquery/src/main/resources/pubsub-proto-to-bigquery-command-spec.json	7
v2/pubsub-binary-to-bigquery/src/main/resources/requirements.txt	2192
v2/pubsub-binary-to-bigquery/src/test/resources/PubSubProtoToBigQueryIT/BigQuerySchema.json	53
v2/pubsub-binary-to-bigquery/src/test/resources/PubSubProtoToBigQueryIT/BigQuerySchemaPreserved.json	53
v2/pubsub-binary-to-bigquery/src/test/resources/invalid_proto_schema.pb	1
v2/pubsub-binary-to-bigquery/src/test/resources/protobuf/schema/proto_schema.pb	23
v2/pubsub-cdc-to-bigquery/README.md	232
v2/pubsub-cdc-to-bigquery/src/main/resources/pubsub-cdc-to-bigquery-command-spec.json	9
v2/pubsub-to-jms/README.md	95
v2/pubsub-to-jms/README_Pubsub_to_Jms.md	156
v2/pubsub-to-jms/src/main/resources/pubsub-to-jms-command-spec.json	9
v2/pubsub-to-jms/src/main/resources/pubsub-to-jms-metadata.json	52
v2/pubsub-to-kafka/README.md	154
v2/pubsub-to-kafka/README_PubSub_to_Kafka.md	178
v2/pubsub-to-kafka/src/main/resources/pubsub-to-kafka-command-spec.json	9
v2/pubsub-to-kafka/src/main/resources/pubsub_to_kafka_metadata.json	73
v2/pubsub-to-mongodb/README.md	196
v2/pubsub-to-mongodb/README_Cloud_PubSub_to_MongoDB.md	217
v2/pubsub-to-mongodb/README_Cloud_PubSub_to_MongoDB_Xlang.md	205
v2/pubsub-to-mongodb/src/main/resources/pubsub-to-mongodb-command-spec.json	7
v2/pubsub-to-mongodb/src/main/resources/requirements.txt	2192
v2/pubsub-to-redis/README.md	77
v2/pubsub-to-redis/README_Cloud_PubSub_to_Redis.md	198
v2/pubsub-to-redis/src/main/resources/pubsub-to-redis-command-spec.json	7
v2/sourcedb-to-spanner/README.md	93
v2/sourcedb-to-spanner/README_Sourcedb_to_Spanner.md	328
v2/sourcedb-to-spanner/README_Sourcedb_to_Spanner_Flex.md	248
v2/sourcedb-to-spanner/src/main/resources/sourcedb-to-spanner-command-spec.json	7
v2/sourcedb-to-spanner/src/test/resources/DDLIT/company-session.json	968
v2/sourcedb-to-spanner/src/test/resources/SchemaMapperIT/company-session-sharded.json	725
v2/sourcedb-to-spanner/src/test/resources/SchemaMapperIT/company-session-with-transformation.json	638
v2/sourcedb-to-spanner/src/test/resources/SchemaMapperIT/company-session.json	638
v2/sourcedb-to-spanner/src/test/resources/SingleShardWithTransformation/session.json	224
v2/sourcedb-to-spanner/src/test/resources/TestCollations/README.md	24
v2/sourcedb-to-spanner/src/test/resources/session-file-empty.json	8
v2/sourcedb-to-spanner/src/test/resources/session-file-sharded.json	286
v2/sourcedb-to-spanner/src/test/resources/session-file-with-dropped-column.json	273
v2/sourcedb-to-spanner/terraform/samples/README.md	13
v2/sourcedb-to-spanner/terraform/samples/sharded-bulk-migration/README.md	346
v2/sourcedb-to-spanner/terraform/samples/sharded-bulk-migration/main.tf	97
v2/sourcedb-to-spanner/terraform/samples/sharded-bulk-migration/outputs.tf	8
v2/sourcedb-to-spanner/terraform/samples/sharded-bulk-migration/terraform.tf	40
v2/sourcedb-to-spanner/terraform/samples/sharded-bulk-migration/terraform.tfvars	61
v2/sourcedb-to-spanner/terraform/samples/sharded-bulk-migration/terraform_simple.tfvars	30
v2/sourcedb-to-spanner/terraform/samples/sharded-bulk-migration/variables.tf	51
v2/sourcedb-to-spanner/terraform/samples/single-job-bulk-migration/README.md	331
v2/sourcedb-to-spanner/terraform/samples/single-job-bulk-migration/main.tf	77
v2/sourcedb-to-spanner/terraform/samples/single-job-bulk-migration/outputs.tf	8
v2/sourcedb-to-spanner/terraform/samples/single-job-bulk-migration/terraform.tf	40
v2/sourcedb-to-spanner/terraform/samples/single-job-bulk-migration/terraform.tfvars	27
v2/sourcedb-to-spanner/terraform/samples/single-job-bulk-migration/terraform_simple.tfvars	13
v2/sourcedb-to-spanner/terraform/samples/single-job-bulk-migration/variables.tf	151
v2/spanner-change-streams-to-sharded-file-sink/README.md	58
v2/spanner-change-streams-to-sharded-file-sink/README_Spanner_Change_Streams_to_Sharded_File_Sink.md	229
v2/spanner-change-streams-to-sharded-file-sink/src/main/resources/spanner-change-streams-to-sharded-file-sink-command-spec.json	7
v2/spanner-change-streams-to-sharded-file-sink/src/test/resources/SpannerChangeStreamToGcsCustomShardIT/session.json	161
v2/spanner-change-streams-to-sharded-file-sink/src/test/resources/SpannerChangeStreamToGcsMultiShardIT/session.json	261
v2/spanner-common/src/test/resources/bulk-migration-shards-secret.json	55
v2/spanner-common/src/test/resources/bulk-migration-shards.json	57
v2/spanner-common/src/test/resources/schema-overrides-cols-tables.json	15
v2/spanner-common/src/test/resources/schema-overrides-columns.json	10
v2/spanner-common/src/test/resources/schema-overrides-malformed.json	9
v2/spanner-common/src/test/resources/schema-overrides-tables.json	7
v2/spanner-common/src/test/resources/session-file-empty.json	8
v2/spanner-common/src/test/resources/session-file-sharded.json	286
v2/spanner-common/src/test/resources/session-file-with-dropped-column.json	273
v2/spanner-common/src/test/resources/session-file-with-extra-spanner-column.json	204
v2/spanner-common/src/test/resources/session-file.json	285
v2/spanner-common/src/test/resources/shard-with-nocreds.json	9
v2/spanner-common/src/test/resources/shard-with-secret-error.json	10
v2/spanner-common/src/test/resources/shard-with-secret.json	39
v2/spanner-common/src/test/resources/shard.json	21
v2/spanner-common/src/test/resources/sharding-context.json	12
v2/spanner-common/src/test/resources/transformation-context.json	6
v2/spanner-common/terraform/samples/README.md	40
v2/spanner-common/terraform/samples/configure-shared-vpc/README.md	201
v2/spanner-common/terraform/samples/configure-shared-vpc/main.tf	25
v2/spanner-common/terraform/samples/configure-shared-vpc/outputs.tf	7
v2/spanner-common/terraform/samples/configure-shared-vpc/terraform.tf	26
v2/spanner-common/terraform/samples/configure-shared-vpc/terraform.tfvars	6
v2/spanner-common/terraform/samples/configure-shared-vpc/terraform_simple.tfvars	5
v2/spanner-common/terraform/samples/configure-shared-vpc/variables.tf	9
v2/spanner-common/terraform/samples/mysql-vpc-spanner-test-infra/README.md	245
v2/spanner-common/terraform/samples/mysql-vpc-spanner-test-infra/main.tf	82
v2/spanner-common/terraform/samples/mysql-vpc-spanner-test-infra/mysql5.7-setup.sh	38
v2/spanner-common/terraform/samples/mysql-vpc-spanner-test-infra/mysql8.4-setup.sh	33
v2/spanner-common/terraform/samples/mysql-vpc-spanner-test-infra/outputs.tf	26
v2/spanner-common/terraform/samples/mysql-vpc-spanner-test-infra/terraform.tf	31
v2/spanner-common/terraform/samples/mysql-vpc-spanner-test-infra/terraform.tfvars	24
v2/spanner-common/terraform/samples/mysql-vpc-spanner-test-infra/terraform_simple.tfvars	12
v2/spanner-common/terraform/samples/mysql-vpc-spanner-test-infra/variables.tf	40
v2/spanner-to-sourcedb/README.md	313
v2/spanner-to-sourcedb/src/main/resources/spanner-to-sourcedb-command-spec.json	7
v2/spanner-to-sourcedb/src/test/resources/MultiColmPKSession.json	196
v2/spanner-to-sourcedb/src/test/resources/SpannerToCassandraSourceLT/datagenerator-schema.json	9
v2/spanner-to-sourcedb/src/test/resources/SpannerToMySqlCustomTransformationLT/session.json	390
v2/spanner-to-sourcedb/src/test/resources/SpannerToMySqlSourceLT/datagenerator-schema.json	9
v2/spanner-to-sourcedb/src/test/resources/SpannerToMySqlSourceLT/session.json	330
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbCustomShardIT/session.json	161
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbCustomTransformationIT/session.json	885
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbIT/session.json	404
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbInterleaveMultiShardIT/session.json	995
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbTimezoneIT/session.json	132
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbWideRowIT/col-mb-session.json	235
v2/spanner-to-sourcedb/src/test/resources/allDatatypeSession.json	1149
v2/spanner-to-sourcedb/src/test/resources/allMatchSession.json	754
v2/spanner-to-sourcedb/src/test/resources/bitSession.json	207
v2/spanner-to-sourcedb/src/test/resources/bufferInput.json	17
v2/spanner-to-sourcedb/src/test/resources/bufferInputAllDatatypes.json	17
v2/spanner-to-sourcedb/src/test/resources/cassandraSession.json	1064
v2/spanner-to-sourcedb/src/test/resources/coulmnNameTypeMismatchSession.json	754
v2/spanner-to-sourcedb/src/test/resources/customTransformation.json	169
v2/spanner-to-sourcedb/src/test/resources/errorSchemaSession.json	754
v2/spanner-to-sourcedb/src/test/resources/primarykeyMismatchSession.json	754
v2/spanner-to-sourcedb/src/test/resources/quotesSession.json	211
v2/spanner-to-sourcedb/src/test/resources/shard.json	20
v2/spanner-to-sourcedb/src/test/resources/sourceColumnAbsentInSpannerSession.json	775
v2/spanner-to-sourcedb/src/test/resources/sourceNoPkSession.json	748
v2/spanner-to-sourcedb/src/test/resources/sourceWriterUTSession.json	995
v2/spanner-to-sourcedb/src/test/resources/spannerColumnAbsentInSourceSession.json	766
v2/spanner-to-sourcedb/src/test/resources/tableNameMismatchSession.json	754
v2/spanner-to-sourcedb/src/test/resources/timeZoneSession.json	721
v2/spanner-to-sourcedb/terraform/samples/README.md	30
v2/spanner-to-sourcedb/terraform/samples/spanner-to-cassandra/README.md	358
v2/spanner-to-sourcedb/terraform/samples/spanner-to-cassandra/main.tf	190
v2/spanner-to-sourcedb/terraform/samples/spanner-to-cassandra/outputs.tf	8
v2/spanner-to-sourcedb/terraform/samples/spanner-to-cassandra/terraform.tf	42
v2/spanner-to-sourcedb/terraform/samples/spanner-to-cassandra/terraform.tfvars	118
v2/spanner-to-sourcedb/terraform/samples/spanner-to-cassandra/terraform_simple.tfvars	39
v2/spanner-to-sourcedb/terraform/samples/spanner-to-cassandra/variables.tf	90
v2/spanner-to-sourcedb/terraform/samples/spanner-to-sharded-mysql/README.md	442
v2/spanner-to-sourcedb/terraform/samples/spanner-to-sharded-mysql/main.tf	193
v2/spanner-to-sourcedb/terraform/samples/spanner-to-sharded-mysql/outputs.tf	8
v2/spanner-to-sourcedb/terraform/samples/spanner-to-sharded-mysql/session.json	7
v2/spanner-to-sourcedb/terraform/samples/spanner-to-sharded-mysql/terraform.tf	42
v2/spanner-to-sourcedb/terraform/samples/spanner-to-sharded-mysql/terraform.tfvars	134
v2/spanner-to-sourcedb/terraform/samples/spanner-to-sharded-mysql/terraform_simple.tfvars	40
v2/spanner-to-sourcedb/terraform/samples/spanner-to-sharded-mysql/variables.tf	78
v2/sqlserver-to-googlecloud/README_Jdbc_to_PubSub.md	185
v2/sqlserver-to-googlecloud/README_Jdbc_to_PubSub_Auto.md	197
v2/sqlserver-to-googlecloud/README_SQLServer_to_BigQuery.md	255
v2/sqlserver-to-googlecloud/src/main/resources/sqlserver-to-bigquery-command-spec.json	7
v2/streaming-data-generator/README.md	366
v2/streaming-data-generator/README_Streaming_Data_Generator.md	284
v2/streaming-data-generator/src/main/resources/streaming-data-generator-command-spec.json	9
v2/streaming-data-generator/src/test/resources/gameevent.json	11
yaml/README_Kafka_to_BigQuery_Yaml.md	173