Path	Lines of Code
v1/src/main/java/com/google/cloud/teleport/avro/AvroPubsubMessageRecord.java	63
v1/src/main/java/com/google/cloud/teleport/avro/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/bigtable/AvroToBigtable.java	170
v1/src/main/java/com/google/cloud/teleport/bigtable/BeamRowToBigtableFn.java	347
v1/src/main/java/com/google/cloud/teleport/bigtable/BigtableToAvro.java	200
v1/src/main/java/com/google/cloud/teleport/bigtable/BigtableToJson.java	266
v1/src/main/java/com/google/cloud/teleport/bigtable/BigtableToParquet.java	177
v1/src/main/java/com/google/cloud/teleport/bigtable/BigtableToVectorEmbeddings.java	555
v1/src/main/java/com/google/cloud/teleport/bigtable/CassandraColumnSchema.java	69
v1/src/main/java/com/google/cloud/teleport/bigtable/CassandraKeyUtils.java	45
v1/src/main/java/com/google/cloud/teleport/bigtable/CassandraRowMapperFactory.java	18
v1/src/main/java/com/google/cloud/teleport/bigtable/CassandraRowMapperFn.java	183
v1/src/main/java/com/google/cloud/teleport/bigtable/CassandraToBigtable.java	202
v1/src/main/java/com/google/cloud/teleport/bigtable/CassandraWritetimeQueryProvider.java	55
v1/src/main/java/com/google/cloud/teleport/bigtable/ParquetToBigtable.java	183
v1/src/main/java/com/google/cloud/teleport/bigtable/PipelineUtils.java	11
v1/src/main/java/com/google/cloud/teleport/bigtable/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/coders/FailsafeElementCoder.java	66
v1/src/main/java/com/google/cloud/teleport/coders/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/datadog/DatadogEvent.java	54
v1/src/main/java/com/google/cloud/teleport/datadog/DatadogEventCoder.java	59
v1/src/main/java/com/google/cloud/teleport/datadog/DatadogEventPublisher.java	182
v1/src/main/java/com/google/cloud/teleport/datadog/DatadogEventSerializer.java	19
v1/src/main/java/com/google/cloud/teleport/datadog/DatadogEventWriter.java	367
v1/src/main/java/com/google/cloud/teleport/datadog/DatadogIO.java	153
v1/src/main/java/com/google/cloud/teleport/datadog/DatadogWriteError.java	39
v1/src/main/java/com/google/cloud/teleport/datadog/DatadogWriteErrorCoder.java	56
v1/src/main/java/com/google/cloud/teleport/datadog/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/io/WindowedFilenamePolicy.java	302
v1/src/main/java/com/google/cloud/teleport/io/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/options/CommonTemplateOptions.java	33
v1/src/main/java/com/google/cloud/teleport/options/WindowedFilenamePolicyOptions.java	96
v1/src/main/java/com/google/cloud/teleport/options/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/spanner/ApplyDDLTransform.java	73
v1/src/main/java/com/google/cloud/teleport/spanner/AsList.java	33
v1/src/main/java/com/google/cloud/teleport/spanner/AvroRecordConverter.java	639
v1/src/main/java/com/google/cloud/teleport/spanner/AvroSchemaToDdlConverter.java	656
v1/src/main/java/com/google/cloud/teleport/spanner/AvroTableFileAsMutations.java	80
v1/src/main/java/com/google/cloud/teleport/spanner/AvroUtil.java	73
v1/src/main/java/com/google/cloud/teleport/spanner/BuildReadFromTableOperations.java	154
v1/src/main/java/com/google/cloud/teleport/spanner/CSVRecordToMutation.java	228
v1/src/main/java/com/google/cloud/teleport/spanner/DdlToAvroSchemaConverter.java	478
v1/src/main/java/com/google/cloud/teleport/spanner/ExportPipeline.java	217
v1/src/main/java/com/google/cloud/teleport/spanner/ExportTransform.java	841
v1/src/main/java/com/google/cloud/teleport/spanner/FileChecksum.java	36
v1/src/main/java/com/google/cloud/teleport/spanner/FileShard.java	64
v1/src/main/java/com/google/cloud/teleport/spanner/GcsUtil.java	18
v1/src/main/java/com/google/cloud/teleport/spanner/ImportPipeline.java	187
v1/src/main/java/com/google/cloud/teleport/spanner/ImportTransform.java	787
v1/src/main/java/com/google/cloud/teleport/spanner/ReadDialect.java	43
v1/src/main/java/com/google/cloud/teleport/spanner/ReadFileShardFn.java	122
v1/src/main/java/com/google/cloud/teleport/spanner/ReadInformationSchema.java	71
v1/src/main/java/com/google/cloud/teleport/spanner/SpannerRecordConverter.java	423
v1/src/main/java/com/google/cloud/teleport/spanner/SpannerTableFilter.java	60
v1/src/main/java/com/google/cloud/teleport/spanner/SplitIntoRangesFn.java	200
v1/src/main/java/com/google/cloud/teleport/spanner/TextImportPipeline.java	233
v1/src/main/java/com/google/cloud/teleport/spanner/TextImportTransform.java	502
v1/src/main/java/com/google/cloud/teleport/spanner/TextSource.java	183
v1/src/main/java/com/google/cloud/teleport/spanner/common/NameUtils.java	64
v1/src/main/java/com/google/cloud/teleport/spanner/common/NumericUtils.java	63
v1/src/main/java/com/google/cloud/teleport/spanner/common/SizedType.java	318
v1/src/main/java/com/google/cloud/teleport/spanner/common/Type.java	410
v1/src/main/java/com/google/cloud/teleport/spanner/common/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/ChangeStream.java	75
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/CheckConstraint.java	48
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Column.java	289
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/DatabaseOptionAllowlist.java	11
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Ddl.java	683
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/ForeignKey.java	132
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/GraphElementTable.java	183
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Index.java	223
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/IndexColumn.java	170
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/InformationSchemaScanner.java	1746
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Model.java	134
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/ModelColumn.java	85
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/NamedSchema.java	50
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Placement.java	68
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/PropertyGraph.java	177
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Sequence.java	97
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Table.java	224
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/View.java	70
v1/src/main/java/com/google/cloud/teleport/spanner/ddl/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/spanner/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/BatchSpannerRead.java	218
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/CreateTransactionFn.java	31
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationCellCounter.java	26
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationGroup.java	56
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationKeyEncoder.java	189
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationSizeEstimator.java	173
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationUtils.java	371
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/NaiveSpannerRead.java	135
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/OrderedCode.java	450
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/ReadOperation.java	85
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/ReadSpannerSchema.java	135
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerAccessor.java	251
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerConfig.java	202
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerIO.java	1602
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerQuerySourceDef.java	33
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerReadSchemaTransformProvider.java	213
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerSchema.java	185
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerSchemaRetrievalException.java	9
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerSourceDef.java	6
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerTableSourceDef.java	39
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerTransformRegistrar.java	315
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerWriteResult.java	45
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerWriteSchemaTransformProvider.java	212
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/StructUtils.java	413
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/Transaction.java	15
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/ChangeStreamMetrics.java	108
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/ChangeStreamsConstants.java	32
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/MetadataSpannerConfigFactory.java	73
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/SpannerChangestreamsReadSchemaTransformProvider.java	367
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action/ActionFactory.java	92
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action/ChildPartitionsRecordAction.java	112
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action/DataChangeRecordAction.java	53
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action/DetectNewPartitionsAction.java	143
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action/HeartbeatRecordAction.java	47
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action/QueryChangeStreamAction.java	191
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao/ChangeStreamDao.java	84
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao/ChangeStreamResultSet.java	61
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao/ChangeStreamResultSetMetadata.java	43
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao/DaoFactory.java	96
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao/PartitionMetadataAdminDao.java	198
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao/PartitionMetadataDao.java	499
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao/PartitionMetadataTableNames.java	84
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dofn/CleanUpReadChangeStreamDoFn.java	17
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dofn/DetectNewPartitionsDoFn.java	112
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dofn/InitializeDoFn.java	55
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dofn/PostProcessingMetricsDoFn.java	59
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dofn/ReadChangeStreamPartitionDoFn.java	144
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dofn/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/encoder/TimestampEncoding.java	41
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/encoder/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/estimator/BytesThroughputEstimator.java	85
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/estimator/EncodingException.java	6
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/estimator/NullThroughputEstimator.java	21
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/estimator/SizeEstimator.java	31
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/estimator/ThroughputEstimator.java	10
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/estimator/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/mapper/ChangeStreamRecordMapper.java	408
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/mapper/MapperFactory.java	26
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/mapper/PartitionMetadataMapper.java	39
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/mapper/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/ChangeStreamRecord.java	6
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/ChangeStreamRecordMetadata.java	272
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/ChildPartition.java	54
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/ChildPartitionsRecord.java	74
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/ColumnType.java	72
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/DataChangeRecord.java	197
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/HeartbeatRecord.java	49
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/InitialPartition.java	10
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/Mod.java	59
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/ModType.java	10
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/PartitionMetadata.java	270
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/TypeCode.java	38
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/ValueCaptureType.java	11
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/restriction/DetectNewPartitionsRangeTracker.java	18
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/restriction/ReadChangeStreamPartitionRangeTracker.java	32
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/restriction/RestrictionInterrupter.java	40
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/restriction/TimestampRange.java	46
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/restriction/TimestampRangeTracker.java	147
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/restriction/TimestampUtils.java	44
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/restriction/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/splunk/CustomX509TrustManager.java	53
v1/src/main/java/com/google/cloud/teleport/splunk/HttpEventPublisher.java	237
v1/src/main/java/com/google/cloud/teleport/splunk/SplunkEvent.java	71
v1/src/main/java/com/google/cloud/teleport/splunk/SplunkEventCoder.java	121
v1/src/main/java/com/google/cloud/teleport/splunk/SplunkEventWriter.java	377
v1/src/main/java/com/google/cloud/teleport/splunk/SplunkIO.java	198
v1/src/main/java/com/google/cloud/teleport/splunk/SplunkWriteError.java	39
v1/src/main/java/com/google/cloud/teleport/splunk/SplunkWriteErrorCoder.java	55
v1/src/main/java/com/google/cloud/teleport/splunk/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/templates/BigQueryToDatastore.java	73
v1/src/main/java/com/google/cloud/teleport/templates/BigQueryToTFRecord.java	299
v1/src/main/java/com/google/cloud/teleport/templates/BulkCompressor.java	183
v1/src/main/java/com/google/cloud/teleport/templates/BulkDecompressor.java	213
v1/src/main/java/com/google/cloud/teleport/templates/CSVToBigQuery.java	263
v1/src/main/java/com/google/cloud/teleport/templates/DLPTextToBigQueryStreaming.java	544
v1/src/main/java/com/google/cloud/teleport/templates/DatastoreSchemasCountToText.java	28
v1/src/main/java/com/google/cloud/teleport/templates/DatastoreToBigQuery.java	66
v1/src/main/java/com/google/cloud/teleport/templates/DatastoreToDatastoreDelete.java	113
v1/src/main/java/com/google/cloud/teleport/templates/DatastoreToPubsub.java	36
v1/src/main/java/com/google/cloud/teleport/templates/DatastoreToText.java	89
v1/src/main/java/com/google/cloud/teleport/templates/ExportJobPlaceholder.java	112
v1/src/main/java/com/google/cloud/teleport/templates/ImportJobPlaceholder.java	82
v1/src/main/java/com/google/cloud/teleport/templates/JdbcToBigQuery.java	81
v1/src/main/java/com/google/cloud/teleport/templates/PubSubToBigQuery.java	279
v1/src/main/java/com/google/cloud/teleport/templates/PubSubToDatadog.java	266
v1/src/main/java/com/google/cloud/teleport/templates/PubSubToSplunk.java	271
v1/src/main/java/com/google/cloud/teleport/templates/PubsubToAvro.java	166
v1/src/main/java/com/google/cloud/teleport/templates/PubsubToDatastore.java	36
v1/src/main/java/com/google/cloud/teleport/templates/PubsubToPubsub.java	196
v1/src/main/java/com/google/cloud/teleport/templates/PubsubToText.java	177
v1/src/main/java/com/google/cloud/teleport/templates/SchemaParser.java	23
v1/src/main/java/com/google/cloud/teleport/templates/SpannerToText.java	131
v1/src/main/java/com/google/cloud/teleport/templates/SpannerVectorEmbeddingExport.java	227
v1/src/main/java/com/google/cloud/teleport/templates/TextIOToBigQuery.java	215
v1/src/main/java/com/google/cloud/teleport/templates/TextToBigQueryStreaming.java	272
v1/src/main/java/com/google/cloud/teleport/templates/TextToDatastore.java	107
v1/src/main/java/com/google/cloud/teleport/templates/TextToPubsub.java	66
v1/src/main/java/com/google/cloud/teleport/templates/TextToPubsubStream.java	53
v1/src/main/java/com/google/cloud/teleport/templates/TextToSpanner.java	364
v1/src/main/java/com/google/cloud/teleport/templates/WordCount.java	89
v1/src/main/java/com/google/cloud/teleport/templates/common/BigQueryConverters.java	339
v1/src/main/java/com/google/cloud/teleport/templates/common/BigQueryDynamicConverters.java	110
v1/src/main/java/com/google/cloud/teleport/templates/common/CombineJsonLines.java	23
v1/src/main/java/com/google/cloud/teleport/templates/common/CommonTemplateJvmInitializer.java	132
v1/src/main/java/com/google/cloud/teleport/templates/common/CsvConverters.java	192
v1/src/main/java/com/google/cloud/teleport/templates/common/DatadogApiKeySource.java	6
v1/src/main/java/com/google/cloud/teleport/templates/common/DatadogConverters.java	232
v1/src/main/java/com/google/cloud/teleport/templates/common/DatastoreConverters.java	643
v1/src/main/java/com/google/cloud/teleport/templates/common/ErrorConverters.java	258
v1/src/main/java/com/google/cloud/teleport/templates/common/FirestoreNestedValueProvider.java	27
v1/src/main/java/com/google/cloud/teleport/templates/common/JavascriptTextTransformer.java	371
v1/src/main/java/com/google/cloud/teleport/templates/common/JdbcConverters.java	216
v1/src/main/java/com/google/cloud/teleport/templates/common/PubsubConverters.java	37
v1/src/main/java/com/google/cloud/teleport/templates/common/SpannerConverters.java	714
v1/src/main/java/com/google/cloud/teleport/templates/common/SplunkConverters.java	263
v1/src/main/java/com/google/cloud/teleport/templates/common/SplunkTokenSource.java	6
v1/src/main/java/com/google/cloud/teleport/templates/common/SubprocessTextTransformer.java	290
v1/src/main/java/com/google/cloud/teleport/templates/common/TextConverters.java	85
v1/src/main/java/com/google/cloud/teleport/templates/common/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/templates/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/util/DatadogApiKeyNestedValueProvider.java	100
v1/src/main/java/com/google/cloud/teleport/util/DualInputNestedValueProvider.java	64
v1/src/main/java/com/google/cloud/teleport/util/DurationUtils.java	28
v1/src/main/java/com/google/cloud/teleport/util/GCSAwareValueProvider.java	44
v1/src/main/java/com/google/cloud/teleport/util/GCSUtils.java	47
v1/src/main/java/com/google/cloud/teleport/util/KMSEncryptedNestedValueProvider.java	69
v1/src/main/java/com/google/cloud/teleport/util/ResourceUtils.java	22
v1/src/main/java/com/google/cloud/teleport/util/SecretManagerValueProvider.java	53
v1/src/main/java/com/google/cloud/teleport/util/TokenNestedValueProvider.java	100
v1/src/main/java/com/google/cloud/teleport/util/ValueProcessor.java	5
v1/src/main/java/com/google/cloud/teleport/util/ValueProviderUtils.java	37
v1/src/main/java/com/google/cloud/teleport/util/package-info.java	1
v1/src/main/java/com/google/cloud/teleport/values/FailsafeElement.java	74
v1/src/main/java/com/google/cloud/teleport/values/package-info.java	1
v1/src/main/proto/export.proto	60
v1/src/main/proto/text_import.proto	37
v1/src/main/resources/schema/avro/bigtable.avsc	23
v1/terraform/Bulk_Compress_GCS_Files/dataflow_job.tf	138
v1/terraform/Bulk_Decompress_GCS_Files/dataflow_job.tf	127
v1/terraform/Cassandra_To_Cloud_Bigtable/dataflow_job.tf	180
v1/terraform/Cloud_BigQuery_to_Cloud_Datastore/dataflow_job.tf	157
v1/terraform/Cloud_BigQuery_to_GCS_TensorFlow_Records/dataflow_job.tf	158
v1/terraform/Cloud_Bigtable_to_GCS_Avro/dataflow_job.tf	140
v1/terraform/Cloud_Bigtable_to_GCS_Json/dataflow_job.tf	153
v1/terraform/Cloud_Bigtable_to_GCS_Parquet/dataflow_job.tf	146
v1/terraform/Cloud_Bigtable_to_GCS_SequenceFile/dataflow_job.tf	168
v1/terraform/Cloud_Bigtable_to_Vector_Embeddings/dataflow_job.tf	193
v1/terraform/Cloud_PubSub_to_Avro/dataflow_job.tf	175
v1/terraform/Cloud_PubSub_to_Cloud_PubSub/dataflow_job.tf	134
v1/terraform/Cloud_PubSub_to_Datadog/dataflow_job.tf	187
v1/terraform/Cloud_PubSub_to_GCS_Text/dataflow_job.tf	177
v1/terraform/Cloud_PubSub_to_Splunk/dataflow_job.tf	211
v1/terraform/Cloud_Spanner_to_GCS_Avro/dataflow_job.tf	181
v1/terraform/Cloud_Spanner_vectors_to_Cloud_Storage/dataflow_job.tf	175
v1/terraform/Datastore_to_Datastore_Delete/dataflow_job.tf	151
v1/terraform/Datastore_to_GCS_Text/dataflow_job.tf	145
v1/terraform/Firestore_to_Firestore_Delete/dataflow_job.tf	151
v1/terraform/Firestore_to_GCS_Text/dataflow_job.tf	145
v1/terraform/GCS_Avro_to_Cloud_Bigtable/dataflow_job.tf	138
v1/terraform/GCS_Avro_to_Cloud_Spanner/dataflow_job.tf	181
v1/terraform/GCS_CSV_to_BigQuery/dataflow_job.tf	184
v1/terraform/GCS_Parquet_to_Cloud_Bigtable/dataflow_job.tf	138
v1/terraform/GCS_SequenceFile_to_Cloud_Bigtable/dataflow_job.tf	144
v1/terraform/GCS_Text_to_BigQuery/dataflow_job.tf	169
v1/terraform/GCS_Text_to_Cloud_PubSub/dataflow_job.tf	122
v1/terraform/GCS_Text_to_Cloud_Spanner/dataflow_job.tf	205
v1/terraform/GCS_Text_to_Datastore/dataflow_job.tf	145
v1/terraform/GCS_Text_to_Firestore/dataflow_job.tf	145
v1/terraform/Jdbc_to_BigQuery/dataflow_job.tf	186
v1/terraform/PubSub_Subscription_to_BigQuery/dataflow_job.tf	102
v1/terraform/PubSub_to_BigQuery/dataflow_job.tf	102
v1/terraform/Spanner_to_GCS_Text/dataflow_job.tf	167
v1/terraform/Stream_DLP_GCS_Text_to_BigQuery/dataflow_job.tf	144
v1/terraform/Stream_GCS_Text_to_BigQuery/dataflow_job.tf	182
v1/terraform/Stream_GCS_Text_to_Cloud_PubSub/dataflow_job.tf	122
v1/terraform/Word_Count/dataflow_job.tf	122