Path	Lines of Code
v2/astradb-to-bigquery/src/main/java/com/google/cloud/teleport/v2/astradb/options/AstraDbToBigQueryOptions.java	91
v2/astradb-to-bigquery/src/main/java/com/google/cloud/teleport/v2/astradb/options/package-info.java	1
v2/astradb-to-bigquery/src/main/java/com/google/cloud/teleport/v2/astradb/templates/AstraDbToBigQuery.java	161
v2/astradb-to-bigquery/src/main/java/com/google/cloud/teleport/v2/astradb/templates/package-info.java	1
v2/astradb-to-bigquery/src/main/java/com/google/cloud/teleport/v2/astradb/transforms/AstraDbToBigQueryMappingFn.java	101
v2/astradb-to-bigquery/src/main/java/com/google/cloud/teleport/v2/astradb/transforms/package-info.java	1
v2/astradb-to-bigquery/terraform/AstraDB_To_BigQuery/dataflow_job.tf	183
v2/azure-eventhub-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/AzureEventhubToPubsub.java	130
v2/azure-eventhub-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/azure-eventhub-to-pubsub/terraform/Azure_Eventhub_to_PubSub/dataflow_job.tf	159
v2/bigquery-to-bigtable/src/main/java/com/google/cloud/teleport/v2/templates/BigQueryToBigtable.java	79
v2/bigquery-to-bigtable/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/bigquery-to-bigtable/terraform/BigQuery_to_Bigtable/dataflow_job.tf	237
v2/bigquery-to-parquet/src/main/java/com/google/cloud/teleport/v2/templates/BigQueryToParquet.java	188
v2/bigquery-to-parquet/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/bigquery-to-parquet/terraform/BigQuery_to_Parquet/dataflow_job.tf	167
v2/bigtable-changestreams-to-hbase/src/main/java/com/google/cloud/teleport/v2/templates/BigtableChangeStreamsToHBase.java	159
v2/bigtable-changestreams-to-hbase/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/bigtable-changestreams-to-hbase/src/main/java/com/google/cloud/teleport/v2/templates/transforms/ChangeStreamToRowMutations.java	149
v2/bigtable-changestreams-to-hbase/src/main/java/com/google/cloud/teleport/v2/templates/transforms/package-info.java	1
v2/bigtable-changestreams-to-hbase/src/main/java/com/google/cloud/teleport/v2/templates/utils/RowMutationsBuilder.java	203
v2/bigtable-changestreams-to-hbase/src/main/java/com/google/cloud/teleport/v2/templates/utils/package-info.java	1
v2/bigtable-changestreams-to-hbase/terraform/Bigtable_Change_Streams_to_HBase/dataflow_job.tf	278
v2/bigtable-common/src/main/java/com/google/cloud/teleport/v2/bigtable/options/BigtableCommonOptions.java	231
v2/bigtable-common/src/main/java/com/google/cloud/teleport/v2/bigtable/options/package-info.java	1
v2/bigtable-common/src/main/java/com/google/cloud/teleport/v2/bigtable/transforms/BigtableConverters.java	43
v2/bigtable-common/src/main/java/com/google/cloud/teleport/v2/bigtable/transforms/package-info.java	1
v2/bigtable-common/src/main/java/com/google/cloud/teleport/v2/bigtable/utils/BigtableConfig.java	79
v2/bigtable-common/src/main/java/com/google/cloud/teleport/v2/bigtable/utils/UnsupportedEntryException.java	19
v2/bigtable-common/src/main/java/com/google/cloud/teleport/v2/bigtable/utils/package-info.java	1
v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/BigQueryAction.java	35
v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/BigQueryChangeApplier.java	204
v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/BigQuerySchemaUtils.java	56
v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/BigQueryStatementIssuingFn.java	89
v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/CdcPCollectionsFetchers.java	163
v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/CdcToBigQueryChangeApplierPipeline.java	150
v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/ChangelogTableDynamicDestinations.java	89
v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/DecodeRows.java	37
v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/KeySchemasByTableFn.java	25
v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/MergeStatementBuildingFn.java	201
v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/PubsubUtils.java	94
v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/package-info.java	1
v2/cdc-parent/cdc-change-applier/terraform/Cdc_To_BigQuery_Template/dataflow_job.tf	199
v2/cdc-parent/cdc-common/src/main/java/com/google/cloud/dataflow/cdc/common/DataCatalogSchemaUtils.java	237
v2/cdc-parent/cdc-common/src/main/java/com/google/cloud/dataflow/cdc/common/DataflowCdcRowFormat.java	8
v2/cdc-parent/cdc-common/src/main/java/com/google/cloud/dataflow/cdc/common/SchemaUtils.java	106
v2/cdc-parent/cdc-common/src/main/java/com/google/cloud/dataflow/cdc/common/package-info.java	1
v2/cdc-parent/cdc-embedded-connector/src/main/java/com/google/cloud/dataflow/cdc/connector/App.java	129
v2/cdc-parent/cdc-embedded-connector/src/main/java/com/google/cloud/dataflow/cdc/connector/DebeziumSourceRecordToDataflowCdcFormatTranslator.java	257
v2/cdc-parent/cdc-embedded-connector/src/main/java/com/google/cloud/dataflow/cdc/connector/DebeziumToPubSubDataSender.java	180
v2/cdc-parent/cdc-embedded-connector/src/main/java/com/google/cloud/dataflow/cdc/connector/PubSubChangeConsumer.java	133
v2/cdc-parent/cdc-embedded-connector/src/main/java/com/google/cloud/dataflow/cdc/connector/package-info.java	1
v2/common/src/main/java/com/google/cloud/teleport/v2/auto/blocks/BlockConstants.java	13
v2/common/src/main/java/com/google/cloud/teleport/v2/auto/blocks/PubsubMessageToTableRow.java	97
v2/common/src/main/java/com/google/cloud/teleport/v2/auto/blocks/ReadFromPubSub.java	33
v2/common/src/main/java/com/google/cloud/teleport/v2/auto/blocks/RowToJSONString.java	21
v2/common/src/main/java/com/google/cloud/teleport/v2/auto/blocks/WriteToBigQuery.java	150
v2/common/src/main/java/com/google/cloud/teleport/v2/auto/blocks/WriteToPubSub.java	35
v2/common/src/main/java/com/google/cloud/teleport/v2/auto/blocks/package-info.java	1
v2/common/src/main/java/com/google/cloud/teleport/v2/auto/dlq/AutoDLQUtil.java	25
v2/common/src/main/java/com/google/cloud/teleport/v2/auto/dlq/BigQueryDeadletterOptions.java	17
v2/common/src/main/java/com/google/cloud/teleport/v2/auto/dlq/WriteDlqToBigQuery.java	59
v2/common/src/main/java/com/google/cloud/teleport/v2/auto/dlq/package-info.java	1
v2/common/src/main/java/com/google/cloud/teleport/v2/auto/options/ReadFromJdbcOptions.java	126
v2/common/src/main/java/com/google/cloud/teleport/v2/auto/options/package-info.java	1
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/DeadLetterQueueManager.java	111
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/PubSubNotifiedDlqIO.java	65
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/dlq/package-info.java	1
v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/mappers/BigQueryDefaultSchemas.java	39
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/cdc/mappers/BigQueryMappers.java	70
v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/mappers/BigQueryTableRowCleaner.java	60
v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/mappers/package-info.java	1
v2/common/src/main/java/com/google/cloud/teleport/v2/coders/FailsafeElementCoder.java	66
v2/common/src/main/java/com/google/cloud/teleport/v2/coders/GenericRecordCoder.java	41
v2/common/src/main/java/com/google/cloud/teleport/v2/coders/package-info.java	1
v2/common/src/main/java/com/google/cloud/teleport/v2/common/CommonTemplateJvmInitializer.java	130
v2/common/src/main/java/com/google/cloud/teleport/v2/common/UncaughtExceptionLogger.java	16
v2/common/src/main/java/com/google/cloud/teleport/v2/common/package-info.java	1
v2/common/src/main/java/com/google/cloud/teleport/v2/io/WindowedFilenamePolicy.java	236
v2/common/src/main/java/com/google/cloud/teleport/v2/io/package-info.java	1
v2/common/src/main/java/com/google/cloud/teleport/v2/options/BigQueryCommonOptions.java	64
v2/common/src/main/java/com/google/cloud/teleport/v2/options/BigQueryStorageApiBatchOptions.java	26
v2/common/src/main/java/com/google/cloud/teleport/v2/options/BigQueryStorageApiStreamingOptions.java	56
v2/common/src/main/java/com/google/cloud/teleport/v2/options/CommonTemplateOptions.java	30
v2/common/src/main/java/com/google/cloud/teleport/v2/options/PubsubCommonOptions.java	41
v2/common/src/main/java/com/google/cloud/teleport/v2/options/WindowedFilenamePolicyOptions.java	106
v2/common/src/main/java/com/google/cloud/teleport/v2/options/package-info.java	1
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/AccumulateListFn.java	37
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/AvroConverters.java	172
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryConverters.java	571
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/CsvConverters.java	574
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/DLQWriteTransform.java	82
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/ErrorConverters.java	436
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/FailsafeElementTransforms.java	76
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/JavascriptTextTransformer.java	365
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/JsonConverters.java	169
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/KeyValueToGenericRecordFn.java	44
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/NoopTransform.java	17
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/ParquetConverters.java	177
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/PubSubToFailSafeElement.java	18
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/PythonExternalTextTransformer.java	286
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/PythonTextTransformer.java	394
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/UDFTextTransformer.java	96
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/WriteToGCSAvro.java	119
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/WriteToGCSParquet.java	102
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/WriteToGCSText.java	121
v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/package-info.java	1
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/BigQueryIOUtils.java	63
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/BigQueryTableCache.java	51
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/DurationUtils.java	28
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/FileFormat.java	15
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/GCSAwareValueProvider.java	34
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/GCSUtils.java	82
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/KMSUtils.java	56
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/MappedObjectCache.java	67
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/MetadataValidator.java	50
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/ResourceUtils.java	22
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/SchemaUtils.java	171
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/SecretManagerUtils.java	25
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/SerializableSchemaSupplier.java	46
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/SpannerUtils.java	163
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/StreamingModeUtils.java	33
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/WriteToGCSUtility.java	25
v2/common/src/main/java/com/google/cloud/teleport/v2/utils/package-info.java	1
v2/common/src/main/java/com/google/cloud/teleport/v2/values/FailsafeElement.java	74
v2/common/src/main/java/com/google/cloud/teleport/v2/values/SpannerSchema.java	80
v2/common/src/main/java/com/google/cloud/teleport/v2/values/package-info.java	1
v2/common/src/main/resources/udf-samples/enrich.js	5
v2/common/src/main/resources/udf-samples/enrich_log.js	31
v2/common/src/main/resources/udf-samples/filter.js	7
v2/common/src/main/resources/udf-samples/route.js	7
v2/common/src/main/resources/udf-samples/transform.js	11
v2/common/src/main/resources/udf-samples/transform_csv.js	11
v2/common/src/main/resources/udf-samples/transform_log.js	9
v2/common/src/main/resources/udf-samples/transform_log_splunk.js	12
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/clients/DataplexClient.java	27
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/clients/DataplexClientFactory.java	10
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/clients/DefaultDataplexClient.java	243
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/clients/package-info.java	1
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/io/AvroSinkWithJodaDatesConversion.java	70
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/io/package-info.java	1
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/options/DataplexBigQueryToGcsOptions.java	129
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/options/DataplexJdbcIngestionOptions.java	214
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/options/DataplexUpdateMetadataOptions.java	17
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/options/package-info.java	1
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/templates/DataplexBigQueryToGcs.java	299
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/templates/DataplexFileFormatConversion.java	659
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/templates/DataplexJdbcIngestion.java	395
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/transforms/BeamRowToGenericRecordFn.java	18
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryTableToGcsTransform.java	217
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/transforms/DataplexBigQueryToGcsUpdateMetadata.java	214
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/transforms/DataplexJdbcIngestionUpdateMetadata.java	52
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/transforms/DeleteBigQueryDataFn.java	122
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/transforms/GenericRecordsToGcsPartitioned.java	147
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/transforms/package-info.java	1
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/BigQueryMetadataLoader.java	158
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/BigQueryToGcsDirectoryNaming.java	20
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/BigQueryToGcsFileNaming.java	28
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/BigQueryUtils.java	46
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/DataplexBigQueryToGcsFilter.java	163
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/DataplexJdbcIngestionFilter.java	103
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/DataplexJdbcIngestionNaming.java	24
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/DataplexJdbcPartitionUtils.java	100
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/DataplexUtils.java	316
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/DataplexWriteDisposition.java	20
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/SchemaConversionException.java	9
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/Schemas.java	156
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/package-info.java	1
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/values/BigQueryTable.java	70
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/values/BigQueryTablePartition.java	23
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/values/DataplexCompression.java	56
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/values/DataplexEnums.java	68
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/values/DataplexPartitionMetadata.java	41
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/values/GetEntityRequestEntityView.java	8
v2/dataplex/src/main/java/com/google/cloud/teleport/v2/values/package-info.java	1
v2/dataplex/terraform/Dataplex_BigQuery_to_GCS/dataflow_job.tf	209
v2/dataplex/terraform/Dataplex_File_Format_Conversion/dataflow_job.tf	172
v2/dataplex/terraform/Dataplex_JDBC_Ingestion/dataflow_job.tf	251
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/cdc/merge/BigQueryMergeValidatorTemplate.java	86
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/cdc/merge/BigQueryMerger.java	197
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/cdc/merge/MergeInfo.java	153
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/cdc/merge/MergeStatementBuilder.java	189
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/cdc/merge/package-info.java	1
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/io/package-info.java	1
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/mappers/DataStreamMapper.java	101
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/mappers/MergeInfoMapper.java	115
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/mappers/package-info.java	1
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/sources/DataStreamIO.java	332
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/sources/ReadFileRangesFn.java	87
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/sources/package-info.java	1
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/FormatDatastreamRecord.java	77
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/transforms/package-info.java	1
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/utils/DataStreamPkCache.java	22
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/utils/package-info.java	1
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/values/DatastreamRow.java	138
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/values/DmlInfo.java	46
v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/values/package-info.java	1
v2/datastream-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/BigQueryDeadLetterQueueSanitizer.java	30
v2/datastream-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/BigQueryDynamicConverters.java	104
v2/datastream-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToBigQuery.java	487
v2/datastream-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/datastream-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/StatefulRowCleaner.java	160
v2/datastream-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/package-info.java	1
v2/datastream-to-bigquery/terraform/Cloud_Datastream_to_BigQuery/dataflow_job.tf	320
v2/datastream-to-mongodb/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToMongoDB.java	195
v2/datastream-to-mongodb/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/datastream-to-postgres/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToPostgres.java	164
v2/datastream-to-postgres/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/datastream-to-postgres/src/main/java/com/google/cloud/teleport/v2/transforms/CreateDml.java	48
v2/datastream-to-postgres/src/main/java/com/google/cloud/teleport/v2/transforms/ProcessDml.java	73
v2/datastream-to-postgres/src/main/java/com/google/cloud/teleport/v2/transforms/package-info.java	1
v2/datastream-to-postgres/src/main/java/com/google/cloud/teleport/v2/utils/DatabaseMigrationUtils.java	456
v2/datastream-to-postgres/src/main/java/com/google/cloud/teleport/v2/utils/package-info.java	1
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/MetricUpdaterDoFn.java	30
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/SpannerTransactionWriter.java	111
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/constants/DatastreamToSpannerConstants.java	20
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/constants/package-info.java	1
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventContext.java	57
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventContextFactory.java	47
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventConvertor.java	136
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventSequence.java	12
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventSequenceCreationException.java	6
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventSequenceFactory.java	60
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/DatastreamConstants.java	116
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/MySqlChangeEventContext.java	49
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/OracleChangeEventContext.java	42
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/PostgresChangeEventContext.java	42
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/datastream/package-info.java	1
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/spanner/DatastreamToSpannerExceptionClassifier.java	34
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/spanner/ShadowTableCreator.java	62
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/spanner/package-info.java	1
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/transform/ChangeEventTransformerDoFn.java	236
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/transform/package-info.java	1
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/utils/WatchdogRunnable.java	43
v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/utils/package-info.java	1
v2/datastream-to-spanner/terraform/Cloud_Datastream_to_Spanner/dataflow_job.tf	279
v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToSQL.java	277
v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/transforms/CreateDml.java	63
v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/transforms/ProcessDml.java	71
v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/transforms/package-info.java	1
v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/utils/DatastreamToDML.java	448
v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/utils/DatastreamToMySQLDML.java	47
v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/utils/DatastreamToPostgresDML.java	166
v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/utils/package-info.java	1
v2/datastream-to-sql/terraform/Cloud_Datastream_to_SQL/dataflow_job.tf	219
v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options/ElasticsearchWriteOptions.java	256
v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options/package-info.java	1
v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms/ValueExtractorTransform.java	83
v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms/WriteToElasticsearch.java	187
v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms/package-info.java	1
v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/utils/BulkInsertMethod.java	7
v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/utils/ConnectionInformation.java	90
v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/utils/Dataset.java	15
v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/utils/ElasticsearchIO.java	1067
v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/utils/ElasticsearchIndex.java	12
v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/utils/ElasticsearchUtils.java	16
v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/utils/package-info.java	1
v2/failure-injected-spanner-service/src/main/java/com/google/cloud/teleport/v2/spanner/service/SpannerService.java	83
v2/failure-injected-spanner-service/src/main/java/com/google/cloud/teleport/v2/spanner/service/package-info.java	1
v2/failure-injected-spanner-service/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerServiceFactoryImpl.java	10
v2/failure-injected-spanner-service/src/main/java/org/apache/beam/sdk/io/gcp/spanner/package-info.java	1
v2/failure-injection-policies/src/main/java/com/google/cloud/teleport/v2/failureinjection/AlwaysFailPolicy.java	9
v2/failure-injection-policies/src/main/java/com/google/cloud/teleport/v2/failureinjection/ErrorInjectionPolicy.java	4
v2/failure-injection-policies/src/main/java/com/google/cloud/teleport/v2/failureinjection/ErrorInjectionPolicyFactory.java	6
v2/failure-injection-policies/src/main/java/com/google/cloud/teleport/v2/failureinjection/package-info.java	1
v2/file-format-conversion/src/main/java/com/google/cloud/teleport/v2/templates/FileFormatConversion.java	103
v2/file-format-conversion/src/main/java/com/google/cloud/teleport/v2/templates/FileFormatConversionFactory.java	133
v2/file-format-conversion/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/file-format-conversion/terraform/File_Format_Conversion/dataflow_job.tf	224
v2/flex-wordcount-python/wordcount.py	125
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/GCSToSourceDb.java	307
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/common/ProcessingContext.java	99
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/common/ShardProgress.java	21
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/common/TrimmedShardedDataChangeRecord.java	139
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/common/package-info.java	1
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/constants/Constants.java	11
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/constants/package-info.java	1
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dao/DaoFactory.java	19
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dao/MySqlDao.java	122
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dao/SpannerDao.java	335
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dao/package-info.java	1
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/processing/dml/DMLGenerator.java	373
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/processing/dml/package-info.java	1
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/processing/handler/GCSToSourceStreamingHandler.java	151
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/processing/handler/InputRecordProcessor.java	135
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/processing/handler/package-info.java	1
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/processing/package-info.java	1
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/GcsToSourceStreamer.java	179
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/package-info.java	1
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/GCSReader.java	190
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/ProcessingContextGenerator.java	224
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/ShardFileCreationTracker.java	67
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/ShardProgressTracker.java	102
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/SpannerToGcsJobMetadataFetcher.java	32
v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/package-info.java	1
v2/gcs-to-sourcedb/terraform/GCS_to_Sourcedb/dataflow_job.tf	216
v2/google-ads-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/GoogleAdsToBigQuery.java	169
v2/google-ads-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/google-ads-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/GoogleAdsRowToReportRowJsonFn.java	92
v2/google-ads-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/package-info.java	1
v2/google-ads-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/utils/GoogleAdsRateLimitPolicyFactory.java	39
v2/google-ads-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/utils/GoogleAdsUtils.java	65
v2/google-ads-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/utils/package-info.java	1
v2/google-ads-to-googlecloud/terraform/Google_Ads_to_BigQuery/dataflow_job.tf	203
v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options/BigQueryToElasticsearchOptions.java	7
v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options/GCSToElasticsearchOptions.java	28
v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options/PubSubToElasticsearchOptions.java	55
v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options/package-info.java	1
v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates/BigQueryToElasticsearch.java	124
v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates/GCSToElasticsearch.java	183
v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates/PubSubToElasticsearch.java	177
v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates/package-info.java	1
v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms/EventMetadataBuilder.java	147
v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms/FailedPubsubMessageToPubsubTopicFn.java	49
v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms/ProcessEventMetadata.java	21
v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms/ProcessFailsafePubSubFn.java	44
v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms/PubSubMessageToJsonDocument.java	108
v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms/PubsubMessageToFailsafeElementFn.java	14
v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms/package-info.java	1
v2/googlecloud-to-elasticsearch/terraform/BigQuery_to_Elasticsearch/dataflow_job.tf	338
v2/googlecloud-to-elasticsearch/terraform/GCS_to_Elasticsearch/dataflow_job.tf	366
v2/googlecloud-to-elasticsearch/terraform/PubSub_to_Elasticsearch/dataflow_job.tf	337
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/avro/AvroPubsubMessageRecord.java	63
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/avro/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/BigtableChangeStreamToBigQueryOptions.java	111
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/BigtableChangeStreamsToGcsOptions.java	130
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/BigtableChangeStreamsToPubSubOptions.java	138
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/BigtableChangeStreamsToVectorSearchOptions.java	165
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/SpannerChangeStreamsToBigQueryOptions.java	190
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/SpannerChangeStreamsToGcsOptions.java	140
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/SpannerChangeStreamsToPubSubOptions.java	185
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/SpannerToBigQueryOptions.java	72
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/DLPTextToBigQueryStreaming.java	592
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/FirestoreToBigQuery.java	177
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/PubSubToBigQuery.java	334
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/PubsubToAvro.java	160
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamsToGcs.java	131
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamsToPubSub.java	149
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/SpannerToBigQuery.java	84
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/TextIOToBigQuery.java	361
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/TextToBigQueryStreaming.java	382
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/BigQueryDeadLetterQueueSanitizer.java	29
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/BigtableChangeStreamsToBigQuery.java	285
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/model/BigQueryDestination.java	136
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/model/ChangelogColumn.java	74
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/model/Mod.java	204
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/model/ModType.java	14
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/model/TransientColumn.java	31
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/model/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/schemautils/BigQueryUtils.java	240
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/schemautils/BigQueryValueFormatter.java	5
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/schemautils/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/BigtableChangeStreamMutationToChangelogEntryFn.java	17
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/BigtableChangeStreamsToGcs.java	247
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/BigtableChangelogEntryToBigtableRowFn.java	21
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/bigtablechangestreamstogcs/FileFormatFactoryBigtableChangeStreams.java	82
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/WriteChangeStreamMutationToGcsAvro.java	128
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/WriteChangeStreamMutationsToGcsText.java	117
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/WriteChangelogEntryAsJson.java	62
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/model/BigtableSchemaFormat.java	5
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/model/ChangelogColumns.java	28
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/model/DestinationInfo.java	30
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/model/ModType.java	20
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/model/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/BigtableChangeStreamsToPubSub.java	532
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/FailsafePublisher.java	150
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/model/MessageEncoding.java	5
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/model/MessageFormat.java	6
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/model/Mod.java	190
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/model/ModType.java	14
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/model/PubSubDestination.java	64
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/model/PubSubFields.java	27
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/model/TestChangeStreamMutation.java	73
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/model/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/schemautils/PubSubUtils.java	363
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/schemautils/PubSubValueFormatter.java	5
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/schemautils/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstovectorsearch/BigtableChangeStreamsToVectorSearch.java	220
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstovectorsearch/ChangeStreamMutationToDatapointOperationFn.java	170
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstovectorsearch/DatapointOperationFn.java	28
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstovectorsearch/RemoveDatapointsFn.java	30
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstovectorsearch/UpsertDatapointsFn.java	32
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstovectorsearch/Utils.java	58
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstovectorsearch/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/pubsubtotext/PubsubToText.java	164
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/pubsubtotext/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/BigQueryDeadLetterQueueSanitizer.java	20
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/BigQueryDynamicDestinations.java	203
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/FailsafeModJsonToTableRowTransformer.java	354
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/SpannerChangeStreamsToBigQuery.java	421
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/model/Mod.java	185
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/model/ModColumnType.java	69
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/model/TrackedSpannerColumn.java	15
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/model/TrackedSpannerTable.java	113
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/model/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/BigQueryUtils.java	62
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/OptionsUtils.java	39
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/SchemaUpdateUtils.java	96
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/SpannerChangeStreamsUtils.java	430
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/SpannerToBigQueryUtils.java	275
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/TypesUtils.java	93
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/FileFormatFactorySpannerChangeStreams.java	66
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/FileFormatFactorySpannerChangeStreamsToPubSub.java	165
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/PublishToPubSubDoFn.java	62
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/SpannerToBigQueryTransform.java	24
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToAvro.java	188
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToGcsAvro.java	120
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToGcsText.java	117
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToJson.java	74
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/utils/BigtableSource.java	90
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/utils/FirestoreConverters.java	692
v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/utils/package-info.java	1
v2/googlecloud-to-googlecloud/src/main/proto/changelogentrymessage-text.proto	25
v2/googlecloud-to-googlecloud/src/main/proto/changelogentrymessageproto.proto	25
v2/googlecloud-to-googlecloud/src/main/resources/schema/avro/bigtablerow.avsc	23
v2/googlecloud-to-googlecloud/src/main/resources/schema/avro/changelogentry-text.avsc	25
v2/googlecloud-to-googlecloud/src/main/resources/schema/avro/changelogentry.avsc	25
v2/googlecloud-to-googlecloud/src/main/resources/schema/avro/changelogentrymessage.avsc	27
v2/googlecloud-to-googlecloud/src/main/resources/schema/avro/datachangerecord.avsc	90
v2/googlecloud-to-googlecloud/terraform/Bigtable_Change_Streams_to_BigQuery/dataflow_job.tf	267
v2/googlecloud-to-googlecloud/terraform/Bigtable_Change_Streams_to_Google_Cloud_Storage/dataflow_job.tf	275
v2/googlecloud-to-googlecloud/terraform/Bigtable_Change_Streams_to_PubSub/dataflow_job.tf	279
v2/googlecloud-to-googlecloud/terraform/Cloud_PubSub_to_Avro_Flex/dataflow_job.tf	221
v2/googlecloud-to-googlecloud/terraform/Cloud_PubSub_to_GCS_Text_Flex/dataflow_job.tf	222
v2/googlecloud-to-googlecloud/terraform/Cloud_Spanner_to_BigQuery_Flex/dataflow_job.tf	208
v2/googlecloud-to-googlecloud/terraform/Firestore_to_BigQuery_Flex/dataflow_job.tf	209
v2/googlecloud-to-googlecloud/terraform/GCS_Text_to_BigQuery_Flex/dataflow_job.tf	183
v2/googlecloud-to-googlecloud/terraform/PubSub_to_BigQuery_Auto/dataflow_job.tf	221
v2/googlecloud-to-googlecloud/terraform/PubSub_to_BigQuery_Flex/dataflow_job.tf	210
v2/googlecloud-to-googlecloud/terraform/Spanner_Change_Streams_to_BigQuery/dataflow_job.tf	274
v2/googlecloud-to-googlecloud/terraform/Spanner_Change_Streams_to_Google_Cloud_Storage/dataflow_job.tf	235
v2/googlecloud-to-googlecloud/terraform/Spanner_Change_Streams_to_PubSub/dataflow_job.tf	229
v2/googlecloud-to-googlecloud/terraform/Stream_DLP_GCS_Text_to_BigQuery_Flex/dataflow_job.tf	198
v2/googlecloud-to-googlecloud/terraform/Stream_GCS_Text_to_BigQuery_Flex/dataflow_job.tf	208
v2/googlecloud-to-mongodb/src/main/java/com/google/cloud/teleport/v2/mongodb/options/BigQueryToMongoDbOptions.java	41
v2/googlecloud-to-mongodb/src/main/java/com/google/cloud/teleport/v2/mongodb/options/package-info.java	1
v2/googlecloud-to-mongodb/src/main/java/com/google/cloud/teleport/v2/mongodb/templates/BigQueryToMongoDb.java	76
v2/googlecloud-to-mongodb/src/main/java/com/google/cloud/teleport/v2/mongodb/templates/package-info.java	1
v2/googlecloud-to-mongodb/terraform/BigQuery_to_MongoDB/dataflow_job.tf	159
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/ActionDoFnFactory.java	22
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/ActionPreloadFactory.java	27
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/function/BigQueryActionFn.java	39
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/function/CypherActionFn.java	79
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/function/HttpActionFn.java	37
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/function/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/preload/PreloadAction.java	8
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/preload/PreloadBigQueryAction.java	37
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/preload/PreloadCypherAction.java	78
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/preload/PreloadHttpAction.java	36
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/preload/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/database/CypherGenerator.java	376
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/database/CypherPatterns.java	183
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/database/Neo4jCapabilities.java	157
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/database/Neo4jConnection.java	176
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/database/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/logicaltypes/IsoDateTime.java	39
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/logicaltypes/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/InputValidator.java	40
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/Json.java	91
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/connection/BasicConnectionParams.java	63
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/connection/BearerConnectionParams.java	53
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/connection/ConnectionParams.java	45
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/connection/CustomConnectionParams.java	80
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/connection/KerberosConnectionParams.java	53
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/connection/NoAuthConnectionParams.java	27
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/connection/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/enums/ArtifactType.java	8
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/enums/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/ActionMapper.java	107
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/BigQuerySpec.java	66
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/CsvSources.java	30
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/JobSpecIndex.java	273
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/JobSpecMapper.java	120
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/JsonObjects.java	32
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/MappingListener.java	374
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/MappingMapper.java	443
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/MappingVisitor.java	55
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/OptionsParamsMapper.java	17
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/SourceMapper.java	87
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/TargetMapper.java	259
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/TargetQuerySpec.java	130
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/TargetSequence.java	13
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/job/ActionContext.java	24
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/job/OptionsParams.java	27
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/job/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/sources/BigQuerySource.java	68
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/sources/BigQuerySourceProvider.java	19
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/sources/ExternalTextSource.java	55
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/sources/InlineTextSource.java	35
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/sources/TextFormat.java	13
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/sources/TextSource.java	42
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/sources/TextSourceProvider.java	40
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/sources/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/validation/BigQuerySourceProjectDatasetValidator.java	33
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/validation/DuplicateAggregateFieldNameValidator.java	70
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/validation/DuplicateTextHeaderValidator.java	83
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/validation/InlineSourceDataValidator.java	78
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/validation/NodeKeyValidator.java	32
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/validation/NodeMatchModeValidator.java	29
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/validation/TextColumnMappingValidator.java	77
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/validation/WriteModeValidator.java	36
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/validation/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/options/Neo4jFlexTemplateOptions.java	61
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/options/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/Provider.java	15
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/ProviderFactory.java	19
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/bigquery/BigQueryImpl.java	85
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/bigquery/BqQueryToRow.java	48
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/bigquery/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/LineToRowFn.java	37
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/ListOfStringToRowFn.java	32
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/TextImpl.java	40
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/TextSourceFileMetadataToRow.java	20
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/TextSourceFileToRow.java	62
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/TextTargetToRow.java	69
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/telemetry/Neo4jTelemetry.java	31
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/telemetry/ReportedSourceType.java	50
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/telemetry/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/templates/GoogleCloudToNeo4j.java	479
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/templates/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/transforms/CastExpandTargetRowFn.java	40
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/transforms/Neo4jBlockingUnwindFn.java	124
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/transforms/Neo4jRowWriterTransform.java	212
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/transforms/package-info.java	1
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/BeamBlock.java	55
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/BeamUtils.java	137
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/DataCastingUtils.java	496
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/FileSystemUtils.java	17
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/HttpUtils.java	82
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/ModelUtils.java	208
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/ProcessingCoder.java	17
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/SerializableSupplier.java	5
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/TextParserUtils.java	69
v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/package-info.java	1
v2/googlecloud-to-neo4j/terraform/Google_Cloud_to_Neo4j/dataflow_job.tf	186
v2/googlecloud-to-splunk/src/main/java/com/google/cloud/teleport/v2/coders/SplunkEventCoder.java	68
v2/googlecloud-to-splunk/src/main/java/com/google/cloud/teleport/v2/coders/SplunkWriteErrorCoder.java	51
v2/googlecloud-to-splunk/src/main/java/com/google/cloud/teleport/v2/coders/package-info.java	1
v2/googlecloud-to-splunk/src/main/java/com/google/cloud/teleport/v2/templates/GCSToSplunk.java	281
v2/googlecloud-to-splunk/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/googlecloud-to-splunk/src/main/java/com/google/cloud/teleport/v2/transforms/SplunkConverters.java	249
v2/googlecloud-to-splunk/src/main/java/com/google/cloud/teleport/v2/transforms/package-info.java	1
v2/googlecloud-to-splunk/src/main/java/com/google/cloud/teleport/v2/values/SplunkTokenSource.java	6
v2/googlecloud-to-splunk/src/main/java/com/google/cloud/teleport/v2/values/package-info.java	1
v2/googlecloud-to-splunk/terraform/GCS_To_Splunk/dataflow_job.tf	272
v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/io/DynamicJdbcIO.java	121
v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/io/package-info.java	1
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/options/JdbcToPubsubOptions.java	91
v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/PubsubToJdbcOptions.java	109
v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/package-info.java	1
v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/JdbcToBigQuery.java	246
v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/JdbcToPubSubAuto.java	29
v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/JdbcToPubsub.java	109
v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/PubsubToJdbc.java	103
v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/jdbc-and-googlecloud/terraform/Jdbc_to_BigQuery_Flex/dataflow_job.tf	282
v2/jdbc-and-googlecloud/terraform/Jdbc_to_PubSub/dataflow_job.tf	200
v2/jdbc-and-googlecloud/terraform/Jdbc_to_PubSub_Auto/dataflow_job.tf	218
v2/jdbc-and-googlecloud/terraform/Pubsub_to_Jdbc/dataflow_job.tf	205
v2/jdbc-common/src/main/java/com/google/cloud/teleport/v2/auto/blocks/ReadFromJdbc.java	74
v2/jdbc-common/src/main/java/com/google/cloud/teleport/v2/auto/blocks/package-info.java	1
v2/jdbc-common/src/main/java/com/google/cloud/teleport/v2/utils/JdbcConverters.java	101
v2/jdbc-common/src/main/java/com/google/cloud/teleport/v2/utils/JdbcIngestionWriteDisposition.java	39
v2/jdbc-common/src/main/java/com/google/cloud/teleport/v2/utils/JsonStringToQueryMapper.java	31
v2/jdbc-common/src/main/java/com/google/cloud/teleport/v2/utils/package-info.java	1
v2/jms-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/JmsToPubsub.java	155
v2/jms-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/jms-to-pubsub/terraform/Jms_to_PubSub/dataflow_job.tf	170
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/auth/GcpLoginCallbackHandler.java	131
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/auth/package-info.java	1
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/dlq/BigQueryDeadLetterQueue.java	65
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/dlq/BigQueryDeadLetterQueueOptions.java	30
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/dlq/package-info.java	1
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/options/KafkaCommonOptions.java	19
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/options/KafkaReadOptions.java	225
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/options/KafkaWriteOptions.java	178
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/options/SchemaRegistryOptions.java	201
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/options/package-info.java	1
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/AvroDynamicTransform.java	91
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/AvroTransform.java	83
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/BinaryAvroDeserializer.java	33
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/BinaryAvroSerializer.java	37
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/KafkaRecordErrorConverters.java	68
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/KafkaRecordToGenericRecordFailsafeElementFn.java	103
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/KafkaTransform.java	114
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/SchemaKafkaAvroDeserializer.java	36
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/package-info.java	1
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/utils/FileAwareConsumerFactoryFn.java	16
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/utils/FileAwareFactoryFn.java	89
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/utils/FileAwareProducerFactoryFn.java	16
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/utils/FileAwareSchemaRegistryFactoryFn.java	14
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/utils/KafkaCommonUtils.java	105
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/utils/KafkaConfig.java	170
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/utils/KafkaTopicUtils.java	30
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/utils/SslProducerFactoryFn.java	69
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/utils/package-info.java	1
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/values/KafkaAuthenticationMethod.java	9
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/values/KafkaTemplateParameters.java	12
v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/values/package-info.java	1
v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/options/KafkaToBigQueryFlexOptions.java	192
v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/options/package-info.java	1
v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQuery.java	471
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/templates/package-info.java	1
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-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/StringMessageToTableRow.java	104
v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/package-info.java	1
v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/utils/BigQueryAvroUtils.java	444
v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/utils/BigQueryConstants.java	5
v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/utils/package-info.java	1
v2/kafka-to-bigquery/terraform/Kafka_to_BigQuery/dataflow_job.tf	189
v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/options/KafkaToGCSOptions.java	62
v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/options/package-info.java	1
v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToGCS.java	86
v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToGcsFlex.java	151
v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/transforms/AvroDestination.java	32
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/FileFormatFactory.java	88
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/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/transforms/package-info.java	1
v2/kafka-to-gcs/terraform/Kafka_to_GCS/dataflow_job.tf	178
v2/kafka-to-kafka/src/main/java/com/google/cloud/teleport/v2/options/package-info.java	1
v2/kafka-to-kafka/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToKafka.java	148
v2/kafka-to-kafka/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/kafka-to-pubsub/src/main/java/com/google/cloud/teleport/v2/kafka/consumer/SslConsumerFactoryFn.java	72
v2/kafka-to-pubsub/src/main/java/com/google/cloud/teleport/v2/kafka/consumer/Utils.java	89
v2/kafka-to-pubsub/src/main/java/com/google/cloud/teleport/v2/kafka/consumer/package-info.java	1
v2/kafka-to-pubsub/src/main/java/com/google/cloud/teleport/v2/options/KafkaToPubsubOptions.java	48
v2/kafka-to-pubsub/src/main/java/com/google/cloud/teleport/v2/options/package-info.java	1
v2/kafka-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/KafkaPubsubConstants.java	15
v2/kafka-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToPubsub.java	107
v2/kafka-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/kafka-to-pubsub/src/main/java/com/google/cloud/teleport/v2/transforms/FormatTransform.java	70
v2/kafka-to-pubsub/src/main/java/com/google/cloud/teleport/v2/transforms/package-info.java	1
v2/kinesis-to-pubsub/src/main/java/com/google/cloud/teleport/v2/options/KinesisToPubsubOptions.java	66
v2/kinesis-to-pubsub/src/main/java/com/google/cloud/teleport/v2/options/package-info.java	1
v2/kinesis-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/KinesisToPubsub.java	78
v2/kinesis-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/kinesis-to-pubsub/src/main/java/com/google/cloud/teleport/v2/transforms/KinesisDataTransforms.java	16
v2/kinesis-to-pubsub/src/main/java/com/google/cloud/teleport/v2/transforms/package-info.java	1
v2/kinesis-to-pubsub/terraform/Kinesis_To_Pubsub/dataflow_job.tf	170
v2/kudu-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KuduToBigQuery.java	100
v2/kudu-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/options/MongoDbToBigQueryOptions.java	114
v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/options/package-info.java	1
v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/templates/MongoDbCdcToBigQuery.java	150
v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/templates/MongoDbToBigQuery.java	134
v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/templates/MongoDbUtils.java	215
v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/templates/package-info.java	1
v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/JavascriptDocumentTransformer.java	175
v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/package-info.java	1
v2/mongodb-to-googlecloud/terraform/MongoDB_to_BigQuery/dataflow_job.tf	197
v2/mongodb-to-googlecloud/terraform/MongoDB_to_BigQuery_CDC/dataflow_job.tf	226
v2/mqtt-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/MqttToPubsub.java	129
v2/mqtt-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/mqtt-to-pubsub/terraform/Mqtt_to_PubSub/dataflow_job.tf	165
v2/mysql-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/MySQLToBigQueryOptions.java	20
v2/mysql-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/package-info.java	1
v2/mysql-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/MySQLToBigQuery.java	24
v2/mysql-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/mysql-to-googlecloud/terraform/Jdbc_to_PubSub/dataflow_job.tf	200
v2/mysql-to-googlecloud/terraform/Jdbc_to_PubSub_Auto/dataflow_job.tf	218
v2/mysql-to-googlecloud/terraform/MySQL_to_BigQuery/dataflow_job.tf	272
v2/oracle-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/OracleToBigQueryOptions.java	20
v2/oracle-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/package-info.java	1
v2/oracle-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/OracleToBigQuery.java	24
v2/oracle-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/oracle-to-googlecloud/terraform/Jdbc_to_PubSub/dataflow_job.tf	200
v2/oracle-to-googlecloud/terraform/Jdbc_to_PubSub_Auto/dataflow_job.tf	218
v2/oracle-to-googlecloud/terraform/Oracle_to_BigQuery/dataflow_job.tf	272
v2/postgresql-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/PostgreSQLToBigQueryOptions.java	20
v2/postgresql-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/package-info.java	1
v2/postgresql-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/PostgreSQLToBigQuery.java	24
v2/postgresql-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/postgresql-to-googlecloud/terraform/Jdbc_to_PubSub/dataflow_job.tf	200
v2/postgresql-to-googlecloud/terraform/Jdbc_to_PubSub_Auto/dataflow_job.tf	218
v2/postgresql-to-googlecloud/terraform/PostgreSQL_to_BigQuery/dataflow_job.tf	272
v2/pubsub-binary-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/PubsubAvroToBigQuery.java	110
v2/pubsub-binary-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/PubsubProtoToBigQuery.java	376
v2/pubsub-binary-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/pubsub-binary-to-bigquery/terraform/PubSub_Avro_to_BigQuery/dataflow_job.tf	198
v2/pubsub-binary-to-bigquery/terraform/PubSub_Proto_to_BigQuery/dataflow_job.tf	239
v2/pubsub-cdc-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/PubSubCdcToBigQuery.java	389
v2/pubsub-cdc-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/pubsub-cdc-to-bigquery/terraform/PubSub_CDC_to_BigQuery/dataflow_job.tf	270
v2/pubsub-to-jms/src/main/java/com/google/cloud/teleport/v2/templates/PubsubToJms.java	143
v2/pubsub-to-jms/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/pubsub-to-jms/terraform/Pubsub_to_Jms/dataflow_job.tf	170
v2/pubsub-to-kafka/src/main/java/com/google/cloud/teleport/v2/options/PubsubToKafkaOptions.java	50
v2/pubsub-to-kafka/src/main/java/com/google/cloud/teleport/v2/options/package-info.java	1
v2/pubsub-to-kafka/src/main/java/com/google/cloud/teleport/v2/templates/PubsubKafkaConstants.java	12
v2/pubsub-to-kafka/src/main/java/com/google/cloud/teleport/v2/templates/PubsubToKafka.java	126
v2/pubsub-to-kafka/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/pubsub-to-kafka/src/main/java/com/google/cloud/teleport/v2/transforms/FormatMessageTransform.java	46
v2/pubsub-to-kafka/src/main/java/com/google/cloud/teleport/v2/transforms/package-info.java	1
v2/pubsub-to-kafka/terraform/PubSub_to_Kafka/dataflow_job.tf	190
v2/pubsub-to-mongodb/src/main/java/com/google/cloud/teleport/v2/templates/PubSubToMongoDB.java	422
v2/pubsub-to-mongodb/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/pubsub-to-mongodb/terraform/Cloud_PubSub_to_MongoDB/dataflow_job.tf	225
v2/pubsub-to-redis/src/main/java/com/google/cloud/teleport/v2/templates/PubSubToRedis.java	226
v2/pubsub-to-redis/src/main/java/com/google/cloud/teleport/v2/templates/io/RedisHashIO.java	120
v2/pubsub-to-redis/src/main/java/com/google/cloud/teleport/v2/templates/io/package-info.java	1
v2/pubsub-to-redis/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/pubsub-to-redis/src/main/java/com/google/cloud/teleport/v2/templates/transforms/MessageTransformation.java	137
v2/pubsub-to-redis/src/main/java/com/google/cloud/teleport/v2/templates/transforms/package-info.java	1
v2/pubsub-to-redis/terraform/Cloud_PubSub_to_Redis/dataflow_job.tf	204
v2/real-spanner-service/src/main/java/com/google/cloud/teleport/v2/spanner/service/SpannerService.java	14
v2/real-spanner-service/src/main/java/com/google/cloud/teleport/v2/spanner/service/package-info.java	1
v2/real-spanner-service/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerServiceFactoryImpl.java	10
v2/real-spanner-service/src/main/java/org/apache/beam/sdk/io/gcp/spanner/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/constants/MetricCounters.java	9
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/constants/SourceDbToSpannerConstants.java	9
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/constants/package-info.java	1
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/options/SourceDbToSpannerOptions.java	214
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/options/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/IoWrapperFactory.java	7
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/Reader.java	7
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/ReaderImpl.java	31
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/auth/dbauth/DbAuth.java	7
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/auth/dbauth/LocalCredentialsProvider.java	33
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/auth/dbauth/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/auth/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/IoWrapper.java	12
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraConnector.java	42
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraDataSource.java	91
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraDefaults.java	9
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraIOWrapperFactory.java	34
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraIOWrapperHelper.java	123
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraIoWrapper.java	47
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraTableReaderFactory.java	13
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraTableReaderFactoryCassandraIoImpl.java	128
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/mappings/CassandraMappings.java	112
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/mappings/CassandraMappingsProvider.java	168
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/mappings/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/rowmapper/CassandraFieldMapper.java	22
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/rowmapper/CassandraRowMapper.java	57
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/rowmapper/CassandraRowValueArrayMapper.java	22
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/rowmapper/CassandraRowValueExtractor.java	9
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/rowmapper/CassandraRowValueMapMapper.java	33
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/rowmapper/CassandraRowValueMapper.java	8
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/rowmapper/CassandraSourceRowMapper.java	47
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/rowmapper/CassandraSourceRowMapperFactoryFn.java	20
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/rowmapper/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/schema/CassandraSchemaDiscovery.java	149
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/schema/CassandraSchemaReference.java	20
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/schema/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/datasource/DataSource.java	19
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/datasource/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/exception/RetriableSchemaDiscoveryException.java	6
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/exception/SchemaDiscoveryException.java	6
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/exception/SchemaDiscoveryRetriesExhaustedException.java	6
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/exception/SuitableIndexNotFoundException.java	7
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/exception/ValueMappingException.java	6
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/exception/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/JdbcSchemaReference.java	27
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/DialectAdapter.java	49
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/ResourceUtils.java	37
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/mysql/MysqlDialectAdapter.java	499
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/mysql/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/postgresql/PostgreSQLDialectAdapter.java	384
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/postgresql/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/JdbcDataSource.java	82
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/JdbcIOWrapperConfig.java	176
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/config/SQLDialect.java	6
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/config/TableConfig.java	32
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/jdbc/iowrapper/config/defaults/PostgreSQLConfigDefaults.java	25
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/config/defaults/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/config/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/jdbc/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/JdbcSourceRowMapper.java	80
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/JdbcValueMapper.java	24
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/JdbcValueMappingsProvider.java	6
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/ResultSetValueExtractor.java	9
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/ResultSetValueMapper.java	10
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/provider/MysqlJdbcValueMappings.java	168
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/provider/PostgreSQLJdbcValueMappings.java	136
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/provider/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/UniformSplitterDBAdapter.java	13
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/columnboundary/ColumnForBoundaryQuery.java	37
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/columnboundary/ColumnForBoundaryQueryPreparedStatementSetter.java	25
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/columnboundary/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/Boundary.java	148
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/BoundaryExtractor.java	12
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/BoundaryExtractorFactory.java	121
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/BoundarySplitter.java	12
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/BoundarySplitterFactory.java	138
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/BoundaryTypeMapper.java	15
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/PartitionColumn.java	42
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/Range.java	223
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/RangePreparedStatementSetter.java	45
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/stringmapper/BoundaryTypeMapperImpl.java	65
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/stringmapper/CollationIndex.java	165
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/stringmapper/CollationMapper.java	201
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/stringmapper/CollationOrderRow.java	87
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/stringmapper/CollationReference.java	19
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/stringmapper/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/CollationMapperDoFn.java	55
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/CollationMapperTransform.java	65
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/InitialSplitRangeDoFn.java	59
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/MergeRangesDoFn.java	76
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeBoundaryDoFn.java	92
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeBoundaryTransform.java	53
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeClassifierDoFn.java	91
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeCombiner.java	36
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeCountDoFn.java	120
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeCountTransform.java	53
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/ReadWithUniformPartitions.java	355
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/SplitRangeDoFn.java	16
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/UnflattenRangesDoFn.java	11
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/package-info.java	1
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/row/SourceRow.java	75
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/row/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/RetriableSchemaDiscovery.java	20
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/SchemaDiscovery.java	21
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/SchemaDiscoveryImpl.java	72
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/SourceColumnIndexInfo.java	71
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/SourceSchema.java	22
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/SourceSchemaReference.java	32
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/SourceTableReference.java	31
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/SourceTableSchema.java	85
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/UnifiedTypeMapper.java	46
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/UnifiedTypeMapping.java	7
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/MysqlMappingProvider.java	52
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/source/reader/io/schema/typemapping/provider/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/Array.java	17
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/CustomLogical.java	25
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/CustomSchema.java	121
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/Decimal.java	17
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/SimpleUnifiedTypeMapping.java	19
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/UnifiedMappingProvider.java	88
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/Unsupported.java	18
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/Varchar.java	20
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/transform/AccumulatingTableReader.java	81
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/transform/ReaderTransform.java	46
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/transform/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/DbConfigContainer.java	14
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/DbConfigContainerDefaultImpl.java	29
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/IncrementTableCounter.java	72
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/MigrateTableTransform.java	110
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/PipelineController.java	274
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/RowContext.java	34
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/templates/TableSelector.java	178
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
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/transformer/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/writer/DeadLetterQueue.java	224
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/writer/SpannerWriter.java	48
v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/writer/package-info.java	1
v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/CassandraIO.java	699
v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/ConnectionManager.java	59
v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/DefaultObjectMapper.java	27
v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/DefaultObjectMapperFactory.java	23
v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/ReadFn.java	116
v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/RingRange.java	56
v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/SplitGenerator.java	120
v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/package-info.java	1
v2/sourcedb-to-spanner/src/main/resources/sql/mysql_collation_order_query.sql	104
v2/sourcedb-to-spanner/src/main/resources/sql/postgresql_collation_order_query.sql	50
v2/sourcedb-to-spanner/src/main/scripts/create_simple_shard_config.bash	60
v2/sourcedb-to-spanner/terraform/Sourcedb_to_Spanner_Flex/dataflow_job.tf	236
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamsToShardedFileSink.java	421
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/changestream/DataChangeRecordConvertorException.java	12
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/changestream/DataChangeRecordTypeConvertor.java	133
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/changestream/package-info.java	1
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/common/TrimmedShardedDataChangeRecord.java	139
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/common/package-info.java	1
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/constants/Constants.java	10
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/constants/package-info.java	1
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/transforms/AssignShardIdFn.java	419
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/transforms/ChangeDataProgressTrackerFn.java	71
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/transforms/FileProgressTrackerFn.java	69
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/transforms/FilterRecordsFn.java	23
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/transforms/PreprocessRecordsFn.java	26
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/transforms/WriterGCS.java	106
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/transforms/package-info.java	1
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/utils/DataSeenTracker.java	48
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/utils/FileCreationTracker.java	44
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/utils/InformationSchemaReader.java	30
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/utils/JobMetadataUpdater.java	15
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/utils/ShardIdFetcherImpl.java	71
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/utils/ShardingLogicImplFetcher.java	68
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/utils/SpannerDao.java	420
v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/utils/package-info.java	1
v2/spanner-change-streams-to-sharded-file-sink/terraform/Spanner_Change_Streams_to_Sharded_File_Sink/dataflow_job.tf	250
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/CheckConstraint.java	48
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Column.java	360
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Ddl.java	288
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/DdlUtilityComponents.java	17
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/ForeignKey.java	69
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Index.java	147
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/IndexColumn.java	130
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/InformationSchemaScanner.java	501
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Table.java	228
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/annotations/cassandra/CassandraAnnotations.java	41
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/annotations/cassandra/CassandraList.java	15
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/annotations/cassandra/CassandraMap.java	16
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/annotations/cassandra/CassandraSet.java	15
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/annotations/cassandra/CassandraType.java	49
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/annotations/cassandra/package-info.java	1
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/annotations/package-info.java	1
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/package-info.java	1
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/avro/AvroJsonToCassandraMapConvertor.java	163
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/avro/package-info.java	1
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/constants/Constants.java	13
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/constants/package-info.java	1
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventSessionConvertor.java	218
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventSpannerConvertor.java	189
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventToMapConvertor.java	99
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/convertors/package-info.java	1
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/exceptions/AvroTypeConvertorException.java	12
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/exceptions/ChangeEventConvertorException.java	12
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/exceptions/DroppedTableException.java	12
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/exceptions/InvalidChangeEventException.java	9
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/exceptions/InvalidOptionsException.java	12
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/exceptions/SpannerExceptionParser.java	114
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/exceptions/SpannerMigrationException.java	54
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/exceptions/package-info.java	1
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/metadata/CassandraSourceMetadata.java	105
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/metadata/SpannerToGcsJobMetadata.java	15
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/metadata/package-info.java	1
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/ColumnPK.java	35
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/ISchemaMapper.java	26
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/ISchemaOverridesParser.java	5
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/IdentityMapper.java	105
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/NameAndCols.java	36
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/NoopSchemaOverridesParser.java	12
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/Schema.java	207
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SchemaFileOverride.java	18
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SchemaFileOverridesParser.java	47
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SchemaStringOverridesParser.java	131
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SessionBasedMapper.java	262
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SourceColumnDefinition.java	35
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SourceColumnType.java	45
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SourceTable.java	86
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SpannerColumnDefinition.java	35
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SpannerColumnType.java	35
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SpannerTable.java	86
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SyntheticPKey.java	35
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/package-info.java	1
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/shard/CassandraShard.java	73
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/shard/Shard.java	157
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/shard/ShardingContext.java	20
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/shard/package-info.java	1
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/spanner/SpannerSchema.java	89
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/spanner/package-info.java	1
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/transformation/CustomTransformation.java	31
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/transformation/TransformationContext.java	19
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/transformation/package-info.java	1
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/CassandraConfigFileReader.java	25
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/CassandraDriverConfigLoader.java	130
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/ChangeEventUtils.java	25
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/CustomTransformationImplFetcher.java	61
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/ISecretManagerAccessor.java	4
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/SecretManagerAccessorImpl.java	7
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/SessionFileReader.java	61
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/ShardFileReader.java	198
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/ShardingContextReader.java	39
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/TransformationContextReader.java	40
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/package-info.java	1
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/type/Type.java	334
v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/type/package-info.java	1
v2/spanner-custom-shard/src/main/java/com/custom/CustomShardIdFetcher.java	18
v2/spanner-custom-shard/src/main/java/com/custom/CustomShardIdFetcherForIT.java	25
v2/spanner-custom-shard/src/main/java/com/custom/CustomTransformationFetcher.java	50
v2/spanner-custom-shard/src/main/java/com/custom/CustomTransformationWithCassandraForIT.java	35
v2/spanner-custom-shard/src/main/java/com/custom/CustomTransformationWithShardForBulkIT.java	121
v2/spanner-custom-shard/src/main/java/com/custom/CustomTransformationWithShardForLiveIT.java	198
v2/spanner-custom-shard/src/main/java/com/custom/package-info.java	1
v2/spanner-migrations-sdk/src/main/java/com/google/cloud/teleport/v2/spanner/exceptions/InvalidTransformationException.java	12
v2/spanner-migrations-sdk/src/main/java/com/google/cloud/teleport/v2/spanner/exceptions/package-info.java	1
v2/spanner-migrations-sdk/src/main/java/com/google/cloud/teleport/v2/spanner/utils/IShardIdFetcher.java	5
v2/spanner-migrations-sdk/src/main/java/com/google/cloud/teleport/v2/spanner/utils/ISpannerMigrationTransformer.java	9
v2/spanner-migrations-sdk/src/main/java/com/google/cloud/teleport/v2/spanner/utils/MigrationTransformationRequest.java	52
v2/spanner-migrations-sdk/src/main/java/com/google/cloud/teleport/v2/spanner/utils/MigrationTransformationResponse.java	31
v2/spanner-migrations-sdk/src/main/java/com/google/cloud/teleport/v2/spanner/utils/ShardIdRequest.java	22
v2/spanner-migrations-sdk/src/main/java/com/google/cloud/teleport/v2/spanner/utils/ShardIdResponse.java	10
v2/spanner-migrations-sdk/src/main/java/com/google/cloud/teleport/v2/spanner/utils/package-info.java	1
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/SpannerToSourceDb.java	679
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/changestream/ChangeStreamErrorRecord.java	32
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/changestream/DataChangeRecordConvertorException.java	12
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/changestream/TrimmedShardedDataChangeRecord.java	148
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/changestream/package-info.java	1
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/constants/Constants.java	26
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/constants/package-info.java	1
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/connection/CassandraConnectionHelper.java	78
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/connection/IConnectionHelper.java	8
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/connection/JdbcConnectionHelper.java	79
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/connection/package-info.java	1
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dao/package-info.java	1
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dao/source/CassandraDao.java	43
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dao/source/IDao.java	4
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dao/source/JdbcDao.java	36
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dao/source/package-info.java	1
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dao/spanner/SpannerDao.java	62
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dao/spanner/package-info.java	1
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/CassandraDMLGenerator.java	262
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/CassandraTypeHandler.java	372
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/IDMLGenerator.java	6
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/MySQLDMLGenerator.java	371
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/package-info.java	1
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/package-info.java	1
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/dbutils/processor/SourceProcessor.java	47
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/processor/SourceProcessorFactory.java	137
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/processor/package-info.java	1
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/exceptions/ConnectionException.java	12
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/exceptions/UnsupportedSourceException.java	12
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/exceptions/package-info.java	1
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/models/ConnectionHelperRequest.java	37
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/models/DMLGeneratorRequest.java	87
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/models/DMLGeneratorResponse.java	13
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/models/PreparedStatementGeneratedResponse.java	16
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/models/PreparedStatementValueObject.java	10
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/models/package-info.java	1
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/AssignShardIdFn.java	432
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/ConvertChangeStreamErrorRecordToFailsafeElementFn.java	20
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/ConvertDlqRecordToTrimmedShardedDataChangeRecordFn.java	20
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/FilterRecordsFn.java	23
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/PreprocessRecordsFn.java	25
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/SourceWriterFn.java	260
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/SourceWriterTransform.java	138
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/UpdateDlqMetricsFn.java	30
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/package-info.java	1
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/CassandraSourceSchemaReader.java	29
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/ShadowTableCreator.java	159
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/ShadowTableRecord.java	16
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/ShardIdFetcherImpl.java	71
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/ShardingLogicImplFetcher.java	109
v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/package-info.java	1
v2/spanner-to-sourcedb/terraform/Spanner_Change_Streams_to_Sharded_File_Sink/dataflow_job.tf	250
v2/sqlserver-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/SQLServerToBigQueryOptions.java	20
v2/sqlserver-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/package-info.java	1
v2/sqlserver-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/SQLServerToBigQuery.java	24
v2/sqlserver-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/sqlserver-to-googlecloud/terraform/Jdbc_to_PubSub/dataflow_job.tf	200
v2/sqlserver-to-googlecloud/terraform/Jdbc_to_PubSub_Auto/dataflow_job.tf	218
v2/sqlserver-to-googlecloud/terraform/SQLServer_to_BigQuery/dataflow_job.tf	272
v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/templates/StreamingDataGenerator.java	617
v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/templates/package-info.java	1
v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/transforms/StreamingDataGeneratorWriteToBigQuery.java	88
v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/transforms/StreamingDataGeneratorWriteToGcs.java	155
v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/transforms/StreamingDataGeneratorWriteToJdbc.java	61
v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/transforms/StreamingDataGeneratorWriteToKafka.java	141
v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/transforms/StreamingDataGeneratorWriteToPubSub.java	206
v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/transforms/StreamingDataGeneratorWriteToSpanner.java	83
v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/transforms/package-info.java	1
v2/streaming-data-generator/terraform/Streaming_Data_Generator/dataflow_job.tf	324