Path	Lines of Code
cicd/cmd/run-it-smoke-tests/main.go	58
cicd/cmd/run-it-tests/main.go	62
cicd/cmd/run-load-test-observer/main.go	59
cicd/cmd/run-load-tests/main.go	59
cicd/cmd/run-spanner-staging-it-tests/main.go	62
cicd/cmd/run-unit-tests/main.go	25
cicd/internal/flags/common-flags_test.go	63
cicd/internal/repo/files_test.go	70
cicd/internal/repo/modules_test.go	81
cicd/internal/terraform/filter_test.go	100
cicd/internal/terraform/matcher_test.go	241
cicd/internal/terraform/templates_test.go	131
it/datadog/src/test/java/com/google/cloud/teleport/it/datadog/DatadogResourceManagerIT.java	46
it/datadog/src/test/java/com/google/cloud/teleport/it/datadog/DatadogResourceManagerTest.java	137
it/datadog/src/test/java/com/google/cloud/teleport/it/datadog/DatadogResourceManagerUtilsTest.java	40
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/WordCountIT.java	60
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/artifacts/GcsArtifactTest.java	40
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/artifacts/utils/ArtifactUtilsTest.java	40
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryIOLT.java	338
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryResourceManagerTest.java	278
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryResourceManagerUtilsTest.java	36
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigtable/BigTableIOLT.java	202
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManagerClientFactoryTest.java	70
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManagerClusterTest.java	23
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManagerIT.java	54
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManagerTest.java	353
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManagerUtilsTest.java	57
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/cloudsql/CloudMySQLResourceManagerTest.java	31
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/cloudsql/CloudOracleResourceManagerTest.java	37
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/cloudsql/CloudSqlResourceManagerIT.java	77
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/cloudsql/CloudSqlResourceManagerTest.java	130
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/dataflow/AbstractPipelineLauncherTest.java	128
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/dataflow/ClassicTemplateClientTest.java	149
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/dataflow/DefaultPipelineLauncherTest.java	57
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/dataflow/FlexTemplateClientTest.java	153
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/dataflow/FlexTemplateDataflowJobResourceManagerTest.java	35
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/datastore/DatastoreResourceManagerIT.java	62
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/datastore/DatastoreResourceManagerTest.java	75
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/datastream/DatastreamResourceManagerTest.java	233
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/kms/KMSResourceManagerIT.java	32
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/kms/KMSResourceManagerTest.java	151
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/pubsub/PubsubResourceManagerTest.java	311
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/pubsub/PubsubUtilsTest.java	53
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/secretmanager/SecretManagerResourceManagerTest.java	91
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/spanner/SpannerIOLT.java	212
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/spanner/SpannerResourceManagerIT.java	138
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/spanner/SpannerResourceManagerTest.java	669
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/spanner/utils/SpannerResourceManagerUtilsTest.java	80
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/storage/FileBasedIOLT.java	172
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/storage/GcsResourceManagerTest.java	381
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/storage/conditions/GCSArtifactsCheckTest.java	82
lt/observability/src/test/java/com/google/cloud/teleport/lt/AssertAll.java	19
lt/observability/src/test/java/com/google/cloud/teleport/lt/dataset/bigquery/BigQueryPerfDataset.java	20
lt/observability/src/test/java/com/google/cloud/teleport/lt/dataset/bigquery/BigQueryPerfDatasetFetcher.java	83
lt/observability/src/test/java/com/google/cloud/teleport/lt/dataset/bigquery/PerfResultRow.java	8
lt/observability/src/test/java/com/google/cloud/teleport/lt/rules/DetectMetricDeviationConditionCheck.java	110
lt/observability/src/test/java/com/google/cloud/teleport/lt/spanner/DataStreamToSpannerLTObserver.java	60
lt/observability/src/test/java/com/google/cloud/teleport/lt/spanner/GenericTemplateLTObserver.java	98
metadata/src/test/java/com/google/cloud/teleport/metadata/util/EnumBasedExperimentValueProviderTest.java	27
metadata/src/test/java/com/google/cloud/teleport/metadata/util/MetadataUtilsTest.java	43
plugins/core-plugin/src/test/java/com/google/cloud/teleport/plugin/DockerfileGeneratorTest.java	246
plugins/core-plugin/src/test/java/com/google/cloud/teleport/plugin/TemplateDefinitionsParserTest.java	23
plugins/core-plugin/src/test/java/com/google/cloud/teleport/plugin/TemplateSpecsGeneratorTest.java	99
plugins/core-plugin/src/test/java/com/google/cloud/teleport/plugin/model/TemplateDefinitionsTest.java	246
plugins/core-plugin/src/test/java/com/google/cloud/teleport/plugin/sample/AtoBMissingAnnotation.java	34
plugins/core-plugin/src/test/java/com/google/cloud/teleport/plugin/sample/AtoBNestedFlex.java	15
plugins/core-plugin/src/test/java/com/google/cloud/teleport/plugin/sample/AtoBOk.java	142
plugins/core-plugin/src/test/java/com/google/cloud/teleport/plugin/terraform/TemplateTerraformGeneratorTest.java	51
plugins/templates-maven-plugin/src/test/java/com/google/cloud/teleport/plugin/maven/PromoteHelperTest.java	71
plugins/templates-maven-plugin/src/test/java/com/google/cloud/teleport/plugin/maven/TemplatesStageMojoTest.java	88
python/src/test/java/com/google/cloud/teleport/templates/python/PubSubToBigQueryYamlIT.java	111
python/src/test/java/com/google/cloud/teleport/templates/python/WordCountPythonIT.java	50
python/src/test/java/com/google/cloud/teleport/templates/python/YAMLTemplateIT.java	96
python/src/test/resources/PubSubToBigQueryYamlIT.yaml	21
python/src/test/resources/YamlTemplateIT.yaml	74
structured-logging/src/test/java/com/google/cloud/teleport/v2/logging/JsonLoggingAppenderTest.java	66
v1/src/test/java/com/google/cloud/spanner/FakeBatchTransactionId.java	28
v1/src/test/java/com/google/cloud/spanner/FakePartitionFactory.java	20
v1/src/test/java/com/google/cloud/spanner/OptionsImposter.java	10
v1/src/test/java/com/google/cloud/teleport/bigtable/AvroToBigtableLT.java	118
v1/src/test/java/com/google/cloud/teleport/bigtable/AvroToBigtableTest.java	81
v1/src/test/java/com/google/cloud/teleport/bigtable/BeamRowToBigtableFnTest.java	1003
v1/src/test/java/com/google/cloud/teleport/bigtable/BigtableToAvroTest.java	47
v1/src/test/java/com/google/cloud/teleport/bigtable/BigtableToJsonTest.java	55
v1/src/test/java/com/google/cloud/teleport/bigtable/BigtableToParquetTest.java	49
v1/src/test/java/com/google/cloud/teleport/bigtable/BigtableToVectorEmbeddingsTest.java	293
v1/src/test/java/com/google/cloud/teleport/bigtable/CassandraBaseTest.java	45
v1/src/test/java/com/google/cloud/teleport/bigtable/CassandraColumnSchemaTest.java	22
v1/src/test/java/com/google/cloud/teleport/bigtable/CassandraKeyUtilsTest.java	138
v1/src/test/java/com/google/cloud/teleport/bigtable/CassandraRowMapperFnTest.java	332
v1/src/test/java/com/google/cloud/teleport/bigtable/CassandraToBigtableIT.java	258
v1/src/test/java/com/google/cloud/teleport/bigtable/ParquetToBigtableTest.java	119
v1/src/test/java/com/google/cloud/teleport/bigtable/TestUtils.java	103
v1/src/test/java/com/google/cloud/teleport/datadog/DatadogEventCoderTest.java	34
v1/src/test/java/com/google/cloud/teleport/datadog/DatadogEventPublisherTest.java	132
v1/src/test/java/com/google/cloud/teleport/datadog/DatadogEventSerializerTest.java	60
v1/src/test/java/com/google/cloud/teleport/datadog/DatadogEventTest.java	47
v1/src/test/java/com/google/cloud/teleport/datadog/DatadogEventWriterTest.java	413
v1/src/test/java/com/google/cloud/teleport/datadog/DatadogIOTest.java	115
v1/src/test/java/com/google/cloud/teleport/datadog/DatadogWriteErrorCoderTest.java	30
v1/src/test/java/com/google/cloud/teleport/datadog/DatadogWriteErrorTest.java	39
v1/src/test/java/com/google/cloud/teleport/io/WindowedFilenamePolicyTest.java	258
v1/src/test/java/com/google/cloud/teleport/spanner/AsListTest.java	23
v1/src/test/java/com/google/cloud/teleport/spanner/AvroRecordConverterTest.java	1290
v1/src/test/java/com/google/cloud/teleport/spanner/AvroSchemaToDdlConverterTest.java	1489
v1/src/test/java/com/google/cloud/teleport/spanner/AvroTableFileAsMutationsTest.java	261
v1/src/test/java/com/google/cloud/teleport/spanner/AvroToDdlTool.java	30
v1/src/test/java/com/google/cloud/teleport/spanner/AvroUtilTest.java	63
v1/src/test/java/com/google/cloud/teleport/spanner/BuildReadFromTableOperationsTest.java	166
v1/src/test/java/com/google/cloud/teleport/spanner/CSVRecordToMutationTest.java	1217
v1/src/test/java/com/google/cloud/teleport/spanner/CompareDatabases.java	145
v1/src/test/java/com/google/cloud/teleport/spanner/CopyDbTest.java	1078
v1/src/test/java/com/google/cloud/teleport/spanner/CopySchemaTest.java	52
v1/src/test/java/com/google/cloud/teleport/spanner/DdlToAvroSchemaConverterTest.java	1874
v1/src/test/java/com/google/cloud/teleport/spanner/ExportPipelineIT.java	448
v1/src/test/java/com/google/cloud/teleport/spanner/ExportPipelineLT.java	112
v1/src/test/java/com/google/cloud/teleport/spanner/ExportRelatedTablesCheckTest.java	893
v1/src/test/java/com/google/cloud/teleport/spanner/ExportTimestampTest.java	416
v1/src/test/java/com/google/cloud/teleport/spanner/ExportTransformTest.java	288
v1/src/test/java/com/google/cloud/teleport/spanner/GcsUtilTest.java	11
v1/src/test/java/com/google/cloud/teleport/spanner/ImportFromAvroTest.java	1971
v1/src/test/java/com/google/cloud/teleport/spanner/ImportPipelineIT.java	401
v1/src/test/java/com/google/cloud/teleport/spanner/ImportTransformTest.java	261
v1/src/test/java/com/google/cloud/teleport/spanner/IntegrationTest.java	2
v1/src/test/java/com/google/cloud/teleport/spanner/ReadFileShardFnTest.java	295
v1/src/test/java/com/google/cloud/teleport/spanner/SpannerRecordConverterTest.java	975
v1/src/test/java/com/google/cloud/teleport/spanner/SpannerServerResource.java	186
v1/src/test/java/com/google/cloud/teleport/spanner/SpannerTableFilterTest.java	760
v1/src/test/java/com/google/cloud/teleport/spanner/SpannerVectorEmbeddingExportIT.java	175
v1/src/test/java/com/google/cloud/teleport/spanner/SplitIntoRangesFnTest.java	592
v1/src/test/java/com/google/cloud/teleport/spanner/TextImportTransformTest.java	551
v1/src/test/java/com/google/cloud/teleport/spanner/TextSourceTest.java	108
v1/src/test/java/com/google/cloud/teleport/spanner/common/NameUtilsTest.java	43
v1/src/test/java/com/google/cloud/teleport/spanner/common/NumericUtilsTest.java	20
v1/src/test/java/com/google/cloud/teleport/spanner/common/SizedTypeTest.java	98
v1/src/test/java/com/google/cloud/teleport/spanner/common/TypeTest.java	19
v1/src/test/java/com/google/cloud/teleport/spanner/ddl/DdlTest.java	1382
v1/src/test/java/com/google/cloud/teleport/spanner/ddl/ForeignKeyTest.java	37
v1/src/test/java/com/google/cloud/teleport/spanner/ddl/GraphElementTableTest.java	101
v1/src/test/java/com/google/cloud/teleport/spanner/ddl/InformationSchemaScannerIT.java	1181
v1/src/test/java/com/google/cloud/teleport/spanner/ddl/InformationSchemaScannerTest.java	127
v1/src/test/java/com/google/cloud/teleport/spanner/ddl/PropertyGraphTest.java	161
v1/src/test/java/com/google/cloud/teleport/spanner/ddl/RandomDdlGenerator.java	562
v1/src/test/java/com/google/cloud/teleport/spanner/ddl/RandomInsertMutationGenerator.java	235
v1/src/test/java/com/google/cloud/teleport/spanner/ddl/RandomUtils.java	28
v1/src/test/java/com/google/cloud/teleport/spanner/ddl/RandomValueGenerator.java	240
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/FakeServiceFactory.java	79
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/MutationKeyEncoderTest.java	844
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/MutationSizeEstimatorTest.java	489
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/MutationUtilsTest.java	358
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/OrderedCodeTest.java	738
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/RandomUtils.java	14
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/ReadSpannerSchemaTest.java	156
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/SpannerAccessorTest.java	116
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/SpannerIOReadTest.java	796
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/SpannerIOWriteExceptionHandlingTest.java	171
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/SpannerIOWriteTest.java	1372
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/SpannerReadIT.java	459
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/SpannerSchemaTest.java	92
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/SpannerTransformRegistrarTest.java	170
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/SpannerWriteIT.java	367
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/StructUtilsTest.java	424
v1/src/test/java/com/google/cloud/teleport/spanner/spannerio/TestCredential.java	31
v1/src/test/java/com/google/cloud/teleport/splunk/CustomX509TrustManagerTest.java	51
v1/src/test/java/com/google/cloud/teleport/splunk/HttpEventPublisherTest.java	240
v1/src/test/java/com/google/cloud/teleport/splunk/SplunkEventCoderTest.java	141
v1/src/test/java/com/google/cloud/teleport/splunk/SplunkEventTest.java	57
v1/src/test/java/com/google/cloud/teleport/splunk/SplunkEventWriterTest.java	251
v1/src/test/java/com/google/cloud/teleport/splunk/SplunkIOTest.java	121
v1/src/test/java/com/google/cloud/teleport/splunk/SplunkWriteErrorCoderTest.java	30
v1/src/test/java/com/google/cloud/teleport/splunk/SplunkWriteErrorTest.java	39
v1/src/test/java/com/google/cloud/teleport/templates/AvroToBigtableIT.java	66
v1/src/test/java/com/google/cloud/teleport/templates/BigQueryToDatastoreIT.java	86
v1/src/test/java/com/google/cloud/teleport/templates/BigQueryToTFRecordIT.java	49
v1/src/test/java/com/google/cloud/teleport/templates/BigQueryToTFRecordTest.java	161
v1/src/test/java/com/google/cloud/teleport/templates/BigtableToAvroIT.java	128
v1/src/test/java/com/google/cloud/teleport/templates/BigtableToJsonIT.java	105
v1/src/test/java/com/google/cloud/teleport/templates/BigtableToParquetIT.java	85
v1/src/test/java/com/google/cloud/teleport/templates/BigtableToVectorEmbeddingsIT.java	256
v1/src/test/java/com/google/cloud/teleport/templates/BulkCompressorIT.java	57
v1/src/test/java/com/google/cloud/teleport/templates/BulkCompressorLT.java	94
v1/src/test/java/com/google/cloud/teleport/templates/BulkCompressorTest.java	63
v1/src/test/java/com/google/cloud/teleport/templates/BulkDecompressorIT.java	53
v1/src/test/java/com/google/cloud/teleport/templates/BulkDecompressorTest.java	180
v1/src/test/java/com/google/cloud/teleport/templates/CSVToBigQueryIT.java	218
v1/src/test/java/com/google/cloud/teleport/templates/DLPTextToBigQueryStreamingIT.java	209
v1/src/test/java/com/google/cloud/teleport/templates/DLPTextToBigQueryStreamingTest.java	110
v1/src/test/java/com/google/cloud/teleport/templates/DatastoreToDatastoreDeleteIT.java	91
v1/src/test/java/com/google/cloud/teleport/templates/DatastoreToTextIT.java	114
v1/src/test/java/com/google/cloud/teleport/templates/ExportJobIT.java	66
v1/src/test/java/com/google/cloud/teleport/templates/ImportJobIT.java	63
v1/src/test/java/com/google/cloud/teleport/templates/JdbcToBigQueryIT.java	237
v1/src/test/java/com/google/cloud/teleport/templates/ParquetToBigtableIT.java	68
v1/src/test/java/com/google/cloud/teleport/templates/PubSubToAvroIT.java	111
v1/src/test/java/com/google/cloud/teleport/templates/PubSubToBigQueryIT.java	484
v1/src/test/java/com/google/cloud/teleport/templates/PubSubToDatadogIT.java	187
v1/src/test/java/com/google/cloud/teleport/templates/PubSubToPubSubIT.java	91
v1/src/test/java/com/google/cloud/teleport/templates/PubSubToSplunkIT.java	211
v1/src/test/java/com/google/cloud/teleport/templates/PubSubTopicToBigQueryIT.java	83
v1/src/test/java/com/google/cloud/teleport/templates/PubsubToAvroTest.java	36
v1/src/test/java/com/google/cloud/teleport/templates/PubsubToBigQueryLT.java	202
v1/src/test/java/com/google/cloud/teleport/templates/PubsubToBigQueryTest.java	70
v1/src/test/java/com/google/cloud/teleport/templates/PubsubToDatadogTest.java	52
v1/src/test/java/com/google/cloud/teleport/templates/PubsubToPubsubLT.java	173
v1/src/test/java/com/google/cloud/teleport/templates/PubsubToPubsubTest.java	122
v1/src/test/java/com/google/cloud/teleport/templates/PubsubToSplunkTest.java	52
v1/src/test/java/com/google/cloud/teleport/templates/PubsubToTextIT.java	93
v1/src/test/java/com/google/cloud/teleport/templates/PubsubToTextTest.java	37
v1/src/test/java/com/google/cloud/teleport/templates/SpannerServerResource.java	119
v1/src/test/java/com/google/cloud/teleport/templates/SpannerToTextIT.java	293
v1/src/test/java/com/google/cloud/teleport/templates/SpannerToTextLT.java	113
v1/src/test/java/com/google/cloud/teleport/templates/SpannerToTextTest.java	229
v1/src/test/java/com/google/cloud/teleport/templates/TextIOToBigQueryIT.java	86
v1/src/test/java/com/google/cloud/teleport/templates/TextImportPipelineIT.java	519
v1/src/test/java/com/google/cloud/teleport/templates/TextToBigQueryStreamLT.java	196
v1/src/test/java/com/google/cloud/teleport/templates/TextToBigQueryStreamingTest.java	56
v1/src/test/java/com/google/cloud/teleport/templates/TextToDatastoreIT.java	112
v1/src/test/java/com/google/cloud/teleport/templates/TextToPubsubIT.java	99
v1/src/test/java/com/google/cloud/teleport/templates/TextToPubsubStreamIT.java	101
v1/src/test/java/com/google/cloud/teleport/templates/TextToPubsubStreamLT.java	179
v1/src/test/java/com/google/cloud/teleport/templates/TextToSpannerTest.java	157
v1/src/test/java/com/google/cloud/teleport/templates/WordCountTest.java	47
v1/src/test/java/com/google/cloud/teleport/templates/common/BigQueryConvertersTest.java	802
v1/src/test/java/com/google/cloud/teleport/templates/common/CommonTemplateJvmInitializerTest.java	48
v1/src/test/java/com/google/cloud/teleport/templates/common/CsvConvertersTest.java	101
v1/src/test/java/com/google/cloud/teleport/templates/common/DatadogConvertersTest.java	483
v1/src/test/java/com/google/cloud/teleport/templates/common/DatastoreConvertersTest.java	263
v1/src/test/java/com/google/cloud/teleport/templates/common/ErrorConvertersTest.java	204
v1/src/test/java/com/google/cloud/teleport/templates/common/JavascriptTextTransformerTest.java	319
v1/src/test/java/com/google/cloud/teleport/templates/common/JdbcConvertersTest.java	152
v1/src/test/java/com/google/cloud/teleport/templates/common/SpannerConverterTest.java	566
v1/src/test/java/com/google/cloud/teleport/templates/common/SplunkConvertersTest.java	269
v1/src/test/java/com/google/cloud/teleport/util/DatadogApiKeyNestedValueProviderTest.java	135
v1/src/test/java/com/google/cloud/teleport/util/DualInputNestedValueProviderTest.java	64
v1/src/test/java/com/google/cloud/teleport/util/ResourceUtilsTest.java	26
v1/src/test/java/com/google/cloud/teleport/util/TestUtils.java	31
v1/src/test/java/com/google/cloud/teleport/util/TokenNestedValueProviderTest.java	135
v1/src/test/java/com/google/cloud/teleport/values/FailsafeElementTest.java	29
v1/src/test/proto/protos_test.proto	96
v1/src/test/resources/ExportPipelineIT/spanner-gsql-ddl.sql	37
v1/src/test/resources/ExportPipelineIT/spanner-gsql-uuid-ddl.sql	6
v1/src/test/resources/ExportPipelineIT/spanner-pg-ddl.sql	33
v1/src/test/resources/ExportPipelineIT/spanner-pg-uuid-ddl.sql	6
v1/src/test/resources/ImportPipelineIT/googlesql/spanner-gsql-ddl.sql	17
v1/src/test/resources/ImportPipelineIT/googlesql/spanner-gsql-uuid-ddl.sql	7
v1/src/test/resources/ImportPipelineIT/postgres/spanner-pg-ddl.sql	18
v1/src/test/resources/ImportPipelineIT/postgres/spanner-pg-uuid-ddl.sql	7
v1/src/test/resources/JavascriptTextTransformerTest/es6_transform.js	5
v1/src/test/resources/JavascriptTextTransformerTest/scriptParseException.js	4
v1/src/test/resources/JavascriptTextTransformerTest/transform.js	23
v1/src/test/resources/TextIOToBigQueryTest/udf.js	3
v2/astradb-to-bigquery/src/test/java/com/google/cloud/teleport/v2/astradb/templates/AstraDbToBigQueryIT.java	182
v2/azure-eventhub-to-pubsub/src/test/java/com/google/cloud/teleport/v2/templates/AzureEventhubToPubsubIT.java	124
v2/azure-eventhub-to-pubsub/src/test/java/com/google/cloud/teleport/v2/templates/AzureEventhubToPubsubTest.java	32
v2/azure-eventhub-to-pubsub/src/test/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/bigquery-to-bigtable/src/test/java/com/google/cloud/teleport/v2/templates/BigQueryToBigtableIT.java	141
v2/bigquery-to-bigtable/src/test/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/bigquery-to-parquet/src/test/java/com/google/cloud/teleport/v2/templates/BigQueryToParquetIT.java	150
v2/bigquery-to-parquet/src/test/java/com/google/cloud/teleport/v2/templates/BigQueryToParquetTest.java	35
v2/bigtable-changestreams-to-hbase/src/test/java/com/google/cloud/bigtable/data/v2/models/ChangeStreamMutationBuilder.java	51
v2/bigtable-changestreams-to-hbase/src/test/java/com/google/cloud/teleport/v2/templates/ChangeStreamToRowMutationsTest.java	303
v2/bigtable-changestreams-to-hbase/src/test/java/com/google/cloud/teleport/v2/templates/RowMutationsBuilderTest.java	107
v2/bigtable-changestreams-to-hbase/src/test/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/bigtable-changestreams-to-hbase/src/test/java/com/google/cloud/teleport/v2/templates/utils/HashUtils.java	90
v2/bigtable-changestreams-to-hbase/src/test/java/com/google/cloud/teleport/v2/templates/utils/HbaseUtils.java	45
v2/bigtable-changestreams-to-hbase/src/test/java/com/google/cloud/teleport/v2/templates/utils/TestConstants.java	16
v2/bigtable-common/src/test/java/com/google/cloud/teleport/v2/bigtable/transforms/BigtableConvertersTest.java	117
v2/cdc-parent/cdc-change-applier/src/test/java/com/google/cloud/dataflow/cdc/applier/BigQueryChangeApplierTest.java	73
v2/cdc-parent/cdc-change-applier/src/test/java/com/google/cloud/dataflow/cdc/applier/BigQuerySchemaUtilsTest.java	57
v2/cdc-parent/cdc-change-applier/src/test/java/com/google/cloud/dataflow/cdc/applier/BigQueryStatementIssuingFnTest.java	12
v2/cdc-parent/cdc-change-applier/src/test/java/com/google/cloud/dataflow/cdc/applier/CdcToBigQueryChangeApplierPipelineIT.java	285
v2/cdc-parent/cdc-change-applier/src/test/java/com/google/cloud/dataflow/cdc/applier/ChangelogTableDynamicDestinationsTest.java	16
v2/cdc-parent/cdc-change-applier/src/test/java/com/google/cloud/dataflow/cdc/applier/MergeStatementBuildingFnTest.java	152
v2/cdc-parent/cdc-change-applier/src/test/java/com/google/cloud/dataflow/cdc/applier/PubSubUtilsTest.java	13
v2/cdc-parent/cdc-common/src/test/java/com/google/cloud/dataflow/cdc/common/DataCatalogSchemaUtilsTest.java	2
v2/cdc-parent/cdc-common/src/test/java/com/google/cloud/dataflow/cdc/common/SchemaUtilsTest.java	31
v2/cdc-parent/cdc-embedded-connector/src/test/java/com/google/cloud/dataflow/cdc/connector/DebeziumMysqlToPubSubDataSenderTest.java	51
v2/cdc-parent/cdc-embedded-connector/src/test/java/com/google/cloud/dataflow/cdc/connector/DebeziumSourceRecordToDataflowCdcFormatTranslatorTest.java	227
v2/cdc-parent/cdc-embedded-connector/src/test/java/com/google/cloud/dataflow/cdc/connector/PubSubChangeConsumerTest.java	106
v2/common/src/test/java/com/google/cloud/teleport/v2/coders/FailsafeElementCoderTest.java	28
v2/common/src/test/java/com/google/cloud/teleport/v2/common/CommonTemplateJvmInitializerTest.java	44
v2/common/src/test/java/com/google/cloud/teleport/v2/io/WindowedFilenamePolicyTest.java	230
v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/AccumulateListFnTest.java	61
v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/AvroConvertersTest.java	72
v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/BigQueryConvertersTest.java	363
v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/CsvConvertersTest.java	452
v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/ErrorConvertersTest.java	215
v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/FailsafeElementTransformsTest.java	168
v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/JavascriptTextTransformerTest.java	272
v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/JsonConvertersTest.java	244
v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/JsonStringToMutationFnTest.java	40
v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/KeyValueToGenericRecordFnTest.java	48
v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/ParquetConvertersTest.java	76
v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/PythonTextTransformerTest.java	113
v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/UdfSamplesTest.java	114
v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/WriteToGCSAvroTest.java	42
v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/WriteToGCSParquetTest.java	28
v2/common/src/test/java/com/google/cloud/teleport/v2/transforms/WriteToGCSTextTest.java	42
v2/common/src/test/java/com/google/cloud/teleport/v2/utils/BigQueryIOUtilsTest.java	175
v2/common/src/test/java/com/google/cloud/teleport/v2/utils/GCSUtilsTest.java	64
v2/common/src/test/java/com/google/cloud/teleport/v2/utils/SchemaUtilsTest.java	118
v2/common/src/test/java/com/google/cloud/teleport/v2/utils/SecretManagerUtilsTest.java	15
v2/common/src/test/java/com/google/cloud/teleport/v2/utils/SerializableSchemaSupplierTest.java	32
v2/common/src/test/java/com/google/cloud/teleport/v2/utils/SpannerUtilsTest.java	275
v2/common/src/test/java/com/google/cloud/teleport/v2/values/FailsafeElementTest.java	29
v2/common/src/test/proto/import_proto_definition.proto	27
v2/common/src/test/proto/proto_definition.proto	54
v2/common/src/test/proto/shared_import_definition.proto	23
v2/common/src/test/proto/transitive_import_definition.proto	25
v2/common/src/test/resources/CsvConvertersTest/elasticPyUdf.py	13
v2/common/src/test/resources/CsvConvertersTest/elasticUdf.js	13
v2/common/src/test/resources/CsvConvertersTest/elasticUdfBad.js	13
v2/common/src/test/resources/JavascriptTextTransformerTest/es6_transform.js	11
v2/common/src/test/resources/JavascriptTextTransformerTest/scriptParseException.js	4
v2/common/src/test/resources/JavascriptTextTransformerTest/transform.js	11
v2/common/src/test/resources/PythonTextTransformerTest/transform.py	45
v2/dataplex/src/test/java/com/google/cloud/teleport/v2/clients/DefaultDataplexClientTest.java	242
v2/dataplex/src/test/java/com/google/cloud/teleport/v2/templates/DataplexBigQueryToGcsTest.java	814
v2/dataplex/src/test/java/com/google/cloud/teleport/v2/templates/DataplexFileFormatConversionTest.java	562
v2/dataplex/src/test/java/com/google/cloud/teleport/v2/templates/DataplexJdbcIngestionTest.java	209
v2/dataplex/src/test/java/com/google/cloud/teleport/v2/transforms/DeleteBigQueryDataFnTest.java	142
v2/dataplex/src/test/java/com/google/cloud/teleport/v2/transforms/GenericRecordsToGcsPartitionedTest.java	243
v2/dataplex/src/test/java/com/google/cloud/teleport/v2/utils/BigQueryTablePartitionTest.java	23
v2/dataplex/src/test/java/com/google/cloud/teleport/v2/utils/BigQueryTableTest.java	37
v2/dataplex/src/test/java/com/google/cloud/teleport/v2/utils/BigQueryToGcsFileNamingTest.java	29
v2/dataplex/src/test/java/com/google/cloud/teleport/v2/utils/DataplexBigQueryToGcsFilterTest.java	222
v2/dataplex/src/test/java/com/google/cloud/teleport/v2/utils/DataplexJdbcIngestionFilterTest.java	150
v2/dataplex/src/test/java/com/google/cloud/teleport/v2/utils/DataplexUtilsTest.java	185
v2/dataplex/src/test/java/com/google/cloud/teleport/v2/utils/SchemasTest.java	161
v2/datastream-common/src/test/java/com/google/cloud/teleport/v2/cdc/dlq/FileBasedDeadLetterQueueReconsumerTest.java	103
v2/datastream-common/src/test/java/com/google/cloud/teleport/v2/cdc/merge/MergeInfoTest.java	166
v2/datastream-common/src/test/java/com/google/cloud/teleport/v2/datastream/sources/DataStreamIOTest.java	28
v2/datastream-common/src/test/java/com/google/cloud/teleport/v2/datastream/transforms/FormatDatastreamJsonToJsonTest.java	102
v2/datastream-common/src/test/java/com/google/cloud/teleport/v2/datastream/transforms/FormatDatastreamRecordToJsonTest.java	299
v2/datastream-common/src/test/java/com/google/cloud/teleport/v2/datastream/utils/DataStreamClientTest.java	51
v2/datastream-common/src/test/java/com/google/cloud/teleport/v2/datastream/values/DatastreamRowTest.java	43
v2/datastream-common/src/test/java/com/google/cloud/teleport/v2/transforms/DLQWriteTransformTest.java	70
v2/datastream-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/BigQueryDeadLetterQueueSanitizerTest.java	61
v2/datastream-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToBigQueryIT.java	440
v2/datastream-to-postgres/src/test/java/com/google/cloud/teleport/v2/utils/DatabaseMigrationUtilsTest.java	59
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/spanner/IntegrationTest.java	2
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/spanner/SpannerServerResource.java	56
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerDDLIT.java	780
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerEventsIT.java	315
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerFileOverridesIT.java	119
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerIT.java	455
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerITBase.java	385
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerMixedIT.java	177
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerSessionIT.java	202
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerShardedMigrationWithMigrationShardIdColumnIT.java	427
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerShardedMigrationWithoutMigrationShardIdColumnIT.java	256
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerStringOverridesIT.java	113
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerTest.java	157
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMax16KeyTablePerDatabaseIT.java	285
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMax9MibTablePerDatabaseIT.java	288
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMaxColumnsPerTablesIT.java	274
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMaxTableNameIT.java	274
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSpannerWideRowForMaxTableNameWithMaxColumnNameIT.java	277
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DatastreamToSpannerSingleDFShardedMigrationIT.java	225
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/SeparateShadowTableDatabaseDDLIT.java	790
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/SeparateShadowTableDatabaseEventsIT.java	322
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/SeparateShadowTableDatabaseFileOverridesIT.java	130
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/SeparateShadowTableDatabaseMixedIT.java	187
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/SeparateShadowTableDatabasePKFocusedIT.java	219
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/SeparateShadowTableDatabaseSessionIT.java	212
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/SeparateShadowTableDatabaseShardedMigrationWithMigrationShardIdColumnIT.java	447
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/SeparateShadowTableDatabaseShardedMigrationWithoutMigrationShardIdColumnIT.java	274
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/SeparateShadowTableDatabaseSingleDFShardedMigrationIT.java	239
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/SeparateShadowTableDatabaseStringOverridesIT.java	124
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/SpannerStreamingWriteIntegrationTest.java	249
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/SpannerTransactionWriterDoFnTest.java	340
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventContextFactoryTest.java	59
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventConvertorTest.java	506
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventSequenceFactoryTest.java	373
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/datastream/MySqlChangeEventContextTest.java	112
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/datastream/MySqlChangeEventSequenceTest.java	96
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/datastream/OracleChangeEventContextTest.java	103
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/datastream/OracleChangeEventSequenceTest.java	77
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/datastream/PostgresChangeEventContextTest.java	103
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/datastream/PostgresChangeEventSequenceTest.java	119
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/datastream/ShadowTableReadUtilsTest.java	113
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/loadtesting/DataStreamToSpanner100GbLT.java	55
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/loadtesting/DataStreamToSpannerBlobTableLT.java	30
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/loadtesting/DataStreamToSpannerForeignKeyLT.java	35
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/loadtesting/DataStreamToSpannerInterleavedTableLT.java	33
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/loadtesting/DataStreamToSpannerLTBase.java	269
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/loadtesting/DataStreamToSpannerTallTableLT.java	30
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/loadtesting/DataStreamToSpannerWideTableLT.java	30
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/spanner/DatastreamToSpannerExceptionClassifierIT.java	370
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/spanner/DatastreamToSpannerExceptionClassifierTest.java	178
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/spanner/ProcessInformationSchemaIntegrationTest.java	157
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/spanner/ProcessInformationSchemaTest.java	605
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/spanner/ShadowTableCreatorTest.java	186
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/transform/ChangeEventTransformerDoFnTest.java	537
v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/utils/WatchdogRunnableTest.java	41
v2/datastream-to-spanner/src/test/resources/DataStreamToSpanner100GbLT/spanner-schema-blob.sql	4
v2/datastream-to-spanner/src/test/resources/DataStreamToSpanner100GbLT/spanner-schema-foreign-key.sql	53
v2/datastream-to-spanner/src/test/resources/DataStreamToSpanner100GbLT/spanner-schema-interleaving.sql	29
v2/datastream-to-spanner/src/test/resources/DataStreamToSpanner100GbLT/spanner-schema-tall-table.sql	4
v2/datastream-to-spanner/src/test/resources/DataStreamToSpanner100GbLT/spanner-schema-wide-table.sql	803
v2/datastream-to-spanner/src/test/resources/DataStreamToSpanner100GbLT/spanner-schema.sql	90
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerDDLIT/mysql-schema.sql	124
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerDDLIT/spanner-schema.sql	118
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerDDLIT/statements.sql	245
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerEventsIT/mysql-schema.sql	38
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerEventsIT/mysql-statements.sql	12
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerEventsIT/spanner-schema.sql	33
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerFileOverridesIT/mysql-schema.sql	10
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerFileOverridesIT/spanner-schema.sql	9
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerLoadTesting/mysql-schema.sql	7
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerMixedIT/mysql-schema.sql	17
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerMixedIT/spanner-schema.sql	12
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerMixedIT/statements.sql	13
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerSessionIT/mysql-schema.sql	11
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerSessionIT/spanner-schema.sql	11
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerSessionIT/statements.sql	7
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerShardedMigrationWithMigrationShardIdColumnIT/mysql-schema.sql	19
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerShardedMigrationWithMigrationShardIdColumnIT/mysql-statements.sql	28
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerShardedMigrationWithMigrationShardIdColumnIT/spanner-schema.sql	20
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerShardedMigrationWithoutMigrationShardIdColumnIT/mysql-schema.sql	6
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerShardedMigrationWithoutMigrationShardIdColumnIT/mysql-statements.sql	16
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerShardedMigrationWithoutMigrationShardIdColumnIT/spanner-schema.sql	5
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerStringOverridesIT/mysql-schema.sql	10
v2/datastream-to-spanner/src/test/resources/DataStreamToSpannerStringOverridesIT/spanner-schema.sql	9
v2/datastream-to-spanner/src/test/resources/DatastreamToSpannerSingleDFShardedMigrationIT/mysql-schema.sql	6
v2/datastream-to-spanner/src/test/resources/DatastreamToSpannerSingleDFShardedMigrationIT/mysql-statements.sql	10
v2/datastream-to-spanner/src/test/resources/DatastreamToSpannerSingleDFShardedMigrationIT/spanner-schema.sql	6
v2/datastream-to-spanner/src/test/resources/SeparateShadowTableDatabaseIT/mysql-schema.sql	19
v2/datastream-to-spanner/src/test/resources/SeparateShadowTableDatabaseIT/spanner-schema.sql	26
v2/datastream-to-spanner/src/test/resources/SpannerExceptionClassifierIT/spanner-data.sql	13
v2/datastream-to-spanner/src/test/resources/SpannerExceptionClassifierIT/spanner-schema.sql	36
v2/datastream-to-sql/src/test/java/com/google/cloud/teleport/v2/templates/DataStreamToSQLIT.java	350
v2/datastream-to-sql/src/test/java/com/google/cloud/teleport/v2/utils/DatastreamToDMLTest.java	278
v2/elasticsearch-common/src/test/java/com/google/cloud/teleport/v2/elasticsearch/transforms/ValueExtractorTransformTest.java	72
v2/elasticsearch-common/src/test/java/com/google/cloud/teleport/v2/elasticsearch/transforms/WriteToElasticsearchTest.java	154
v2/elasticsearch-common/src/test/java/com/google/cloud/teleport/v2/elasticsearch/utils/ConnectionInformationTest.java	68
v2/elasticsearch-common/src/test/java/com/google/cloud/teleport/v2/elasticsearch/utils/ElasticsearchIndexTest.java	15
v2/elasticsearch-common/src/test/resources/ValueExtractorTransformTest/transform.js	11
v2/failure-injected-spanner-service/src/test/java/com/google/cloud/teleport/v2/spanner/service/SpannerServiceTest.java	88
v2/failure-injected-spanner-service/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerServiceFactoryImplTest.java	26
v2/failure-injection-policies/src/test/java/com/google/cloud/teleport/v2/failureinjection/AlwaysFailPolicyTest.java	10
v2/file-format-conversion/src/test/java/com/google/cloud/teleport/v2/templates/FileFormatConversionIT.java	171
v2/file-format-conversion/src/test/java/com/google/cloud/teleport/v2/templates/FileFormatConversionTest.java	273
v2/gcs-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/GCSToSourceDbInterleaveIT.java	351
v2/gcs-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/GCSToSourceDbInterleaveMultiShardIT.java	395
v2/gcs-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/GCSToSourceDbWithReaderIT.java	204
v2/gcs-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/GCSToSourceDbWithoutReaderIT.java	258
v2/gcs-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToJdbcLTBase.java	193
v2/gcs-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToMySql100TpsLT.java	129
v2/gcs-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/TimezoneIT.java	237
v2/gcs-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/processing/dml/DMLGeneratorTest.java	449
v2/gcs-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/processing/handler/GCSToSourceStreamingHandlerTest.java	87
v2/gcs-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/utils/ShardProgressTrackerTest.java	100
v2/gcs-to-sourcedb/src/test/resources/GCSToSourceDbInterleaveIT/mysql-schema.sql	12
v2/gcs-to-sourcedb/src/test/resources/GCSToSourceDbInterleaveIT/spanner-schema.sql	30
v2/gcs-to-sourcedb/src/test/resources/GCSToSourceDbInterleaveMultiShardIT/mysql-schema.sql	12
v2/gcs-to-sourcedb/src/test/resources/GCSToSourceDbInterleaveMultiShardIT/spanner-schema.sql	34
v2/gcs-to-sourcedb/src/test/resources/GCSToSourceDbWithReaderIT/spanner-schema.sql	9
v2/gcs-to-sourcedb/src/test/resources/GCSToSourceDbWithoutReaderIT/spanner-schema.sql	24
v2/gcs-to-sourcedb/src/test/resources/SpannerToMySql100TpsLT/mysql-schema.sql	10
v2/gcs-to-sourcedb/src/test/resources/SpannerToMySql100TpsLT/spanner-schema.sql	14
v2/gcs-to-sourcedb/src/test/resources/TimezoneIT/spanner-schema.sql	9
v2/google-ads-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/transforms/GoogleAdsRowToReportRowJsonFnTest.java	39
v2/google-ads-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/utils/GoogleAdsRateLimitPolicyFactoryTest.java	26
v2/google-ads-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/utils/GoogleAdsUtilsTest.java	632
v2/googlecloud-to-elasticsearch/src/test/java/com/google/cloud/teleport/v2/elasticsearch/templates/BigQueryToElasticsearchIT.java	214
v2/googlecloud-to-elasticsearch/src/test/java/com/google/cloud/teleport/v2/elasticsearch/templates/BigQueryToElasticsearchTest.java	48
v2/googlecloud-to-elasticsearch/src/test/java/com/google/cloud/teleport/v2/elasticsearch/templates/GCSToElasticsearchIT.java	197
v2/googlecloud-to-elasticsearch/src/test/java/com/google/cloud/teleport/v2/elasticsearch/templates/GCSToElasticsearchTest.java	215
v2/googlecloud-to-elasticsearch/src/test/java/com/google/cloud/teleport/v2/elasticsearch/templates/PubSubToElasticsearchIT.java	136
v2/googlecloud-to-elasticsearch/src/test/java/com/google/cloud/teleport/v2/elasticsearch/templates/PubSubToElasticsearchTest.java	236
v2/googlecloud-to-elasticsearch/src/test/java/com/google/cloud/teleport/v2/elasticsearch/transforms/EventMetadataBuilderTest.java	92
v2/googlecloud-to-elasticsearch/src/test/resources/GCSToElasticsearch/elasticPyUdf.py	13
v2/googlecloud-to-elasticsearch/src/test/resources/GCSToElasticsearch/elasticUdf.js	13
v2/googlecloud-to-elasticsearch/src/test/resources/GCSToElasticsearch/elasticUdfES6.js	13
v2/googlecloud-to-elasticsearch/src/test/resources/JavascriptTextTransformer/transform.js	11
v2/googlecloud-to-elasticsearch/src/test/resources/PubSubToElasticsearch/transform.js	10
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/spanner/IntegrationTest.java	2
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/spanner/SpannerServerResource.java	64
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/spanner/SpannerTestHelper.java	97
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/DLPTextToBigQueryStreamingIT.java	225
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/DLPTextToBigQueryStreamingTest.java	109
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/PubSubToAvroIT.java	141
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/PubSubToBigQueryAutoIT.java	16
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/PubSubToBigQueryIT.java	351
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/PubsubToAvroLT.java	165
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/PubsubToAvroTest.java	36
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/PubsubToBigQueryLT.java	182
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/PubsubToBigQueryTest.java	64
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamsToGcsIT.java	252
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamsToGcsTest.java	418
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamsToPubSubIT.java	238
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamsToPubSubTest.java	550
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToBigQueryIT.java	172
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/TextIOToBigQueryIT.java	127
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/TextIOToBigQueryTest.java	137
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/TextIOtoBigQueryLT.java	142
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/TextToBigQueryStreamingIT.java	120
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/TextToBigQueryStreamingTest.java	54
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/BigtableChangeStreamsToBigQueryIT.java	369
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/TestUtil.java	28
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/model/BigQueryDestinationTest.java	171
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/schemautils/BigQueryUtilTest.java	444
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/BigtableChangeStreamsToGcsIT.java	421
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/BigtableUtilsTest.java	376
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/CharSequenceTypeAdapter.java	25
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/CommitTimeAwarePredicate.java	27
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/LookForBigtableRowAvroRecord.java	82
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/LookForChangelogEntryAvroRecord.java	42
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/LookForChangelogEntryJsonBase64Record.java	42
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/LookForChangelogEntryJsonRecord.java	40
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/Tools.java	20
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/BigtableChangeStreamsToPubSubIT.java	809
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstovectorsearch/BigtableChangeStreamsToVectorSearchIT.java	417
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstovectorsearch/UtilsTest.java	97
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstovectorsearch/VectorSearchResourceManager.java	232
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/pubsubtotext/PubsubToTextIT.java	118
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/pubsubtotext/PubsubToTextLT.java	166
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/pubsubtotext/PubsubToTextTest.java	37
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/BigQueryDeadLetterQueueSanitizerTest.java	48
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/BigQueryDynamicDestinationsTest.java	264
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/FailsafeModJsonToTableRowTransformerTest.java	746
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/OptionsUtilsTest.java	60
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/SchemaUpdateUtilsTest.java	194
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/SchemaUtilsTest.java	960
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/SpannerChangeStreamsToBigQueryIT.java	483
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/TestUtils.java	184
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/TypesUtilsTest.java	69
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/transforms/SpannerToBigQueryTransformTest.java	31
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToAvroTest.java	135
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToGcsAvroTest.java	125
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToGcsTextTest.java	124
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToJsonTest.java	111
v2/googlecloud-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/utils/FirestoreConvertersTest.java	263
v2/googlecloud-to-googlecloud/src/test/resources/JavascriptTextTransformerTest/transform.js	11
v2/googlecloud-to-googlecloud/src/test/resources/TextIOToBigQueryTest/pyudf.py	2
v2/googlecloud-to-googlecloud/src/test/resources/TextIOToBigQueryTest/udf.js	3
v2/googlecloud-to-googlecloud/src/test/resources/TextToBigQueryStreamingIT/pyudf.py	2
v2/googlecloud-to-googlecloud/src/test/resources/TextToBigQueryStreamingIT/udf.js	3
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/actions/function/CypherActionFnTest.java	64
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/actions/preload/PreloadCypherActionTest.java	51
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/database/CypherGeneratorTest.java	683
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/database/Neo4jCapabilitiesTest.java	28
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/database/Neo4jConnectionTest.java	149
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/model/InputValidatorTest.java	320
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/model/connection/ConnectionParamsTest.java	136
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/model/helpers/ActionMapperTest.java	202
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/model/helpers/CsvSourcesTest.java	48
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/model/helpers/JobSpecIndexTest.java	945
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/model/helpers/JobSpecMapperTest.java	257
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/model/helpers/MappingMapperTest.java	284
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/model/helpers/OptionsParamsMapperTest.java	17
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/model/helpers/SourceMapperTest.java	127
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/model/helpers/TargetMapperTest.java	1098
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/model/validation/BigQuerySourceProjectDatasetValidatorTest.java	46
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/model/validation/DuplicateAggregateFieldNameValidatorTest.java	56
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/model/validation/DuplicateTextHeaderValidatorTest.java	40
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/model/validation/InlineSourceDataValidatorTest.java	48
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/model/validation/TextColumnMappingValidatorTest.java	98
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/providers/text/LineToRowFnTest.java	54
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/providers/text/ListOfStringToRowFnTest.java	43
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/templates/Connections.java	15
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/templates/ConstraintsIndicesIT.java	292
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/templates/CustomNeo4jWriteQueryIT.java	97
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/templates/DataConversionIT.java	338
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/templates/EscapingIT.java	176
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/templates/GoogleToNeo4jTest.java	46
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/templates/InlineDataToNeo4jIT.java	98
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/templates/MovieImportIT.java	75
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/templates/PropertyMappingsIT.java	199
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/templates/Resources.java	14
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/templates/SecretManagerIT.java	71
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/templates/SinglePassGraphImportIT.java	198
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/templates/SyntheticFieldsIT.java	66
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/templates/ValidationIT.java	80
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/templates/package-info.java	1
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/transforms/Neo4jBlockingUnwindFnTest.java	51
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/transforms/Neo4jRowWriterTransformTest.java	78
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/utils/DataCastingUtilsTest.java	556
v2/googlecloud-to-neo4j/src/test/java/com/google/cloud/teleport/v2/neo4j/utils/ModelUtilsTest.java	677
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/job-spec-mapper-test/invalid-yaml.yaml	1
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/job-spec-mapper-test/valid-yaml-import-spec.yaml	58
v2/googlecloud-to-neo4j/src/test/resources/testing-specs/job-spec-mapper-test/valid-yaml-wrong-format-import-spec.yaml	58
v2/googlecloud-to-splunk/src/test/java/com/google/cloud/teleport/v2/coders/SplunkEventCoderTest.java	35
v2/googlecloud-to-splunk/src/test/java/com/google/cloud/teleport/v2/coders/SplunkWriteErrorCoderTest.java	29
v2/googlecloud-to-splunk/src/test/java/com/google/cloud/teleport/v2/templates/GCSToSplunkTest.java	194
v2/googlecloud-to-splunk/src/test/java/com/google/cloud/teleport/v2/transforms/SplunkConvertersTest.java	194
v2/googlecloud-to-splunk/src/test/resources/splunkUdf.js	9
v2/jdbc-and-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/JdbcToBigQueryIT.java	388
v2/jdbc-and-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/JdbcToBigQueryLT.java	147
v2/jdbc-and-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/JdbcToBigQueryReadWithPartitionsTest.java	190
v2/jdbc-and-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/JdbcToBigQueryTest.java	108
v2/jdbc-and-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/JdbcToPubSubAutoIT.java	9
v2/jdbc-and-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/JdbcToPubsubIT.java	124
v2/jdbc-and-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/JdbcToPubsubTest.java	45
v2/jdbc-and-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/PubsubToJdbcIT.java	104
v2/jdbc-common/src/test/java/com/google/cloud/teleport/v2/utils/JdbcConvertersTest.java	146
v2/jdbc-common/src/test/java/com/google/cloud/teleport/v2/utils/JsonStringToQueryMapperTest.java	38
v2/jms-to-pubsub/src/test/java/com/google/cloud/teleport/v2/templates/JmsToPubsubIT.java	153
v2/jms-to-pubsub/src/test/java/com/google/cloud/teleport/v2/templates/JmsToPubsubTest.java	22
v2/kafka-common/src/test/java/com/google/cloud/teleport/v2/kafka/utils/KafkaCommonUtilsTest.java	54
v2/kafka-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryAvroIT.java	240
v2/kafka-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryFlexAvroIT.java	523
v2/kafka-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryFlexJsonIT.java	204
v2/kafka-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryIT.java	190
v2/kafka-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryLT.java	196
v2/kafka-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryTest.java	85
v2/kafka-to-bigquery/src/test/resources/JavascriptTextTransformerTest/scriptParseException.js	4
v2/kafka-to-bigquery/src/test/resources/JavascriptTextTransformerTest/transform.js	11
v2/kafka-to-bigquery/src/test/resources/KafkaToBigQueryAvroIT/avro_schema.avsc	14
v2/kafka-to-bigquery/src/test/resources/KafkaToBigQueryFlexAvroIT/avro_schema.avsc	33
v2/kafka-to-bigquery/src/test/resources/KafkaToBigQueryFlexAvroIT/other_avro_schema.avsc	19
v2/kafka-to-gcs/src/test/java/com/google/cloud/teleport/v2/templates/KafkaToGCSTest.java	89
v2/kafka-to-gcs/src/test/java/com/google/cloud/teleport/v2/templates/KafkaToGcsAvroBinaryIT.java	155
v2/kafka-to-gcs/src/test/java/com/google/cloud/teleport/v2/templates/KafkaToGcsFlexJsonIT.java	112
v2/kafka-to-gcs/src/test/java/com/google/cloud/teleport/v2/templates/KafkaToGcsIT.java	137
v2/kafka-to-gcs/src/test/resources/KafkaToGcsAvroBinaryIT/avro_schema.avsc	15
v2/kafka-to-gcs/src/test/resources/KafkaToGcsIT/avro_schema.avsc	15
v2/kafka-to-kafka/src/test/java/com/google/cloud/teleport/v2/templates/KafkaToKafkaIT.java	104
v2/kafka-to-pubsub/src/test/java/com/google/cloud/teleport/v2/templates/KafkaToPubsubTest.java	54
v2/kinesis-to-pubsub/src/test/java/com/google/cloud/teleport/v2/templates/KinesisToPubsubTest.java	24
v2/kinesis-to-pubsub/src/test/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/kudu-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/KuduToBigQueryTest.java	87
v2/mongodb-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/mongodb/templates/MongoDbToBigQueryIT.java	221
v2/mongodb-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/mongodb/templates/package-info.java	1
v2/mqtt-to-pubsub/src/test/java/com/google/cloud/teleport/v2/templates/MqttToPubsubTest.java	48
v2/mqtt-to-pubsub/src/test/java/com/google/cloud/teleport/v2/templates/MqttToPubsubTestIT.java	112
v2/mqtt-to-pubsub/src/test/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/mysql-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/MySQLToBigQueryIT.java	118
v2/oracle-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/OracleToBigQueryIT.java	125
v2/postgresql-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLToBigQueryIT.java	150
v2/pubsub-binary-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/PubsubAvroToBigQueryIT.java	144
v2/pubsub-binary-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/PubsubProtoToBigQueryIT.java	362
v2/pubsub-binary-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/PubsubProtoToBigQueryTest.java	90
v2/pubsub-binary-to-bigquery/src/test/proto/User.proto	41
v2/pubsub-binary-to-bigquery/src/test/resources/PubsubAvroToBigQueryIT/avro_schema.avsc	23
v2/pubsub-cdc-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/PubSubCdcToBigQueryIT.java	195
v2/pubsub-cdc-to-bigquery/src/test/java/com/google/cloud/teleport/v2/templates/PubSubCdcToBigQueryTest.java	82
v2/pubsub-cdc-to-bigquery/src/test/resources/JavascriptTextTransformerTest/transform.js	11
v2/pubsub-to-jms/src/test/java/com/google/cloud/teleport/v2/templates/PubsubToJmsIT.java	146
v2/pubsub-to-jms/src/test/java/com/google/cloud/teleport/v2/templates/PubsubToJmsTest.java	22
v2/pubsub-to-kafka/src/test/java/com/google/cloud/teleport/v2/templates/PubsubToKafkaIT.java	106
v2/pubsub-to-kafka/src/test/java/com/google/cloud/teleport/v2/templates/PubsubToKafkaTest.java	14
v2/pubsub-to-mongodb/src/test/java/com/google/cloud/teleport/v2/templates/PubSubToMongoDBIT.java	250
v2/pubsub-to-mongodb/src/test/java/com/google/cloud/teleport/v2/templates/PubSubToMongoDBTest.java	228
v2/pubsub-to-mongodb/src/test/resources/PubSubToMongoDBTest/transform.js	10
v2/pubsub-to-redis/src/test/java/com/google/cloud/teleport/v2/templates/PubSubToRedisTest.java	94
v2/real-spanner-service/src/test/java/com/google/cloud/teleport/v2/spanner/service/SpannerServiceTest.java	14
v2/real-spanner-service/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerServiceFactoryImplTest.java	26
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/options/OptionsToConfigBuilderTest.java	274
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/FakeReader.java	34
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/auth/dbauth/GuardedStringValueProviderTest.java	15
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/auth/dbauth/LocalCredentialsProviderTest.java	20
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/CustomAsserts.java	21
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraConnectorTest.java	64
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraDataSourceTest.java	72
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraIOWrapperFactoryTest.java	124
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraIOWrapperHelperTest.java	170
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraIoWrapperTest.java	85
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraTableReaderFactoryCassandraIoImplTest.java	201
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/rowmapper/CassandraSourceRowMapperTest.java	172
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/schema/CassandraSchemaDiscoveryTest.java	212
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/schema/CassandraSchemaReferenceTest.java	23
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/testutils/EmbeddedCassandra.java	175
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/testutils/SharedEmbeddedCassandra.java	116
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/datasource/DataSourceTest.java	20
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/JdbcSchemaReferenceTest.java	33
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/DialectAdapterTest.java	46
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/ResourceUtilsTest.java	36
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/mysql/MysqlDialectAdapterTest.java	751
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/postgresql/PostgreSQLDialectAdapterTest.java	323
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/JdbcDataSourceTest.java	111
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/JdbcIoWrapperTest.java	436
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/config/TableConfigTest.java	42
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/JdbcSourceRowMapperTest.java	1023
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/columnboundary/ColumnForBoundaryQueryPreparedStatementSetterTest.java	115
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/columnboundary/ColumnForBoundaryQueryTest.java	37
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/BoundaryExtractorFactoryTest.java	203
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/BoundarySplitterFactoryTest.java	268
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/BoundaryTest.java	249
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/PartitionColumnTest.java	73
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/RangePreparedStatementSetterTest.java	151
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/RangeTest.java	252
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/stringmapper/BoundaryTypeMapperImplTest.java	89
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/stringmapper/CollationIndexTest.java	101
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/stringmapper/CollationMapperTest.java	403
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/stringmapper/CollationOrderRowTest.java	83
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/stringmapper/TestUtils.java	63
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/CollationMapperDoFnTest.java	105
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/CollationMapperTransformTest.java	159
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/InitialSplitRangeDoFnTest.java	50
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/MergeRangesDoFnTest.java	125
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeBoundaryDoFnTest.java	107
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeBoundaryTransformTest.java	99
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeClassifierDoFnTest.java	260
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeCombinerTest.java	55
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeCountDoFnTest.java	179
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeCountTransformTest.java	84
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/ReadWithUniformPartitionsTest.java	318
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/SplitRangeDoFnTest.java	40
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/TransformTestUtils.java	65
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/row/SerializableGenericRecordTest.java	86
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/row/SourceRowTest.java	45
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/SchemaDiscoveryImplTest.java	153
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/SchemaTestUtils.java	21
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/SourceColumnIndexInfoTest.java	53
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/SourceSchemaReferenceTest.java	29
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/SourceSchemaTest.java	25
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/SourceTableReferenceTest.java	28
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/SourceTableSchemaTest.java	55
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/UnifiedTypeMapperTest.java	31
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/MysqlMappingProviderTest.java	77
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/PostgreSQLMappingProviderTest.java	80
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/CustomLogicalTest.java	28
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/CustomSchemaTest.java	72
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/DecimalTest.java	32
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/SimpleUnifiedTypeMappingTest.java	26
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/UnifiedMappingProviderTest.java	127
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/UnsupportedTest.java	24
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/VarcharTest.java	28
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/transform/AccumulatingTableReaderTest.java	41
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/transform/ReaderTransformTest.java	24
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/source/reader/io/transform/ReaderTransformTestUtils.java	106
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/CassandraAllDataTypesIT.java	398
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/DbConfigContainerDefaultImplTest.java	32
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/IncrementTableCounterTest.java	42
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLCustomTransformationsNonShardedIT.java	106
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDDLIT.java	75
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLDataTypesIT.java	215
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLForeignKeyDependencyIT.java	62
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLIdentitySchemaMapperIT.java	76
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLIdentitySchemaMapperWithTransformationIT.java	84
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLSessionSchemaMapperIT.java	77
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLSessionSchemaMapperWithTableFilterIT.java	86
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLSessionSchemaMapperWithTransformationIT.java	87
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLSingleShardIT.java	72
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLSourceDBToSpannerWideRowInterleaveDepthIT.java	69
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLSourceDBToSpannerWideRowMaxColumnAndTableSizeIT.java	75
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLSourceDBToSpannerWideRowMaxSizeStringIT.java	74
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLSourceDbToSpannerSimpleIT.java	127
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLSourceDbToSpannerWideRowMaxColumnsTableKeyIT.java	74
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLSourceDbToSpannerWideRowMaxSizeTableKeyIT.java	68
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/MySQLToSpannerWiderowForMaxColumnsPerTableIT.java	114
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PipelineControllerTest.java	299
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLDataTypesIT.java	186
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLIdentitySchemaMapperIT.java	72
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLNamespaceIT.java	71
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/PostgreSQLReservedKeywordsIT.java	57
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/SourceDbToSpannerITBase.java	289
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/SourceDbToSpannerTest.java	23
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/TableSelectorTest.java	429
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/loadtesting/MySQLSourceDbToSpannerLT.java	57
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/loadtesting/MySQLSourceDbtoSpannerWideRow10MBPerCellLT.java	56
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/loadtesting/PostgreSQLSourceDbToSpannerLT.java	55
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/loadtesting/SourceDbToSpannerLTBase.java	171
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/transformer/SourceRowToMutationDoFnTest.java	311
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/utilities/ShardedMySQLResourceManager.java	44
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/writer/DeadLetterQueueTest.java	227
v2/sourcedb-to-spanner/src/test/java/com/google/cloud/teleport/v2/writer/SpannerWriterTest.java	42
v2/sourcedb-to-spanner/src/test/java/org/apache/beam/sdk/io/localcassandra/CassandraIOTest.java	625
v2/sourcedb-to-spanner/src/test/java/org/apache/beam/sdk/io/localcassandra/SplitGeneratorTest.java	107
v2/sourcedb-to-spanner/src/test/resources/CassandraUT/basicConfig.yaml	121
v2/sourcedb-to-spanner/src/test/resources/CassandraUT/basicTest.cql	323
v2/sourcedb-to-spanner/src/test/resources/CassandraUT/beamUTConfig.yaml	121
v2/sourcedb-to-spanner/src/test/resources/CustomTransformationsNonShardedIT/mysql-schema.sql	49
v2/sourcedb-to-spanner/src/test/resources/CustomTransformationsNonShardedIT/spanner-schema.sql	32
v2/sourcedb-to-spanner/src/test/resources/DDLIT/company-mysql-schema.sql	50
v2/sourcedb-to-spanner/src/test/resources/DDLIT/company-spanner-schema.sql	38
v2/sourcedb-to-spanner/src/test/resources/DataTypesIT/cassandra-spanner-schema.sql	84
v2/sourcedb-to-spanner/src/test/resources/DataTypesIT/mysql-data-types.sql	416
v2/sourcedb-to-spanner/src/test/resources/DataTypesIT/mysql-spanner-schema.sql	232
v2/sourcedb-to-spanner/src/test/resources/DataTypesIT/postgresql-data-types.sql	151
v2/sourcedb-to-spanner/src/test/resources/DataTypesIT/postgresql-spanner-schema.sql	75
v2/sourcedb-to-spanner/src/test/resources/ForeignKeyDependencyIT/mysql-schema.sql	59
v2/sourcedb-to-spanner/src/test/resources/ForeignKeyDependencyIT/spanner-schema.sql	39
v2/sourcedb-to-spanner/src/test/resources/NamespacesIT/postgresql-schema.sql	23
v2/sourcedb-to-spanner/src/test/resources/NamespacesIT/spanner-schema.sql	11
v2/sourcedb-to-spanner/src/test/resources/ReservedKeywordsIT/postgresql-schema.sql	150
v2/sourcedb-to-spanner/src/test/resources/ReservedKeywordsIT/spanner-schema.sql	147
v2/sourcedb-to-spanner/src/test/resources/SchemaMapperIT/company-mysql-schema.sql	38
v2/sourcedb-to-spanner/src/test/resources/SchemaMapperIT/company-postgresql-schema.sql	34
v2/sourcedb-to-spanner/src/test/resources/SchemaMapperIT/company-spanner-schema-with-transformation.sql	27
v2/sourcedb-to-spanner/src/test/resources/SchemaMapperIT/company-spanner-schema.sql	28
v2/sourcedb-to-spanner/src/test/resources/SingleShardWithTransformation/mysql-schema.sql	7
v2/sourcedb-to-spanner/src/test/resources/SingleShardWithTransformation/spanner-schema.sql	6
v2/sourcedb-to-spanner/src/test/resources/SourceDbToSpannerLT/WideRow/spanner-schema-10mib-per-cell.sql	4
v2/sourcedb-to-spanner/src/test/resources/SourceDbToSpannerLT/mysql-spanner-schema.sql	39
v2/sourcedb-to-spanner/src/test/resources/SourceDbToSpannerLT/postgresql-spanner-schema.sql	130
v2/sourcedb-to-spanner/src/test/resources/SourceDbToSpannerSimpleIT/spanner-schema.sql	8
v2/sourcedb-to-spanner/src/test/resources/WideRow/InterleaveDepthIT/mysql-schema.sql	68
v2/sourcedb-to-spanner/src/test/resources/WideRow/InterleaveDepthIT/spanner-schema.sql	55
v2/sourcedb-to-spanner/src/test/resources/WideRow/MaxColumnsTableKeyIT/mysql-schema.sql	35
v2/sourcedb-to-spanner/src/test/resources/WideRow/MaxColumnsTableKeyIT/spanner-schema.sql	23
v2/sourcedb-to-spanner/src/test/resources/WideRow/MaxSizeTableKey/mysql-schema.sql	15
v2/sourcedb-to-spanner/src/test/resources/WideRow/MaxSizeTableKey/spanner-schema.sql	6
v2/sourcedb-to-spanner/src/test/resources/WideRow/RowMaxSizeLimit/mysql-schema.sql	5
v2/sourcedb-to-spanner/src/test/resources/WideRow/RowMaxSizeLimit/spanner-schema.sql	4
v2/sourcedb-to-spanner/src/test/resources/WideRow/RowMaxSizeString/mysql-schema.sql	6
v2/sourcedb-to-spanner/src/test/resources/WideRow/RowMaxSizeString/spanner-schema.sql	4
v2/spanner-change-streams-to-sharded-file-sink/src/test/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamToGcsCustomShardIT.java	167
v2/spanner-change-streams-to-sharded-file-sink/src/test/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamToGcsITBase.java	140
v2/spanner-change-streams-to-sharded-file-sink/src/test/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamToGcsMultiShardIT.java	233
v2/spanner-change-streams-to-sharded-file-sink/src/test/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamToGcsSingleShardIT.java	246
v2/spanner-change-streams-to-sharded-file-sink/src/test/java/com/google/cloud/teleport/v2/templates/changestream/DataChangeRecordTypeConvertorTest.java	306
v2/spanner-change-streams-to-sharded-file-sink/src/test/java/com/google/cloud/teleport/v2/templates/transforms/AssignShardIdFnTest.java	294
v2/spanner-change-streams-to-sharded-file-sink/src/test/java/com/google/cloud/teleport/v2/templates/transforms/FilterRecordsFnTest.java	85
v2/spanner-change-streams-to-sharded-file-sink/src/test/java/com/google/cloud/teleport/v2/templates/transforms/PreprocessRecordsFnTest.java	73
v2/spanner-change-streams-to-sharded-file-sink/src/test/java/com/google/cloud/teleport/v2/templates/utils/JobMetadataUpdaterTest.java	53
v2/spanner-change-streams-to-sharded-file-sink/src/test/resources/SpannerChangeStreamToGcsCustomShardIT/spanner-schema.sql	10
v2/spanner-change-streams-to-sharded-file-sink/src/test/resources/SpannerChangeStreamToGcsMultiShardIT/spanner-schema.sql	13
v2/spanner-change-streams-to-sharded-file-sink/src/test/resources/SpannerChangeStreamToGcsSingleShardIT/spanner-schema.sql	44
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/ddl/DdlTest.java	843
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/ddl/DdlUtilityComponentsTest.java	13
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/ddl/InformationSchemaScannerTest.java	395
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/ddl/annotations/cassandra/CassandraAnnotationsTest.java	42
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/ddl/annotations/cassandra/CassandraTypeTest.java	28
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/exceptions/SpannerExceptionParserTest.java	169
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/avro/AvroJsonToCassandraMapConvertorTest.java	122
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/avro/AvroTestingHelper.java	112
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/avro/AvroToValueMapperTest.java	740
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/avro/GenericRecordTypeConvertorTest.java	1142
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventSessionConvertorTest.java	550
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventSpannerConvertorTest.java	318
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventToMapConvertorTest.java	146
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventTypeConvertorTest.java	608
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/metadata/CassandraSourceMetadataTest.java	103
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/schema/IdentityMapperTest.java	174
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SchemaFileOverrideTest.java	24
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SchemaFileOverridesParserTest.java	51
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SchemaStringOverridesParserTest.java	80
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SchemaTest.java	172
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SessionBasedMapperTest.java	324
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/schema/package-info.java	1
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/shard/CassandraShardTest.java	170
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/spanner/SpannerSchemaTest.java	79
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/utils/CassandraConfigFileReaderTest.java	67
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/utils/CassandraDriverConfigLoaderTest.java	150
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/utils/ChangeEventUtilsTest.java	33
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/utils/SessionFileReaderTest.java	257
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/utils/ShardFileReaderTest.java	208
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/utils/ShardingContextReaderTest.java	49
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/migrations/utils/TransformationContextReaderTest.java	44
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/transformation/CustomTransformationTest.java	28
v2/spanner-common/src/test/java/com/google/cloud/teleport/v2/spanner/type/TypeTest.java	40
v2/spanner-custom-shard/src/test/java/com/custom/CustomShardIdFetcherForITTest.java	21
v2/spanner-custom-shard/src/test/java/com/custom/CustomShardIdFetcherTest.java	16
v2/spanner-custom-shard/src/test/java/com/custom/CustomTransformationFetcherTest.java	49
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToCassandraLTBase.java	83
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToCassandraSourceDBCustomTransformationIT.java	163
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToCassandraSourceDbIT.java	2109
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToCassandraSourceDbMaxColumnsIT.java	166
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToCassandraSourceDbMaxColumnsSizeIT.java	187
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToCassandraSourceDbWideRow10MbIT.java	175
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToCassandraSourceLT.java	99
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToMySqlCustomTransformationLT.java	128
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToMySqlSourceDbWideRow10MbIT.java	184
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToMySqlSourceDbWideRowMaxColumnsIT.java	154
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToMySqlSourceLT.java	119
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToSourceDbCustomShardIT.java	187
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToSourceDbCustomTransformationIT.java	368
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToSourceDbDatatypeIT.java	250
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToSourceDbIT.java	188
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToSourceDbITBase.java	364
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToSourceDbInterleaveMultiShardIT.java	322
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToSourceDbLTBase.java	259
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToSourceDbTimezoneIT.java	155
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToSourceDbWideRowBasicIT.java	165
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/changestream/DataChangeRecordTypeConvertorTest.java	340
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/dbutils/connection/CassandraConnectionHelperTest.java	165
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/dbutils/connection/JdbcConnectionHelperTest.java	82
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/dbutils/dao/JdbcDaoTest.java	49
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/dbutils/dao/SpannerDaoTest.java	82
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/dbutils/dao/source/CassandraDaoTest.java	138
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/dbutils/dml/CassandraDMLGeneratorTest.java	853
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/dbutils/dml/CassandraTypeHandlerTest.java	1035
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/dbutils/dml/MySQLDMLGeneratorTest.java	860
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/dbutils/processor/SourceProcessorFactoryTest.java	88
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/transforms/AssignShardIdFnTest.java	832
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/transforms/ConvertChangeStreamErrorRecordToFailsafeElementFnTest.java	72
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/transforms/ConvertDlqRecordToTrimmedShardedDataChangeRecordFnTest.java	56
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/transforms/FilterRecordsFnTest.java	86
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/transforms/PreprocessRecordsFnTest.java	71
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/transforms/SourceWriterFnTest.java	809
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/transforms/UpdateDlqMetricsFnTest.java	31
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/utils/CassandraSourceSchemaReaderTest.java	63
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/utils/ShadowTableCreatorTest.java	179
v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/utils/ShardIdFetcherImplTest.java	235
v2/spanner-to-sourcedb/src/test/resources/SpannerToCassandraSourceIT/cassandra-schema.sql	216
v2/spanner-to-sourcedb/src/test/resources/SpannerToCassandraSourceIT/cassandra-transformation-schema.sql	9
v2/spanner-to-sourcedb/src/test/resources/SpannerToCassandraSourceIT/spanner-schema.sql	227
v2/spanner-to-sourcedb/src/test/resources/SpannerToCassandraSourceIT/spanner-transformation-schema.sql	13
v2/spanner-to-sourcedb/src/test/resources/SpannerToCassandraSourceLT/cassandra-schema.sql	9
v2/spanner-to-sourcedb/src/test/resources/SpannerToCassandraSourceLT/spanner-schema.sql	14
v2/spanner-to-sourcedb/src/test/resources/SpannerToMySqlSourceLT/mysql-schema.sql	10
v2/spanner-to-sourcedb/src/test/resources/SpannerToMySqlSourceLT/spanner-schema.sql	14
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbCustomShardIT/mysql-schema.sql	5
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbCustomShardIT/spanner-schema.sql	10
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbCustomTransformationIT/mysql-schema.sql	28
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbCustomTransformationIT/spanner-schema.sql	31
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbDatatypeIT/mysql-schema.sql	32
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbDatatypeIT/spanner-schema.sql	36
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbIT/mysql-schema.sql	9
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbIT/spanner-schema.sql	18
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbInterleaveMultiShardIT/mysql-schema.sql	12
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbInterleaveMultiShardIT/spanner-schema.sql	34
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbTimezoneIT/mysql-schema.sql	4
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbTimezoneIT/spanner-schema.sql	9
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbWideRowIT/cassandra-10mb-schema.sql	4
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbWideRowIT/mysql-10mb-schema.sql	4
v2/spanner-to-sourcedb/src/test/resources/SpannerToSourceDbWideRowIT/spanner-16mb-schema.sql	9
v2/sqlserver-to-googlecloud/src/test/java/com/google/cloud/teleport/v2/templates/SQLServerToBigQueryIT.java	136
v2/streaming-data-generator/src/test/java/com/google/cloud/teleport/v2/templates/StreamingDataGeneratorIT.java	345
v2/streaming-data-generator/src/test/java/com/google/cloud/teleport/v2/templates/StreamingDataGeneratorLT.java	248
v2/streaming-data-generator/src/test/java/com/google/cloud/teleport/v2/templates/StreamingDataGeneratorTest.java	311
yaml/src/test/java/com/google/cloud/teleport/templates/yaml/KafkaToBigQueryYamlIT.java	158
yaml/src/test/java/com/google/cloud/teleport/templates/yaml/package-info.java	1