Path	Lines of Code
it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/LoadTestBase.java	367
it/google-cloud-platform/src/main/java/org/apache/beam/it/jdbc/StaticJDBCResource.java	55
it/splunk/src/main/java/org/apache/beam/it/splunk/CustomSplunkResourceManager.java	247
it/splunk/src/main/java/org/apache/beam/it/splunk/conditions/CustomSplunkEventsCheck.java	63
plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/model/ImageSpec.java	59
plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/PromoteHelper.java	228
plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesReleaseMojo.java	164
plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesRunMojo.java	285
plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesStageMojo.java	1198
v1/src/main/java/com/google/cloud/teleport/bigtable/CassandraToBigtable.java	202
v1/src/main/java/com/google/cloud/teleport/spanner/AvroSchemaToDdlConverter.java	656
v1/src/main/java/com/google/cloud/teleport/spanner/CSVRecordToMutation.java	228
v1/src/main/java/com/google/cloud/teleport/spanner/ExportPipeline.java	217
v1/src/main/java/com/google/cloud/teleport/spanner/ExportTransform.java	841
v1/src/main/java/com/google/cloud/teleport/spanner/ImportPipeline.java	187
v1/src/main/java/com/google/cloud/teleport/spanner/SpannerRecordConverter.java	423
v1/src/main/java/com/google/cloud/teleport/spanner/TextImportPipeline.java	233
v1/src/main/java/com/google/cloud/teleport/spanner/TextImportTransform.java	502
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/ForeignKey.java	132
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/InformationSchemaScanner.java	1746
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/BatchSpannerRead.java	218
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/CreateTransactionFn.java	31
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationCellCounter.java	26
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationGroup.java	56
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationKeyEncoder.java	189
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationSizeEstimator.java	173
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationUtils.java	371
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/NaiveSpannerRead.java	135
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/OrderedCode.java	450
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/ReadOperation.java	85
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/ReadSpannerSchema.java	135
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerAccessor.java	251
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerConfig.java	202
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerIO.java	1602
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerQuerySourceDef.java	33
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerReadSchemaTransformProvider.java	213
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerSchema.java	185
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerSchemaRetrievalException.java	9
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerSourceDef.java	6
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerTableSourceDef.java	39
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerTransformRegistrar.java	315
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerWriteResult.java	45
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerWriteSchemaTransformProvider.java	212
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/StructUtils.java	413
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/Transaction.java	15
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action/QueryChangeStreamAction.java	191
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/templates/TextToSpanner.java	364
v1/src/main/java/com/google/cloud/teleport/templates/common/BigQueryConverters.java	339
v1/src/main/java/com/google/cloud/teleport/templates/common/BigQueryDynamicConverters.java	110
v1/src/main/java/com/google/cloud/teleport/templates/common/SpannerConverters.java	714
v1/src/main/java/com/google/cloud/teleport/templates/common/SubprocessTextTransformer.java	290
v2/bigtable-changestreams-to-hbase/src/main/java/com/google/cloud/teleport/v2/templates/BigtableChangeStreamsToHBase.java	159
v2/cdc-parent/cdc-embedded-connector/src/main/java/com/google/cloud/dataflow/cdc/connector/DebeziumSourceRecordToDataflowCdcFormatTranslator.java	257
v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/dlq/BigQueryDeadLetterQueueSanitizer.java	29
v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/dlq/DeadLetterQueueSanitizer.java	40
v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/dlq/FileBasedDeadLetterQueueReconsumer.java	167
v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/dlq/PubSubDeadLetterQueueSanitizer.java	36
v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/dlq/StringDeadLetterQueueSanitizer.java	19
v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/mappers/BigQueryMapper.java	254
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryDynamicConverters.java	103
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/JsonStringToMutationFn.java	82
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/PythonTextTransformer.java	394
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryTableToGcsTransform.java	217
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/values/DataplexCompression.java	56
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/cdc/merge/MergeConfiguration.java	75
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/io/CdcJdbcIO.java	403
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/transforms/FormatDatastreamJsonToJson.java	174
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/transforms/FormatDatastreamRecordToJson.java	522
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/utils/DataStreamClient.java	461
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/values/DmlInfo.java	46
v2/datastream-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/BigQueryDynamicConverters.java	104
v2/datastream-to-mongodb/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToMongoDB.java	195
v2/datastream-to-postgres/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToPostgres.java	164
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToSpanner.java	785
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/SpannerTransactionWriterDoFn.java	377
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/MySqlChangeEventSequence.java	123
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/OracleChangeEventSequence.java	93
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/PostgresChangeEventSequence.java	108
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ShadowTableReadUtils.java	82
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/spanner/ProcessInformationSchema.java	201
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/transform/ChangeEventTransformerDoFn.java	236
v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/utils/DatastreamToDML.java	448
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dao/MySqlDao.java	122
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/PubSubToBigQueryAuto.java	40
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/BigtableUtils.java	278
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/SchemaUpdateUtils.java	96
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/JobSpecMapper.java	120
v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/JdbcToBigQueryOptions.java	224
v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/JdbcToPubSubAuto.java	29
v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryFlex.java	470
v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryDynamicDestination.java	55
v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryWriteUtils.java	375
v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/transforms/AvroWriteTransform.java	171
v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/transforms/JsonWriteTransform.java	65
v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/transforms/WriteTransform.java	72
v2/pubsub-binary-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/PubsubAvroToBigQuery.java	110
v2/pubsub-cdc-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/PubSubCdcToBigQuery.java	389
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/options/OptionsToConfigBuilder.java	229
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/auth/dbauth/GuardedStringValueProvider.java	38
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/JdbcIoWrapper.java	349
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/config/defaults/MySqlConfigDefaults.java	51
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/row/SerializableGenericRecord.java	53
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/PostgreSQLMappingProvider.java	61
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/SourceDbToSpanner.java	83
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/transformer/SourceRowToMutationDoFn.java	95
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/writer/DeadLetterQueue.java	224
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/transforms/FilterRecordsFn.java	23
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/avro/AvroToValueMapper.java	406
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/avro/GenericRecordTypeConvertor.java	538
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventTypeConvertor.java	210
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/JarFileReader.java	49
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/ShardFileReader.java	198
v2/spanner-custom-shard/src/main/java/com/custom/CustomTransformationWithShardForLiveIT.java	198
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/changestream/DataChangeRecordTypeConvertor.java	113
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/processor/InputRecordProcessor.java	110
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/FilterRecordsFn.java	23