GoogleCloudPlatform / DataflowTemplates
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 1,640 files with 161,946 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 5 files changed 51-100 times (3,224 lines of code)
    • 89 files changed 21-50 times (27,427 lines of code)
    • 368 files changed 6-20 times (55,948 lines of code)
    • 1,178 files changed 1-5 times (75,347 lines of code)
0% | 1% | 16% | 34% | 46%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 1,640 files with 161,946 lines of code.
    • 1 file changed by more than 25 contributors (785 lines of code)
    • 101 files changed by 11-25 contributors (30,067 lines of code)
    • 193 files changed by 6-10 contributors (31,396 lines of code)
    • 928 files changed by 2-5 contributors (74,002 lines of code)
    • 417 files changed by 1 contributor (25,696 lines of code)
<1% | 18% | 19% | 45% | 15%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, json, md, tf, sql, xml, yaml, go, js, tfvars, txt, py, avsc, proto, sh, ftl, properties, pb, mod, gitignore, bash, cql
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 2% | 19% | 39% | 37%
go0% | 13% | 8% | 41% | 36%
tf0% | 0% | 0% | 2% | 97%
avsc0% | 0% | 0% | 23% | 76%
py0% | 0% | 0% | 7% | 92%
ftl0% | 0% | 0% | 73% | 26%
sql0% | 0% | 0% | 0% | 100%
proto0% | 0% | 0% | 0% | 100%
yaml0% | 0% | 0% | 0% | 100%
js0% | 0% | 0% | 0% | 100%
bash0% | 0% | 0% | 0% | 100%
xml0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
v20% | 1% | 16% | 33% | 47%
plugins0% | 25% | 21% | 31% | 21%
cicd0% | 13% | 8% | 42% | 36%
v10% | 0% | 19% | 32% | 48%
it0% | 0% | 5% | 55% | 38%
metadata0% | 0% | 39% | 20% | 39%
yaml0% | 0% | 0% | 63% | 36%
python0% | 0% | 0% | 33% | 66%
test-infra0% | 0% | 0% | 0% | 100%
ROOT0% | 0% | 0% | 0% | 100%
structured-logging0% | 0% | 0% | 0% | 100%
plaintext-logging0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
DataStreamToSpanner.java
in v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates
 785 7 2021-05-26 2025-04-24 74 33 dhercher@google.com manitgupta@google.com
TemplatesStageMojo.java
in plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven
 1198 23 2023-01-17 2025-04-02 65 18 bvolpato@google.com dannymccormick@google.com
maven-workflows.go
in cicd/internal/workflows
 183 39 2022-02-23 2025-01-10 59 20 zhoufek@google.com darshan-sj@users.noreply.gi...
DataStreamToBigQuery.java
in v2/datastream-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates
 487 7 2021-05-26 2024-12-12 55 22 dhercher@google.com sharantej@google.com
BigQueryConverters.java
in v2/common/src/main/java/com/google/cloud/teleport/v2/transforms
 571 33 2019-09-11 2024-12-12 51 22 chlarsen@google.com sharantej@google.com
TemplateDefinitions.java
in plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/model
 421 13 2022-11-22 2024-05-23 50 18 bvolpato@google.com cloud-teleport@google.com
PubsubProtoToBigQuery.java
in v2/pubsub-binary-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates
 376 10 2021-06-02 2024-12-12 49 21 cloud-teleport@google.com sharantej@google.com
TextIOToBigQuery.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates
 361 6 2022-11-15 2024-06-06 46 19 olegsa@google.com cloud-teleport@google.com
KafkaToBigQuery.java
in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates
 471 8 2019-09-11 2024-09-30 46 20 chlarsen@google.com 56550466+surabhiad@users.no...
ElasticsearchWriteOptions.java
in v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options
 256 - 2021-06-22 2024-12-12 45 19 panas_cherepushko@epam.com sharantej@google.com
PubSubToBigQuery.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates
 334 4 2022-12-07 2024-12-12 45 24 olegsa@google.com sharantej@google.com
TemplateTestBase.java
in it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp
 562 23 2023-07-28 2025-03-21 44 20 bvolpato@google.com darshan-sj@users.noreply.gi...
SpannerChangeStreamsToBigQuery.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery
 421 7 2022-04-21 2025-03-31 41 14 cloud-teleport@google.com yathu@google.com
PubSubToMongoDB.java
in v2/pubsub-to-mongodb/src/main/java/com/google/cloud/teleport/v2/templates
 422 8 2019-11-26 2024-06-06 41 20 pritishkamath@google.com cloud-teleport@google.com
ElasticsearchIO.java
in v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/utils
 1067 70 2021-08-12 2024-04-30 40 15 panas_cherepushko@epam.com sharantej957@gmail.com
WriteToElasticsearch.java
in v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms
 187 6 2021-06-22 2024-07-09 39 15 panas_cherepushko@epam.com cloud-teleport@google.com
PubSubCdcToBigQuery.java
in v2/pubsub-cdc-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates
 389 3 2020-05-13 2024-06-17 39 15 dhercher@google.com cloud-teleport@google.com
SourceDbToSpannerOptions.java
in v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/options
 214 - 2024-02-19 2025-03-28 38 14 adibh@google.com 39047439+vardhanthigle@user...
SpannerTransactionWriterDoFn.java
in v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates
 377 13 2021-05-26 2025-02-28 38 15 dhercher@google.com darshan-sj@users.noreply.gi...
GoogleCloudToNeo4j.java
in v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/templates
 479 16 2022-09-09 2025-01-08 38 6 bvolpato@google.com 445792+fbiville@users.norep...
JavascriptTextTransformer.java
in v2/common/src/main/java/com/google/cloud/teleport/v2/transforms
 365 16 2019-09-11 2024-12-12 37 21 chlarsen@google.com sharantej@google.com
TextToBigQueryStreaming.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates
 382 3 2022-12-06 2024-12-12 37 21 olegsa@google.com sharantej@google.com
StreamingDataGenerator.java
in v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/templates
 617 8 2020-06-10 2024-05-20 37 18 cloud-teleport@google.com 53229637+tanusharma2511@use...
PubSubToElasticsearch.java
in v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates
 177 3 2021-06-10 2024-05-13 36 16 panas_cherepushko@epam.com 51637901+tamannakakkar93@us...
CsvConverters.java
in v2/common/src/main/java/com/google/cloud/teleport/v2/transforms
 574 20 2019-09-24 2024-12-12 36 19 chlarsen@google.com sharantej@google.com
DataStreamToSQL.java
in v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/templates
 277 4 2021-08-10 2024-08-03 35 15 dhercher@google.com dhercher@google.com
GenericRecordTypeConvertor.java
in v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/avro
 538 17 2024-04-19 2025-03-20 35 8 deepchowdhury1998@gmail.com 39047439+vardhanthigle@user...
JdbcIoWrapper.java
in v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper
 349 13 2024-05-05 2024-12-19 34 10 vardhan.thigle@gmail.com 39047439+vardhanthigle@user...
Template.java
in metadata/src/main/java/com/google/cloud/teleport/metadata
 55 - 2022-11-17 2024-10-29 31 14 bvolpato@google.com jeff@thekinards.com
MongoDbToBigQueryOptions.java
in v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/options
 114 - 2022-07-13 2024-12-12 31 20 91714892+theshanbhag@users.... sharantej@google.com
TextImportPipeline.java
in v1/src/main/java/com/google/cloud/teleport/spanner
 233 1 2022-10-19 2025-03-11 31 18 bvolpato@google.com darshan-sj@users.noreply.gi...
JavascriptTextTransformer.java
in v1/src/main/java/com/google/cloud/teleport/templates/common
 371 16 2022-10-19 2024-05-23 31 17 bvolpato@google.com vitaly.terentyev@akvelon.com
KafkaToBigQueryFlex.java
in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates
 470 12 2024-04-22 2024-09-30 31 16 dippatel@google.com 56550466+surabhiad@users.no...
DdlToAvroSchemaConverter.java
in v1/src/main/java/com/google/cloud/teleport/spanner
 478 9 2022-10-19 2025-02-26 31 22 bvolpato@google.com seanfox@google.com
InformationSchemaScanner.java
in v1/src/main/java/com/google/cloud/teleport/spanner/ddl
 1746 48 2022-10-19 2025-02-26 31 15 bvolpato@google.com seanfox@google.com
PubsubToText.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/pubsubtotext
 164 3 2022-07-26 2024-12-12 30 21 olegsa@google.com sharantej@google.com
FirestoreToBigQuery.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates
 177 1 2023-01-17 2024-06-07 30 13 olegsa@google.com cloud-teleport@google.com
FailsafeModJsonToTableRowTransformer.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery
 354 12 2022-04-21 2024-09-04 30 12 cloud-teleport@google.com szhang73@u.rochester.edu
MysqlDialectAdapter.java
in v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/mysql
 499 20 2024-04-28 2024-12-19 30 14 vardhan.thigle@gmail.com 39047439+vardhanthigle@user...
SourceDbToSpanner.java
in v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates
 83 4 2024-02-19 2025-04-14 29 11 adibh@google.com vitaly.terentyev@akvelon.com
GCSToSourceDb.java
in v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates
 307 2 2023-09-04 2024-12-12 29 13 aksharau@google.com sharantej@google.com
BigQueryToElasticsearch.java
in v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates
 124 2 2021-06-10 2024-05-13 28 14 panas_cherepushko@epam.com 51637901+tamannakakkar93@us...
ImportPipeline.java
in v1/src/main/java/com/google/cloud/teleport/spanner
 187 1 2022-10-19 2025-03-11 28 9 bvolpato@google.com darshan-sj@users.noreply.gi...
Neo4jRowWriterTransform.java
in v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/transforms
 212 10 2022-07-01 2025-01-08 28 8 anthony@drumcircleanalytics... 445792+fbiville@users.norep...
ExportPipeline.java
in v1/src/main/java/com/google/cloud/teleport/spanner
 217 1 2022-10-19 2025-03-11 28 13 bvolpato@google.com darshan-sj@users.noreply.gi...
Neo4jConnection.java
in v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/database
 176 14 2022-07-01 2025-01-24 27 12 anthony@drumcircleanalytics... 445792+fbiville@users.norep...
PubsubAvroToBigQuery.java
in v2/pubsub-binary-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates
 110 2 2020-06-29 2024-05-20 26 14 saabhyankar@google.com vitaly.terentyev@akvelon.com
GCSToElasticsearch.java
in v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates
 183 2 2021-07-05 2024-05-13 26 14 panas_cherepushko@epam.com 51637901+tamannakakkar93@us...
SpannerChangeStreamsToBigQueryOptions.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options
 190 - 2022-04-21 2024-12-12 26 10 cloud-teleport@google.com sharantej@google.com
CassandraToBigtable.java
in v1/src/main/java/com/google/cloud/teleport/bigtable
 202 1 2022-10-19 2024-12-12 26 13 bvolpato@google.com sharantej@google.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
DataStreamToSpanner.java
in v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates
 785 7 2021-05-26 2025-04-24 74 33 dhercher@google.com manitgupta@google.com
PubSubToBigQuery.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates
 334 4 2022-12-07 2024-12-12 45 24 olegsa@google.com sharantej@google.com
DataStreamToBigQuery.java
in v2/datastream-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates
 487 7 2021-05-26 2024-12-12 55 22 dhercher@google.com sharantej@google.com
BigQueryConverters.java
in v2/common/src/main/java/com/google/cloud/teleport/v2/transforms
 571 33 2019-09-11 2024-12-12 51 22 chlarsen@google.com sharantej@google.com
DdlToAvroSchemaConverter.java
in v1/src/main/java/com/google/cloud/teleport/spanner
 478 9 2022-10-19 2025-02-26 31 22 bvolpato@google.com seanfox@google.com
PubsubProtoToBigQuery.java
in v2/pubsub-binary-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates
 376 10 2021-06-02 2024-12-12 49 21 cloud-teleport@google.com sharantej@google.com
JavascriptTextTransformer.java
in v2/common/src/main/java/com/google/cloud/teleport/v2/transforms
 365 16 2019-09-11 2024-12-12 37 21 chlarsen@google.com sharantej@google.com
TextToBigQueryStreaming.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates
 382 3 2022-12-06 2024-12-12 37 21 olegsa@google.com sharantej@google.com
PubsubToText.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/pubsubtotext
 164 3 2022-07-26 2024-12-12 30 21 olegsa@google.com sharantej@google.com
maven-workflows.go
in cicd/internal/workflows
 183 39 2022-02-23 2025-01-10 59 20 zhoufek@google.com darshan-sj@users.noreply.gi...
KafkaToBigQuery.java
in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates
 471 8 2019-09-11 2024-09-30 46 20 chlarsen@google.com 56550466+surabhiad@users.no...
TemplateTestBase.java
in it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp
 562 23 2023-07-28 2025-03-21 44 20 bvolpato@google.com darshan-sj@users.noreply.gi...
PubSubToMongoDB.java
in v2/pubsub-to-mongodb/src/main/java/com/google/cloud/teleport/v2/templates
 422 8 2019-11-26 2024-06-06 41 20 pritishkamath@google.com cloud-teleport@google.com
MongoDbToBigQueryOptions.java
in v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/options
 114 - 2022-07-13 2024-12-12 31 20 91714892+theshanbhag@users.... sharantej@google.com
TextIOToBigQuery.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates
 361 6 2022-11-15 2024-06-06 46 19 olegsa@google.com cloud-teleport@google.com
ElasticsearchWriteOptions.java
in v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options
 256 - 2021-06-22 2024-12-12 45 19 panas_cherepushko@epam.com sharantej@google.com
CsvConverters.java
in v2/common/src/main/java/com/google/cloud/teleport/v2/transforms
 574 20 2019-09-24 2024-12-12 36 19 chlarsen@google.com sharantej@google.com
TemplatesStageMojo.java
in plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven
 1198 23 2023-01-17 2025-04-02 65 18 bvolpato@google.com dannymccormick@google.com
TemplateDefinitions.java
in plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/model
 421 13 2022-11-22 2024-05-23 50 18 bvolpato@google.com cloud-teleport@google.com
StreamingDataGenerator.java
in v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/templates
 617 8 2020-06-10 2024-05-20 37 18 cloud-teleport@google.com 53229637+tanusharma2511@use...
TextImportPipeline.java
in v1/src/main/java/com/google/cloud/teleport/spanner
 233 1 2022-10-19 2025-03-11 31 18 bvolpato@google.com darshan-sj@users.noreply.gi...
AvroSchemaToDdlConverter.java
in v1/src/main/java/com/google/cloud/teleport/spanner
 656 14 2022-10-19 2025-02-26 26 18 bvolpato@google.com seanfox@google.com
JavascriptTextTransformer.java
in v1/src/main/java/com/google/cloud/teleport/templates/common
 371 16 2022-10-19 2024-05-23 31 17 bvolpato@google.com vitaly.terentyev@akvelon.com
DLPTextToBigQueryStreaming.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates
 592 31 2022-12-05 2024-08-07 26 17 olegsa@google.com dannymccormick@google.com
MqttToPubsub.java
in v2/mqtt-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates
 129 4 2023-03-03 2024-11-27 25 17 cloud-teleport@google.com dannymccormick@google.com
Column.java
in v1/src/main/java/com/google/cloud/teleport/spanner/ddl
 289 44 2022-10-19 2025-02-10 21 17 bvolpato@google.com luvagarwal.k@gmail.com
PubSubToElasticsearch.java
in v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates
 177 3 2021-06-10 2024-05-13 36 16 panas_cherepushko@epam.com 51637901+tamannakakkar93@us...
KafkaToBigQueryFlex.java
in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates
 470 12 2024-04-22 2024-09-30 31 16 dippatel@google.com 56550466+surabhiad@users.no...
ElasticsearchIO.java
in v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/utils
 1067 70 2021-08-12 2024-04-30 40 15 panas_cherepushko@epam.com sharantej957@gmail.com
PubSubCdcToBigQuery.java
in v2/pubsub-cdc-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates
 389 3 2020-05-13 2024-06-17 39 15 dhercher@google.com cloud-teleport@google.com
WriteToElasticsearch.java
in v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms
 187 6 2021-06-22 2024-07-09 39 15 panas_cherepushko@epam.com cloud-teleport@google.com
SpannerTransactionWriterDoFn.java
in v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates
 377 13 2021-05-26 2025-02-28 38 15 dhercher@google.com darshan-sj@users.noreply.gi...
DataStreamToSQL.java
in v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/templates
 277 4 2021-08-10 2024-08-03 35 15 dhercher@google.com dhercher@google.com
InformationSchemaScanner.java
in v1/src/main/java/com/google/cloud/teleport/spanner/ddl
 1746 48 2022-10-19 2025-02-26 31 15 bvolpato@google.com seanfox@google.com
DatastoreConverters.java
in v1/src/main/java/com/google/cloud/teleport/templates/common
 643 28 2022-10-19 2024-12-12 26 15 bvolpato@google.com sharantej@google.com
PubSubToRedis.java
in v2/pubsub-to-redis/src/main/java/com/google/cloud/teleport/v2/templates
 226 2 2023-03-21 2024-12-12 25 15 15679776+viragtripathi@user... sharantej@google.com
SpannerConverters.java
in v1/src/main/java/com/google/cloud/teleport/templates/common
 714 32 2022-10-19 2025-03-11 24 15 bvolpato@google.com darshan-sj@users.noreply.gi...
BigtableCommonOptions.java
in v2/bigtable-common/src/main/java/com/google/cloud/teleport/v2/bigtable/options
 231 - 2023-03-08 2025-05-02 23 15 jeff@thekinards.com 125445217+ron-gal@users.nor...
BigQueryToParquet.java
in v2/bigquery-to-parquet/src/main/java/com/google/cloud/teleport/v2/templates
 188 5 2020-01-27 2025-04-18 22 15 saabhyankar@google.com joy91227@gmail.com
CommonTemplateOptions.java
in v2/common/src/main/java/com/google/cloud/teleport/v2/options
 30 - 2022-06-17 2024-12-12 21 15 pranavbhandari@google.com sharantej@google.com
WindowedFilenamePolicyOptions.java
in v1/src/main/java/com/google/cloud/teleport/options
 96 - 2022-10-19 2024-12-12 17 15 bvolpato@google.com sharantej@google.com
TextConverters.java
in v1/src/main/java/com/google/cloud/teleport/templates/common
 85 - 2022-10-19 2024-12-12 16 15 bvolpato@google.com sharantej@google.com
SpannerChangeStreamsToBigQuery.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery
 421 7 2022-04-21 2025-03-31 41 14 cloud-teleport@google.com yathu@google.com
SourceDbToSpannerOptions.java
in v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/options
 214 - 2024-02-19 2025-03-28 38 14 adibh@google.com 39047439+vardhanthigle@user...
Template.java
in metadata/src/main/java/com/google/cloud/teleport/metadata
 55 - 2022-11-17 2024-10-29 31 14 bvolpato@google.com jeff@thekinards.com
MysqlDialectAdapter.java
in v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/mysql
 499 20 2024-04-28 2024-12-19 30 14 vardhan.thigle@gmail.com 39047439+vardhanthigle@user...
BigQueryToElasticsearch.java
in v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates
 124 2 2021-06-10 2024-05-13 28 14 panas_cherepushko@epam.com 51637901+tamannakakkar93@us...
KafkaReadOptions.java
in v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/options
 225 - 2021-06-23 2025-02-26 26 14 cloud-teleport@google.com venku123@gmail.com
GCSToElasticsearch.java
in v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates
 183 2 2021-07-05 2024-05-13 26 14 panas_cherepushko@epam.com 51637901+tamannakakkar93@us...
PubsubAvroToBigQuery.java
in v2/pubsub-binary-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates
 110 2 2020-06-29 2024-05-20 26 14 saabhyankar@google.com vitaly.terentyev@akvelon.com
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
SpannerIO.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio
 1602 148 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
CassandraIO.java
in v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra
 699 84 2025-03-26 2025-03-26 1 1 39047439+vardhanthigle@user... 39047439+vardhanthigle@user...
PartitionMetadataDao.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao
 499 25 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
OrderedCode.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio
 450 27 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
AssignShardIdFn.java
in v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms
 432 14 2024-07-25 2024-10-01 4 1 126752897+aksharauke@users.... 126752897+aksharauke@users....
StructUtils.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio
 413 7 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
ChangeStreamRecordMapper.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/mapper
 408 25 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
MappingListener.java
in v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers
 374 70 2024-09-18 2024-09-18 1 1 445792+fbiville@users.norep... 445792+fbiville@users.norep...
MySQLDMLGenerator.java
in v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml
 371 11 2024-11-27 2024-12-04 2 1 92910380+shreyakhajanchi@us... 92910380+shreyakhajanchi@us...
MutationUtils.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio
 371 10 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
SpannerChangestreamsReadSchemaTransformProvider.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams
 367 12 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
SpannerTransformRegistrar.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio
 315 28 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
dataflow_job.tf
in v2/jdbc-and-googlecloud/terraform/Jdbc_to_BigQuery_Flex
 282 - 2025-04-02 2025-04-02 1 1 yathu@google.com yathu@google.com
JobSpecIndex.java
in v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers
 273 21 2024-09-18 2024-09-18 1 1 445792+fbiville@users.norep... 445792+fbiville@users.norep...
ChangeStreamRecordMetadata.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model
 272 30 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
PartitionMetadata.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model
 270 29 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
dataflow_job.tf
in v2/spanner-to-sourcedb/terraform/Spanner_Change_Streams_to_Sharded_File_Sink
 250 - 2024-07-25 2024-07-25 1 1 126752897+aksharauke@users.... 126752897+aksharauke@users....
JdbcToBigQuery.java
in v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates
 246 5 2025-04-02 2025-04-02 1 1 yathu@google.com yathu@google.com
PromoteHelper.java
in plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven
 228 12 2025-03-10 2025-03-11 2 1 yathu@google.com yathu@google.com
JdbcToBigQueryOptions.java
in v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/options
 224 - 2025-04-02 2025-04-02 1 1 yathu@google.com yathu@google.com
BigtableChangeStreamsToVectorSearch.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstovectorsearch
 220 7 2024-06-10 2024-06-10 1 1 cloud-teleport@google.com cloud-teleport@google.com
dataflow_job.tf
in v2/jdbc-and-googlecloud/terraform/Jdbc_to_PubSub_Auto
 218 - 2025-04-02 2025-04-02 1 1 yathu@google.com yathu@google.com
BatchSpannerRead.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio
 218 11 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
SpannerReadSchemaTransformProvider.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio
 213 9 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
SpannerWriteSchemaTransformProvider.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio
 212 12 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
dataflow_job.tf
in v2/jdbc-and-googlecloud/terraform/Pubsub_to_Jdbc
 205 - 2025-04-02 2025-04-02 1 1 yathu@google.com yathu@google.com
SpannerConfig.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio
 202 34 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
dataflow_job.tf
in v2/jdbc-and-googlecloud/terraform/Jdbc_to_PubSub
 200 - 2025-04-02 2025-04-02 1 1 yathu@google.com yathu@google.com
CustomTransformationWithShardForLiveIT.java
in v2/spanner-custom-shard/src/main/java/com/custom
 198 3 2024-09-09 2025-02-11 4 1 92910380+shreyakhajanchi@us... 92910380+shreyakhajanchi@us...
PartitionMetadataAdminDao.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao
 198 3 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
DataChangeRecord.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model
 197 21 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
QueryChangeStreamAction.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action
 191 2 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
MutationKeyEncoder.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio
 189 10 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
SpannerSchema.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio
 185 15 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
CypherPatterns.java
in v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/database
 183 19 2024-09-18 2024-09-18 1 1 445792+fbiville@users.norep... 445792+fbiville@users.norep...
GraphElementTable.java
in v1/src/main/java/com/google/cloud/teleport/spanner/ddl
 183 13 2024-11-29 2024-11-29 1 1 sailesh@apache.org sailesh@apache.org
TableSelector.java
in v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates
 178 9 2024-11-04 2024-11-04 1 1 50752534+bharadwaj-aditya@u... 50752534+bharadwaj-aditya@u...
PropertyGraph.java
in v1/src/main/java/com/google/cloud/teleport/spanner/ddl
 177 10 2024-11-29 2024-11-29 1 1 sailesh@apache.org sailesh@apache.org
MutationSizeEstimator.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio
 173 8 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
ChangeStreamMutationToDatapointOperationFn.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstovectorsearch
 170 4 2024-06-10 2024-06-10 1 1 cloud-teleport@google.com cloud-teleport@google.com
JsonConverters.java
in v2/common/src/main/java/com/google/cloud/teleport/v2/transforms
 169 9 2021-09-22 2021-10-27 3 1 cloud-teleport@google.com cloud-teleport@google.com
CassandraMappingsProvider.java
in v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/mappings
 168 2 2024-12-14 2025-03-12 4 1 39047439+vardhanthigle@user... 39047439+vardhanthigle@user...
BigtableChangeStreamsToVectorSearchOptions.java
in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options
 165 - 2024-06-10 2024-06-10 1 1 cloud-teleport@google.com cloud-teleport@google.com
CollationIndex.java
in v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/stringmapper
 165 5 2024-07-26 2024-07-26 1 1 39047439+vardhanthigle@user... 39047439+vardhanthigle@user...
AvroJsonToCassandraMapConvertor.java
in v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/avro
 163 8 2025-03-20 2025-03-20 1 1 39047439+vardhanthigle@user... 39047439+vardhanthigle@user...
ShadowTableCreator.java
in v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils
 159 7 2024-07-25 2024-10-01 4 1 126752897+aksharauke@users.... 126752897+aksharauke@users....
MongoDbCdcToBigQuery.java
in v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/templates
 150 3 2024-09-24 2024-09-24 1 1 damondouglas@users.noreply.... damondouglas@users.noreply....
CassandraSchemaDiscovery.java
in v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/schema
 149 3 2024-11-26 2025-02-21 4 1 39047439+vardhanthigle@user... 39047439+vardhanthigle@user...
TrimmedShardedDataChangeRecord.java
in v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/changestream
 148 17 2024-07-25 2024-08-23 2 1 126752897+aksharauke@users.... 126752897+aksharauke@users....
TimestampRangeTracker.java
in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/restriction
 147 8 2025-03-11 2025-03-11 1 1 darshan-sj@users.noreply.gi... darshan-sj@users.noreply.gi...
Correlations

File Size vs. Number of Changes: 1642 points

v2/bigtable-common/src/main/java/com/google/cloud/teleport/v2/bigtable/options/BigtableCommonOptions.java x: 231 lines of code y: 23 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/BigtableChangeStreamsToBigQuery.java x: 285 lines of code y: 16 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/model/Mod.java x: 204 lines of code y: 6 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/schemautils/BigQueryUtils.java x: 240 lines of code y: 5 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/BigtableUtils.java x: 278 lines of code y: 7 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/BigtableChangeStreamsToPubSub.java x: 532 lines of code y: 12 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/model/Mod.java x: 190 lines of code y: 6 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/schemautils/PubSubUtils.java x: 363 lines of code y: 3 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/utils/BigtableSource.java x: 90 lines of code y: 3 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToSpanner.java x: 785 lines of code y: 74 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/SpannerTemplateITBase.java x: 129 lines of code y: 3 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/BigQueryResourceManager.java x: 320 lines of code y: 8 # changes v2/bigquery-to-parquet/src/main/java/com/google/cloud/teleport/v2/templates/BigQueryToParquet.java x: 188 lines of code y: 22 # changes python/src/main/python/yaml-template/main.py x: 11 lines of code y: 17 # changes v2/cdc-parent/cdc-embedded-connector/src/main/java/com/google/cloud/dataflow/cdc/connector/App.java x: 129 lines of code y: 11 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/SourceDbToSpanner.java x: 83 lines of code y: 29 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/SpannerToSourceDb.java x: 679 lines of code y: 9 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/CassandraDMLGenerator.java x: 262 lines of code y: 4 # changes v2/failure-injected-spanner-service/src/main/java/com/google/cloud/teleport/v2/spanner/service/SpannerService.java x: 83 lines of code y: 1 # changes v2/failure-injected-spanner-service/src/main/java/com/google/cloud/teleport/v2/spanner/service/package-info.java x: 1 lines of code y: 1 # changes v2/failure-injected-spanner-service/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerServiceFactoryImpl.java x: 10 lines of code y: 1 # changes v2/failure-injection-policies/src/main/java/com/google/cloud/teleport/v2/failureinjection/AlwaysFailPolicy.java x: 9 lines of code y: 1 # changes v2/failure-injection-policies/src/main/java/com/google/cloud/teleport/v2/failureinjection/ErrorInjectionPolicy.java x: 4 lines of code y: 1 # changes v2/real-spanner-service/src/main/java/com/google/cloud/teleport/v2/spanner/service/SpannerService.java x: 14 lines of code y: 1 # changes v2/spanner-custom-shard/src/main/java/com/custom/CustomTransformationWithCassandraForIT.java x: 35 lines of code y: 2 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/CassandraTypeHandler.java x: 372 lines of code y: 7 # changes plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesStageMojo.java x: 1198 lines of code y: 65 # changes v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/io/DynamicJdbcIO.java x: 121 lines of code y: 1 # changes v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/JdbcToBigQueryOptions.java x: 224 lines of code y: 1 # changes v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/JdbcToPubsubOptions.java x: 91 lines of code y: 1 # changes v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/PubsubToJdbcOptions.java x: 109 lines of code y: 1 # changes v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/JdbcToBigQuery.java x: 246 lines of code y: 1 # changes v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/JdbcToPubSubAuto.java x: 29 lines of code y: 1 # changes v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/PubsubToJdbc.java x: 103 lines of code y: 1 # changes v2/jdbc-and-googlecloud/terraform/Jdbc_to_BigQuery_Flex/dataflow_job.tf x: 282 lines of code y: 1 # changes v2/jdbc-and-googlecloud/terraform/Jdbc_to_PubSub/dataflow_job.tf x: 200 lines of code y: 1 # changes v2/jdbc-and-googlecloud/terraform/Jdbc_to_PubSub_Auto/dataflow_job.tf x: 218 lines of code y: 1 # changes v2/jdbc-and-googlecloud/terraform/Pubsub_to_Jdbc/dataflow_job.tf x: 205 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerAccessor.java x: 251 lines of code y: 2 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/SpannerChangeStreamsToBigQuery.java x: 421 lines of code y: 41 # changes plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/TemplateDefinitionsParser.java x: 64 lines of code y: 7 # changes plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/TemplateSpecsGenerator.java x: 206 lines of code y: 19 # changes plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesBaseMojo.java x: 58 lines of code y: 3 # changes plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesReleaseMojo.java x: 164 lines of code y: 17 # changes plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesSpecMojo.java x: 33 lines of code y: 3 # changes plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesTerraformMojo.java x: 78 lines of code y: 7 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/options/SourceDbToSpannerOptions.java x: 214 lines of code y: 38 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraDataSource.java x: 91 lines of code y: 5 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraIOWrapperHelper.java x: 123 lines of code y: 3 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraIoWrapper.java x: 47 lines of code y: 3 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/MigrateTableTransform.java x: 110 lines of code y: 6 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/writer/SpannerWriter.java x: 48 lines of code y: 6 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TestConstants.java x: 18 lines of code y: 2 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/SpannerResourceManager.java x: 468 lines of code y: 17 # changes test-infra/cleanup_spanner_databases.py x: 26 lines of code y: 2 # changes v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/CassandraIO.java x: 699 lines of code y: 1 # changes v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/ConnectionManager.java x: 59 lines of code y: 1 # changes v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/DefaultObjectMapper.java x: 27 lines of code y: 1 # changes v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/DefaultObjectMapperFactory.java x: 23 lines of code y: 1 # changes v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/ReadFn.java x: 116 lines of code y: 1 # changes v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/RingRange.java x: 56 lines of code y: 1 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/transformer/SourceRowToMutationDoFn.java x: 95 lines of code y: 22 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TemplateTestBase.java x: 562 lines of code y: 44 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Column.java x: 360 lines of code y: 6 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/annotations/cassandra/CassandraAnnotations.java x: 41 lines of code y: 1 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/annotations/cassandra/CassandraMap.java x: 16 lines of code y: 1 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/annotations/cassandra/CassandraType.java x: 49 lines of code y: 1 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/avro/AvroJsonToCassandraMapConvertor.java x: 163 lines of code y: 1 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/avro/GenericRecordTypeConvertor.java x: 538 lines of code y: 35 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/ISchemaMapper.java x: 26 lines of code y: 14 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/IdentityMapper.java x: 105 lines of code y: 13 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SessionBasedMapper.java x: 262 lines of code y: 19 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ddl/DatabaseOptionAllowlist.java x: 11 lines of code y: 4 # changes test-infra/cleanup_pubsub_notifications.py x: 34 lines of code y: 1 # changes cicd/internal/flags/common-flags.go x: 58 lines of code y: 16 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/mappings/CassandraMappingsProvider.java x: 168 lines of code y: 4 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ApplyDDLTransform.java x: 73 lines of code y: 3 # changes v1/src/main/java/com/google/cloud/teleport/spanner/BuildReadFromTableOperations.java x: 154 lines of code y: 10 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ExportPipeline.java x: 217 lines of code y: 28 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ExportTransform.java x: 841 lines of code y: 15 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ImportPipeline.java x: 187 lines of code y: 28 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ImportTransform.java x: 787 lines of code y: 19 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ReadDialect.java x: 43 lines of code y: 2 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ReadInformationSchema.java x: 71 lines of code y: 2 # changes v1/src/main/java/com/google/cloud/teleport/spanner/TextImportPipeline.java x: 233 lines of code y: 31 # changes v1/src/main/java/com/google/cloud/teleport/spanner/TextImportTransform.java x: 502 lines of code y: 12 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationKeyEncoder.java x: 189 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationSizeEstimator.java x: 173 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationUtils.java x: 371 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/NaiveSpannerRead.java x: 135 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/OrderedCode.java x: 450 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerConfig.java x: 202 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerIO.java x: 1602 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerReadSchemaTransformProvider.java x: 213 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerSchema.java x: 185 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerTableSourceDef.java x: 39 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerTransformRegistrar.java x: 315 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerWriteResult.java x: 45 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/StructUtils.java x: 413 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/MetadataSpannerConfigFactory.java x: 73 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/SpannerChangestreamsReadSchemaTransformProvider.java x: 367 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action/ActionFactory.java x: 92 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action/ChildPartitionsRecordAction.java x: 112 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action/DataChangeRecordAction.java x: 53 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action/DetectNewPartitionsAction.java x: 143 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action/QueryChangeStreamAction.java x: 191 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao/ChangeStreamResultSet.java x: 61 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao/DaoFactory.java x: 96 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao/PartitionMetadataAdminDao.java x: 198 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao/PartitionMetadataDao.java x: 499 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/estimator/NullThroughputEstimator.java x: 21 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/mapper/ChangeStreamRecordMapper.java x: 408 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/ChangeStreamRecordMetadata.java x: 272 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/ColumnType.java x: 72 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/PartitionMetadata.java x: 270 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/restriction/TimestampRangeTracker.java x: 147 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/templates/SpannerToText.java x: 131 lines of code y: 15 # changes v1/src/main/java/com/google/cloud/teleport/templates/SpannerVectorEmbeddingExport.java x: 227 lines of code y: 14 # changes v1/src/main/java/com/google/cloud/teleport/templates/TextToSpanner.java x: 364 lines of code y: 7 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/SpannerConverters.java x: 714 lines of code y: 24 # changes plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/PromoteHelper.java x: 228 lines of code y: 2 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/storage/GcsResourceManager.java x: 291 lines of code y: 13 # changes v1/src/main/java/com/google/cloud/teleport/templates/CSVToBigQuery.java x: 263 lines of code y: 11 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/CsvConverters.java x: 192 lines of code y: 10 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/SpannerTransactionWriterDoFn.java x: 377 lines of code y: 38 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/connection/JdbcConnectionHelper.java x: 79 lines of code y: 2 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/options/KafkaReadOptions.java x: 225 lines of code y: 26 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/options/KafkaWriteOptions.java x: 178 lines of code y: 12 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/utils/KafkaConfig.java x: 170 lines of code y: 6 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/values/KafkaAuthenticationMethod.java x: 9 lines of code y: 6 # changes v1/src/main/java/com/google/cloud/teleport/spanner/AvroSchemaToDdlConverter.java x: 656 lines of code y: 26 # changes v1/src/main/java/com/google/cloud/teleport/spanner/AvroUtil.java x: 73 lines of code y: 14 # changes v1/src/main/java/com/google/cloud/teleport/spanner/DdlToAvroSchemaConverter.java x: 478 lines of code y: 31 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ddl/InformationSchemaScanner.java x: 1746 lines of code y: 31 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Table.java x: 224 lines of code y: 5 # changes v1/src/main/java/com/google/cloud/teleport/templates/BigQueryToTFRecord.java x: 299 lines of code y: 25 # changes v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/transforms/FormatDatastreamRecordToJson.java x: 522 lines of code y: 19 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/mappings/CassandraMappings.java x: 112 lines of code y: 3 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/rowmapper/CassandraFieldMapper.java x: 22 lines of code y: 2 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/schema/CassandraSchemaDiscovery.java x: 149 lines of code y: 4 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/SourceWriterFn.java x: 260 lines of code y: 13 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/avro/AvroToValueMapper.java x: 406 lines of code y: 15 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/MySqlChangeEventSequence.java x: 123 lines of code y: 15 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/OracleChangeEventSequence.java x: 93 lines of code y: 15 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/PostgresChangeEventSequence.java x: 108 lines of code y: 12 # changes v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/utils/DatastreamToDML.java x: 448 lines of code y: 13 # changes v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/utils/DatastreamToPostgresDML.java x: 166 lines of code y: 12 # changes v2/kinesis-to-pubsub/src/main/java/com/google/cloud/teleport/v2/options/KinesisToPubsubOptions.java x: 66 lines of code y: 5 # changes v2/spanner-custom-shard/src/main/java/com/custom/CustomTransformationWithShardForLiveIT.java x: 198 lines of code y: 4 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/matchers/SpannerAsserts.java x: 97 lines of code y: 5 # changes v1/src/main/java/com/google/cloud/teleport/spanner/AvroRecordConverter.java x: 639 lines of code y: 10 # changes v1/src/main/java/com/google/cloud/teleport/spanner/CSVRecordToMutation.java x: 228 lines of code y: 13 # changes v1/src/main/java/com/google/cloud/teleport/spanner/SpannerRecordConverter.java x: 423 lines of code y: 19 # changes v1/src/main/java/com/google/cloud/teleport/spanner/common/SizedType.java x: 318 lines of code y: 18 # changes v1/src/main/java/com/google/cloud/teleport/spanner/common/Type.java x: 410 lines of code y: 12 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Column.java x: 289 lines of code y: 21 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/rowmapper/CassandraRowMapper.java x: 57 lines of code y: 2 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/rowmapper/CassandraRowValueExtractor.java x: 9 lines of code y: 2 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/UnifiedTypeMapper.java x: 46 lines of code y: 6 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/UnifiedTypeMapping.java x: 7 lines of code y: 4 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/UnifiedMappingProvider.java x: 88 lines of code y: 5 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Index.java x: 223 lines of code y: 12 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/database/Neo4jCapabilities.java x: 157 lines of code y: 6 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/database/Neo4jConnection.java x: 176 lines of code y: 27 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/Schema.java x: 207 lines of code y: 11 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/constants/Constants.java x: 26 lines of code y: 7 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/processor/InputRecordProcessor.java x: 110 lines of code y: 3 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/processor/SourceProcessorFactory.java x: 137 lines of code y: 3 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/models/DMLGeneratorRequest.java x: 87 lines of code y: 3 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/SpannerTransactionWriter.java x: 111 lines of code y: 15 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventContext.java x: 57 lines of code y: 17 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventContextFactory.java x: 47 lines of code y: 22 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventSequenceFactory.java x: 60 lines of code y: 13 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/MySqlChangeEventContext.java x: 49 lines of code y: 14 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/OracleChangeEventContext.java x: 42 lines of code y: 14 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/PostgresChangeEventContext.java x: 42 lines of code y: 11 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/spanner/ProcessInformationSchema.java x: 201 lines of code y: 13 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/config/SQLDialect.java x: 6 lines of code y: 2 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/matchers/ArtifactsSubject.java x: 109 lines of code y: 8 # changes plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/DockerfileGenerator.java x: 219 lines of code y: 6 # changes plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesReleaseFinishMojo.java x: 181 lines of code y: 4 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/validation/NodeKeyValidator.java x: 32 lines of code y: 2 # changes cicd/internal/workflows/maven-workflows.go x: 183 lines of code y: 59 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/CassandraDriverConfigLoader.java x: 130 lines of code y: 2 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/templates/GoogleCloudToNeo4j.java x: 479 lines of code y: 38 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/BeamBlock.java x: 55 lines of code y: 12 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/transforms/Neo4jRowWriterTransform.java x: 212 lines of code y: 28 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/ModelUtils.java x: 208 lines of code y: 26 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/constants/Constants.java x: 13 lines of code y: 7 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/metadata/CassandraSourceMetadata.java x: 105 lines of code y: 1 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/spanner/SpannerSchema.java x: 89 lines of code y: 2 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/connection/CassandraConnectionHelper.java x: 78 lines of code y: 1 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/monitoring/MonitoringClient.java x: 370 lines of code y: 7 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub/PubsubResourceManager.java x: 341 lines of code y: 14 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/PipelineController.java x: 274 lines of code y: 18 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/JarFileReader.java x: 49 lines of code y: 3 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/mysql/MysqlDialectAdapter.java x: 499 lines of code y: 30 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/JdbcIoWrapper.java x: 349 lines of code y: 34 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/BoundaryExtractorFactory.java x: 121 lines of code y: 6 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/BoundarySplitterFactory.java x: 138 lines of code y: 4 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/SourceColumnIndexInfo.java x: 71 lines of code y: 7 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/CustomSchema.java x: 121 lines of code y: 4 # changes plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/model/ImageSpecParameter.java x: 615 lines of code y: 25 # changes v1/src/main/java/com/google/cloud/teleport/bigtable/AvroToBigtable.java x: 170 lines of code y: 21 # changes v1/src/main/java/com/google/cloud/teleport/bigtable/BigtableToJson.java x: 266 lines of code y: 18 # changes v1/src/main/java/com/google/cloud/teleport/bigtable/BigtableToParquet.java x: 177 lines of code y: 21 # changes v1/src/main/java/com/google/cloud/teleport/bigtable/BigtableToVectorEmbeddings.java x: 555 lines of code y: 20 # changes v1/src/main/java/com/google/cloud/teleport/bigtable/CassandraToBigtable.java x: 202 lines of code y: 26 # changes v1/src/main/java/com/google/cloud/teleport/bigtable/ParquetToBigtable.java x: 183 lines of code y: 22 # changes v1/src/main/java/com/google/cloud/teleport/options/WindowedFilenamePolicyOptions.java x: 96 lines of code y: 17 # changes v1/src/main/java/com/google/cloud/teleport/templates/DLPTextToBigQueryStreaming.java x: 544 lines of code y: 24 # changes v1/src/main/java/com/google/cloud/teleport/templates/PubsubToAvro.java x: 166 lines of code y: 24 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/BigQueryConverters.java x: 339 lines of code y: 14 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/DatastoreConverters.java x: 643 lines of code y: 26 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/PubsubConverters.java x: 37 lines of code y: 9 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/SplunkConverters.java x: 263 lines of code y: 15 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/TextConverters.java x: 85 lines of code y: 16 # changes v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/CdcToBigQueryChangeApplierPipeline.java x: 150 lines of code y: 25 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/auto/blocks/WriteToPubSub.java x: 35 lines of code y: 5 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/options/CommonTemplateOptions.java x: 30 lines of code y: 21 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/options/WindowedFilenamePolicyOptions.java x: 106 lines of code y: 16 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryConverters.java x: 571 lines of code y: 51 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/CsvConverters.java x: 574 lines of code y: 36 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/JavascriptTextTransformer.java x: 365 lines of code y: 37 # changes v2/datastream-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToBigQuery.java x: 487 lines of code y: 55 # changes v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options/ElasticsearchWriteOptions.java x: 256 lines of code y: 45 # changes v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/GCSToSourceDb.java x: 307 lines of code y: 29 # changes v2/google-ads-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/GoogleAdsToBigQuery.java x: 169 lines of code y: 17 # changes v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options/GCSToElasticsearchOptions.java x: 28 lines of code y: 13 # changes v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options/PubSubToElasticsearchOptions.java x: 55 lines of code y: 25 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/BigtableChangeStreamsToPubSubOptions.java x: 138 lines of code y: 13 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/SpannerChangeStreamsToBigQueryOptions.java x: 190 lines of code y: 26 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/SpannerChangeStreamsToGcsOptions.java x: 140 lines of code y: 18 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/PubSubToBigQuery.java x: 334 lines of code y: 45 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/TextToBigQueryStreaming.java x: 382 lines of code y: 37 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/pubsubtotext/PubsubToText.java x: 164 lines of code y: 30 # changes v2/googlecloud-to-mongodb/src/main/java/com/google/cloud/teleport/v2/mongodb/options/BigQueryToMongoDbOptions.java x: 41 lines of code y: 13 # changes v2/jms-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/JmsToPubsub.java x: 155 lines of code y: 18 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/options/SchemaRegistryOptions.java x: 201 lines of code y: 8 # changes v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/options/KafkaToBigQueryFlexOptions.java x: 192 lines of code y: 21 # changes v2/kafka-to-pubsub/src/main/java/com/google/cloud/teleport/v2/options/KafkaToPubsubOptions.java x: 48 lines of code y: 11 # changes v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/options/MongoDbToBigQueryOptions.java x: 114 lines of code y: 31 # changes v2/pubsub-binary-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/PubsubProtoToBigQuery.java x: 376 lines of code y: 49 # changes v2/pubsub-to-redis/src/main/java/com/google/cloud/teleport/v2/templates/PubSubToRedis.java x: 226 lines of code y: 25 # changes cicd/internal/flags/it-flags.go x: 113 lines of code y: 25 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/BigQuerySpec.java x: 66 lines of code y: 1 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/sources/BigQuerySource.java x: 68 lines of code y: 2 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/bigquery/BigQueryImpl.java x: 85 lines of code y: 10 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/bigquery/BqQueryToRow.java x: 48 lines of code y: 7 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/options/OptionsToConfigBuilder.java x: 229 lines of code y: 23 # changes v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/transforms/FormatDatastreamJsonToJson.java x: 174 lines of code y: 3 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/MySQLDMLGenerator.java x: 371 lines of code y: 2 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/SpannerToBigQueryOptions.java x: 72 lines of code y: 21 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/SpannerToBigQuery.java x: 84 lines of code y: 15 # changes v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/utils/BigQueryAvroUtils.java x: 444 lines of code y: 10 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/ErrorConverters.java x: 436 lines of code y: 14 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Ddl.java x: 683 lines of code y: 16 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ddl/PropertyGraph.java x: 177 lines of code y: 1 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/provider/MysqlJdbcValueMappings.java x: 168 lines of code y: 10 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/MysqlMappingProvider.java x: 52 lines of code y: 10 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/auth/dbauth/LocalCredentialsProvider.java x: 33 lines of code y: 7 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/ReadWithUniformPartitions.java x: 355 lines of code y: 7 # changes v2/mqtt-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/MqttToPubsub.java x: 129 lines of code y: 25 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dao/source/JdbcDao.java x: 36 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ddl/ForeignKey.java x: 132 lines of code y: 6 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/JobSpecMapper.java x: 120 lines of code y: 7 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/options/Neo4jFlexTemplateOptions.java x: 61 lines of code y: 16 # changes v2/mysql-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/MySQLToBigQuery.java x: 24 lines of code y: 7 # changes v2/oracle-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/OracleToBigQuery.java x: 24 lines of code y: 3 # changes v2/postgresql-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/PostgreSQLToBigQuery.java x: 24 lines of code y: 4 # changes v2/sqlserver-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/SQLServerToBigQuery.java x: 24 lines of code y: 6 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/IoWrapper.java x: 12 lines of code y: 7 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/DialectAdapter.java x: 49 lines of code y: 8 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/postgresql/PostgreSQLDialectAdapter.java x: 384 lines of code y: 7 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/config/JdbcIOWrapperConfig.java x: 176 lines of code y: 22 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/package-info.java x: 1 lines of code y: 7 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/RetriableSchemaDiscovery.java x: 20 lines of code y: 8 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/SchemaDiscoveryImpl.java x: 72 lines of code y: 8 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/SourceSchemaReference.java x: 32 lines of code y: 6 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/CsvSources.java x: 30 lines of code y: 2 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/BeamUtils.java x: 137 lines of code y: 12 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/PostgreSQLMappingProvider.java x: 61 lines of code y: 4 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/type/Type.java x: 334 lines of code y: 8 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/writer/DeadLetterQueue.java x: 224 lines of code y: 12 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/config/defaults/MySqlConfigDefaults.java x: 51 lines of code y: 16 # changes v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/sources/ReadFileRangesFn.java x: 87 lines of code y: 6 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventConvertor.java x: 136 lines of code y: 25 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/transform/ChangeEventTransformerDoFn.java x: 236 lines of code y: 12 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventSessionConvertor.java x: 218 lines of code y: 9 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Ddl.java x: 288 lines of code y: 7 # changes plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/TemplatePluginUtils.java x: 28 lines of code y: 3 # changes python/src/main/java/com/google/cloud/teleport/templates/python/JobBuilderServer.java x: 18 lines of code y: 3 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/Boundary.java x: 148 lines of code y: 4 # changes v1/src/main/java/com/google/cloud/teleport/templates/PubSubToDatadog.java x: 266 lines of code y: 22 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/shard/Shard.java x: 157 lines of code y: 8 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/ShardFileReader.java x: 198 lines of code y: 9 # changes metadata/src/main/java/com/google/cloud/teleport/metadata/Template.java x: 55 lines of code y: 31 # changes cicd/cmd/run-build/main.go x: 24 lines of code y: 16 # changes v2/sqlserver-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/SQLServerToBigQueryOptions.java x: 20 lines of code y: 4 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/UniformSplitterDBAdapter.java x: 13 lines of code y: 6 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/stringmapper/CollationMapper.java x: 201 lines of code y: 2 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub/PubsubResourceManagerException.java x: 9 lines of code y: 3 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/constants/DatastreamToSpannerConstants.java x: 20 lines of code y: 5 # changes v2/spanner-custom-shard/src/main/java/com/custom/CustomTransformationWithShardForBulkIT.java x: 121 lines of code y: 3 # changes v1/src/main/java/com/google/cloud/teleport/bigtable/BeamRowToBigtableFn.java x: 347 lines of code y: 6 # changes v1/src/main/java/com/google/cloud/teleport/bigtable/CassandraColumnSchema.java x: 69 lines of code y: 1 # changes v1/src/main/java/com/google/cloud/teleport/bigtable/CassandraRowMapperFn.java x: 183 lines of code y: 6 # changes v1/src/main/java/com/google/cloud/teleport/util/GCSUtils.java x: 47 lines of code y: 4 # changes v1/terraform/Cassandra_To_Cloud_Bigtable/dataflow_job.tf x: 180 lines of code y: 6 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/JDBCBaseIT.java x: 101 lines of code y: 5 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/constants/SourceDbToSpannerConstants.java x: 9 lines of code y: 5 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/JdbcDataSource.java x: 82 lines of code y: 2 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/changestream/DataChangeRecordTypeConvertor.java x: 113 lines of code y: 2 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/AssignShardIdFn.java x: 432 lines of code y: 4 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/ShadowTableCreator.java x: 159 lines of code y: 4 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SchemaStringOverridesParser.java x: 131 lines of code y: 1 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/KafkaTransform.java x: 114 lines of code y: 17 # changes v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQuery.java x: 471 lines of code y: 46 # changes v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryFlex.java x: 470 lines of code y: 31 # changes v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/sources/DataStreamIO.java x: 332 lines of code y: 4 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/DatastreamConstants.java x: 116 lines of code y: 9 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/BigQueryDynamicDestinations.java x: 203 lines of code y: 18 # changes v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/templates/MongoDbCdcToBigQuery.java x: 150 lines of code y: 1 # changes v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/StringMessageToTableRow.java x: 104 lines of code y: 7 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/ActionDoFnFactory.java x: 22 lines of code y: 3 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/function/BigQueryActionFn.java x: 39 lines of code y: 5 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/function/CypherActionFn.java x: 79 lines of code y: 12 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/preload/PreloadBigQueryAction.java x: 37 lines of code y: 8 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/preload/PreloadCypherAction.java x: 78 lines of code y: 14 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/database/CypherGenerator.java x: 376 lines of code y: 22 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/InputValidator.java x: 40 lines of code y: 25 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/ActionMapper.java x: 107 lines of code y: 5 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/MappingListener.java x: 374 lines of code y: 1 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/MappingMapper.java x: 443 lines of code y: 13 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/OptionsParamsMapper.java x: 17 lines of code y: 10 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/SourceMapper.java x: 87 lines of code y: 10 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/TargetMapper.java x: 259 lines of code y: 18 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/Provider.java x: 15 lines of code y: 4 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/LineToRowFn.java x: 37 lines of code y: 7 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/TextImpl.java x: 40 lines of code y: 6 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/TextSourceFileMetadataToRow.java x: 20 lines of code y: 6 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/TextSourceFileToRow.java x: 62 lines of code y: 6 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/TextTargetToRow.java x: 69 lines of code y: 5 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/transforms/Neo4jBlockingUnwindFn.java x: 124 lines of code y: 17 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/DataCastingUtils.java x: 496 lines of code y: 18 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/HttpUtils.java x: 82 lines of code y: 4 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/TextParserUtils.java x: 69 lines of code y: 6 # changes v2/google-ads-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/GoogleAdsRowToReportRowJsonFn.java x: 92 lines of code y: 2 # changes v2/google-ads-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/utils/GoogleAdsRateLimitPolicyFactory.java x: 39 lines of code y: 2 # changes v2/google-ads-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/utils/GoogleAdsUtils.java x: 65 lines of code y: 2 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/JdbcSourceRowMapper.java x: 80 lines of code y: 15 # changes v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/templates/MongoDbUtils.java x: 215 lines of code y: 22 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/SpannerChangeStreamsToPubSubOptions.java x: 185 lines of code y: 18 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamsToPubSub.java x: 149 lines of code y: 17 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/FileFormatFactorySpannerChangeStreamsToPubSub.java x: 165 lines of code y: 7 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToAvro.java x: 188 lines of code y: 4 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToJson.java x: 74 lines of code y: 2 # changes v2/googlecloud-to-googlecloud/src/main/resources/schema/avro/datachangerecord.avsc x: 90 lines of code y: 4 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/AvroDynamicTransform.java x: 91 lines of code y: 7 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/KafkaRecordToGenericRecordFailsafeElementFn.java x: 103 lines of code y: 8 # changes v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/transforms/AvroWriteTransform.java x: 171 lines of code y: 24 # changes v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/transforms/WriteTransform.java x: 72 lines of code y: 19 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/FailsafeModJsonToTableRowTransformer.java x: 354 lines of code y: 30 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/model/Mod.java x: 185 lines of code y: 12 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/model/TrackedSpannerTable.java x: 113 lines of code y: 13 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/OptionsUtils.java x: 39 lines of code y: 8 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/SchemaUpdateUtils.java x: 96 lines of code y: 4 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/SpannerChangeStreamsUtils.java x: 430 lines of code y: 13 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/SpannerToBigQueryUtils.java x: 275 lines of code y: 14 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/TypesUtils.java x: 93 lines of code y: 4 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ddl/IndexColumn.java x: 170 lines of code y: 7 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/changestream/TrimmedShardedDataChangeRecord.java x: 148 lines of code y: 2 # changes v1/src/main/proto/export.proto x: 60 lines of code y: 5 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/utils/SchemaUtils.java x: 171 lines of code y: 17 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/FlexTemplateDataflowJobResourceManager.java x: 189 lines of code y: 3 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/BigQueryResourceManagerUtils.java x: 63 lines of code y: 12 # changes v1/src/main/java/com/google/cloud/teleport/spanner/common/NameUtils.java x: 64 lines of code y: 4 # changes v1/src/main/java/com/google/cloud/teleport/templates/TextToBigQueryStreaming.java x: 272 lines of code y: 17 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/DLPTextToBigQueryStreaming.java x: 592 lines of code y: 26 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventSpannerConvertor.java x: 189 lines of code y: 6 # changes v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToSQL.java x: 277 lines of code y: 35 # changes v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/transforms/CreateDml.java x: 63 lines of code y: 7 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManagerUtils.java x: 115 lines of code y: 16 # changes v1/src/main/java/com/google/cloud/teleport/bigtable/BigtableToAvro.java x: 200 lines of code y: 19 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/BoundaryTypeMapper.java x: 15 lines of code y: 3 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/PartitionColumn.java x: 42 lines of code y: 3 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/stringmapper/CollationIndex.java x: 165 lines of code y: 1 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/stringmapper/CollationOrderRow.java x: 87 lines of code y: 1 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/InitialSplitRangeDoFn.java x: 59 lines of code y: 4 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeBoundaryTransform.java x: 53 lines of code y: 3 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeCountTransform.java x: 53 lines of code y: 5 # changes v2/spanner-to-sourcedb/terraform/Spanner_Change_Streams_to_Sharded_File_Sink/dataflow_job.tf x: 250 lines of code y: 1 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/constants/MetricCounters.java x: 9 lines of code y: 8 # changes python/src/main/java/com/google/cloud/teleport/templates/python/YAMLTemplate.java x: 48 lines of code y: 18 # changes v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/processing/dml/DMLGenerator.java x: 373 lines of code y: 18 # changes v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/processing/handler/InputRecordProcessor.java x: 135 lines of code y: 15 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/utils/SpannerUtils.java x: 163 lines of code y: 6 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/conditions/BigQueryRowsCheck.java x: 77 lines of code y: 5 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/cloudsql/CloudMySQLResourceManager.java x: 34 lines of code y: 4 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/cloudsql/CloudSqlResourceManager.java x: 142 lines of code y: 4 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventTypeConvertor.java x: 210 lines of code y: 7 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/Range.java x: 223 lines of code y: 4 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeCountDoFn.java x: 120 lines of code y: 5 # changes v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms/WriteToElasticsearch.java x: 187 lines of code y: 39 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/config/TableConfig.java x: 32 lines of code y: 10 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/columnboundary/ColumnForBoundaryQuery.java x: 37 lines of code y: 3 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/columnboundary/package-info.java x: 1 lines of code y: 2 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/BoundaryExtractor.java x: 12 lines of code y: 2 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/RangePreparedStatementSetter.java x: 45 lines of code y: 2 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/MergeRangesDoFn.java x: 76 lines of code y: 3 # changes v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/templates/MongoDbToBigQuery.java x: 134 lines of code y: 24 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/InformationSchemaScanner.java x: 501 lines of code y: 4 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/dlq/BigQueryDeadLetterQueueOptions.java x: 30 lines of code y: 3 # changes v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryWriteUtils.java x: 375 lines of code y: 4 # changes v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToGcsFlex.java x: 151 lines of code y: 18 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/AbstractPipelineLauncher.java x: 289 lines of code y: 10 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventToMapConvertor.java x: 99 lines of code y: 7 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/DatadogConverters.java x: 232 lines of code y: 22 # changes v1/terraform/Cloud_PubSub_to_Datadog/dataflow_job.tf x: 187 lines of code y: 7 # changes v2/spanner-migrations-sdk/src/main/java/com/google/cloud/teleport/v2/spanner/utils/MigrationTransformationRequest.java x: 52 lines of code y: 7 # changes v2/spanner-migrations-sdk/src/main/java/com/google/cloud/teleport/v2/spanner/utils/MigrationTransformationResponse.java x: 31 lines of code y: 5 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastream/DatastreamResourceManager.java x: 421 lines of code y: 10 # changes metadata/src/main/java/com/google/cloud/teleport/metadata/TemplateParameter.java x: 406 lines of code y: 22 # changes plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/model/ImageSpecParameterType.java x: 23 lines of code y: 12 # changes v2/kafka-to-kafka/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToKafka.java x: 148 lines of code y: 16 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/cloudsql/CloudSqlContainer.java x: 51 lines of code y: 2 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastream/DatastreamResourceManagerUtils.java x: 33 lines of code y: 12 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/utils/SpannerResourceManagerUtils.java x: 81 lines of code y: 13 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/LoadTestBase.java x: 367 lines of code y: 14 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datagenerator/DataGenerator.java x: 209 lines of code y: 12 # changes v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/mappers/DataStreamMapper.java x: 101 lines of code y: 4 # changes v2/pubsub-cdc-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/PubSubCdcToBigQuery.java x: 389 lines of code y: 39 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/utils/FileAwareSchemaRegistryFactoryFn.java x: 14 lines of code y: 2 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/row/SourceRow.java x: 75 lines of code y: 7 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstovectorsearch/ChangeStreamMutationToDatapointOperationFn.java x: 170 lines of code y: 1 # changes v2/astradb-to-bigquery/src/main/java/com/google/cloud/teleport/v2/astradb/options/AstraDbToBigQueryOptions.java x: 91 lines of code y: 13 # changes v2/azure-eventhub-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/AzureEventhubToPubsub.java x: 130 lines of code y: 9 # changes v2/bigtable-changestreams-to-hbase/src/main/java/com/google/cloud/teleport/v2/templates/BigtableChangeStreamsToHBase.java x: 159 lines of code y: 22 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/WriteToGCSAvro.java x: 119 lines of code y: 15 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/WriteToGCSParquet.java x: 102 lines of code y: 14 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/WriteToGCSText.java x: 121 lines of code y: 12 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/options/DataplexBigQueryToGcsOptions.java x: 129 lines of code y: 7 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/options/DataplexJdbcIngestionOptions.java x: 214 lines of code y: 9 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/templates/DataplexFileFormatConversion.java x: 659 lines of code y: 6 # changes v2/datastream-to-mongodb/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToMongoDB.java x: 195 lines of code y: 19 # changes v2/datastream-to-postgres/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToPostgres.java x: 164 lines of code y: 15 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/BigtableChangeStreamsToGcsOptions.java x: 130 lines of code y: 10 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/FirestoreToBigQuery.java x: 177 lines of code y: 30 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/utils/FirestoreConverters.java x: 692 lines of code y: 8 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/auto/blocks/ReadFromPubSub.java x: 33 lines of code y: 5 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/auto/blocks/WriteToBigQuery.java x: 150 lines of code y: 8 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/auto/options/ReadFromJdbcOptions.java x: 126 lines of code y: 7 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/options/BigQueryCommonOptions.java x: 64 lines of code y: 20 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/PubsubToAvro.java x: 160 lines of code y: 12 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/TextIOToBigQuery.java x: 361 lines of code y: 46 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToGcsAvro.java x: 120 lines of code y: 14 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToGcsText.java x: 117 lines of code y: 11 # changes v2/pubsub-to-jms/src/main/java/com/google/cloud/teleport/v2/templates/PubsubToJms.java x: 143 lines of code y: 12 # changes v2/pubsub-to-kafka/src/main/java/com/google/cloud/teleport/v2/options/PubsubToKafkaOptions.java x: 50 lines of code y: 4 # changes v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamsToShardedFileSink.java x: 421 lines of code y: 23 # changes v1/src/main/java/com/google/cloud/teleport/templates/BulkCompressor.java x: 183 lines of code y: 16 # changes v1/src/main/java/com/google/cloud/teleport/templates/BulkDecompressor.java x: 213 lines of code y: 12 # changes v1/src/main/java/com/google/cloud/teleport/templates/DatastoreToBigQuery.java x: 66 lines of code y: 8 # changes v1/src/main/java/com/google/cloud/teleport/templates/ExportJobPlaceholder.java x: 112 lines of code y: 16 # changes v1/src/main/java/com/google/cloud/teleport/templates/PubsubToPubsub.java x: 196 lines of code y: 21 # changes v1/src/main/java/com/google/cloud/teleport/templates/PubsubToText.java x: 177 lines of code y: 20 # changes v1/src/main/java/com/google/cloud/teleport/templates/TextIOToBigQuery.java x: 215 lines of code y: 19 # changes v1/src/main/java/com/google/cloud/teleport/templates/TextToPubsub.java x: 66 lines of code y: 18 # changes v2/sourcedb-to-spanner/terraform/Sourcedb_to_Spanner_Flex/dataflow_job.tf x: 236 lines of code y: 5 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/transform/package-info.java x: 1 lines of code y: 3 # changes v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/utils/ShardingLogicImplFetcher.java x: 68 lines of code y: 4 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/transformation/CustomTransformation.java x: 31 lines of code y: 4 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/ChangeEventUtils.java x: 25 lines of code y: 2 # changes v2/pubsub-binary-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/PubsubAvroToBigQuery.java x: 110 lines of code y: 26 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/auto/dlq/BigQueryDeadletterOptions.java x: 17 lines of code y: 4 # changes v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/transforms/AssignShardIdFn.java x: 419 lines of code y: 14 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/utils/SslProducerFactoryFn.java x: 69 lines of code y: 3 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/storage/conditions/GCSArtifactsCheck.java x: 107 lines of code y: 6 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/utils/KafkaCommonUtils.java x: 105 lines of code y: 8 # changes plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/model/TemplateDefinitions.java x: 421 lines of code y: 50 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/JavascriptTextTransformer.java x: 371 lines of code y: 31 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/utils/BigQueryIOUtils.java x: 63 lines of code y: 9 # changes v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryDynamicDestination.java x: 55 lines of code y: 10 # changes v1/src/main/java/com/google/cloud/teleport/spanner/SpannerTableFilter.java x: 60 lines of code y: 3 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ddl/ChangeStream.java x: 75 lines of code y: 5 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Model.java x: 134 lines of code y: 6 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ddl/NamedSchema.java x: 50 lines of code y: 2 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ddl/View.java x: 70 lines of code y: 4 # changes v2/bigquery-to-bigtable/src/main/java/com/google/cloud/teleport/v2/templates/BigQueryToBigtable.java x: 79 lines of code y: 19 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/JdbcValueMapper.java x: 24 lines of code y: 10 # changes cicd/internal/op/maven.go x: 22 lines of code y: 15 # changes v1/src/main/java/com/google/cloud/teleport/templates/PubSubToBigQuery.java x: 279 lines of code y: 26 # changes v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/GCSReader.java x: 190 lines of code y: 20 # changes v2/googlecloud-to-splunk/src/main/java/com/google/cloud/teleport/v2/templates/GCSToSplunk.java x: 281 lines of code y: 25 # changes v2/googlecloud-to-splunk/src/main/java/com/google/cloud/teleport/v2/transforms/SplunkConverters.java x: 249 lines of code y: 14 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/BinaryAvroDeserializer.java x: 33 lines of code y: 9 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/ReaderImpl.java x: 31 lines of code y: 6 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/auth/dbauth/package-info.java x: 1 lines of code y: 6 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/JdbcValueMappingsProvider.java x: 6 lines of code y: 9 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/ResultSetValueExtractor.java x: 9 lines of code y: 9 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/ResultSetValueMapper.java x: 10 lines of code y: 9 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/transform/AccumulatingTableReader.java x: 81 lines of code y: 11 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/transform/ReaderTransform.java x: 46 lines of code y: 11 # changes v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/changestream/DataChangeRecordTypeConvertor.java x: 133 lines of code y: 4 # changes v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/utils/SpannerDao.java x: 420 lines of code y: 12 # changes v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/templates/StreamingDataGenerator.java x: 617 lines of code y: 37 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/options/BigQueryStorageApiStreamingOptions.java x: 56 lines of code y: 13 # changes v1/src/main/java/com/google/cloud/teleport/options/CommonTemplateOptions.java x: 33 lines of code y: 11 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/coders/GenericRecordCoder.java x: 41 lines of code y: 6 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/options/BigQueryStorageApiBatchOptions.java x: 26 lines of code y: 9 # changes v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/options/package-info.java x: 1 lines of code y: 5 # changes v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/transforms/JsonWriteTransform.java x: 65 lines of code y: 6 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/exception/RetriableSchemaDiscoveryException.java x: 6 lines of code y: 5 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/ErrorConverters.java x: 258 lines of code y: 9 # changes v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options/BigQueryToElasticsearchOptions.java x: 7 lines of code y: 7 # changes v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates/BigQueryToElasticsearch.java x: 124 lines of code y: 28 # changes v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates/GCSToElasticsearch.java x: 183 lines of code y: 26 # changes v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates/PubSubToElasticsearch.java x: 177 lines of code y: 36 # changes v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms/PubSubMessageToJsonDocument.java x: 108 lines of code y: 13 # changes v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToGCS.java x: 86 lines of code y: 15 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/PythonExternalTextTransformer.java x: 286 lines of code y: 10 # changes v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/utils/ElasticsearchIO.java x: 1067 lines of code y: 40 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/package-info.java x: 1 lines of code y: 4 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/row/SerializableGenericRecord.java x: 53 lines of code y: 4 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/exceptions/AvroTypeConvertorException.java x: 12 lines of code y: 3 # changes yaml/src/main/java/com/google/cloud/teleport/templates/yaml/KafkaToBigQueryYaml.java x: 111 lines of code y: 6 # changes yaml/src/main/python/main.py x: 18 lines of code y: 6 # changes v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToGCSFlex.java x: 151 lines of code y: 2 # changes plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/model/ImageSpecMetadata.java x: 165 lines of code y: 16 # changes v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dao/SpannerDao.java x: 335 lines of code y: 12 # changes v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/ShardFileCreationTracker.java x: 67 lines of code y: 10 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/logicaltypes/IsoDateTime.java x: 39 lines of code y: 3 # changes v1/src/main/java/com/google/cloud/teleport/splunk/SplunkEventWriter.java x: 377 lines of code y: 6 # changes cicd/cmd/run-terraform-schema/generate/freemarker.go x: 148 lines of code y: 7 # changes cicd/internal/terraform/templates.go x: 137 lines of code y: 9 # changes plugins/core-plugin/src/main/resources/terraform-flex-template.tf x: 149 lines of code y: 7 # changes v1/terraform/Bulk_Compress_GCS_Files/dataflow_job.tf x: 138 lines of code y: 5 # changes v1/terraform/Bulk_Decompress_GCS_Files/dataflow_job.tf x: 127 lines of code y: 5 # changes v1/terraform/Cloud_BigQuery_to_Cloud_Datastore/dataflow_job.tf x: 157 lines of code y: 5 # changes v1/terraform/Cloud_BigQuery_to_GCS_TensorFlow_Records/dataflow_job.tf x: 158 lines of code y: 5 # changes v1/terraform/Cloud_Bigtable_to_GCS_Avro/dataflow_job.tf x: 140 lines of code y: 5 # changes v1/terraform/Cloud_Bigtable_to_GCS_Json/dataflow_job.tf x: 153 lines of code y: 5 # changes v1/terraform/Cloud_Bigtable_to_GCS_Parquet/dataflow_job.tf x: 146 lines of code y: 5 # changes v1/terraform/Cloud_Bigtable_to_GCS_SequenceFile/dataflow_job.tf x: 168 lines of code y: 5 # changes v1/terraform/Cloud_Bigtable_to_Vector_Embeddings/dataflow_job.tf x: 193 lines of code y: 3 # changes v1/terraform/Cloud_PubSub_to_Avro/dataflow_job.tf x: 175 lines of code y: 5 # changes v1/terraform/Cloud_PubSub_to_Cloud_PubSub/dataflow_job.tf x: 134 lines of code y: 5 # changes v1/terraform/Cloud_PubSub_to_GCS_Text/dataflow_job.tf x: 177 lines of code y: 5 # changes v1/terraform/Cloud_PubSub_to_Splunk/dataflow_job.tf x: 211 lines of code y: 5 # changes v1/terraform/Cloud_Spanner_to_GCS_Avro/dataflow_job.tf x: 181 lines of code y: 5 # changes v1/terraform/Datastore_to_Datastore_Delete/dataflow_job.tf x: 151 lines of code y: 5 # changes v1/terraform/GCS_CSV_to_BigQuery/dataflow_job.tf x: 184 lines of code y: 3 # changes v1/terraform/GCS_SequenceFile_to_Cloud_Bigtable/dataflow_job.tf x: 144 lines of code y: 5 # changes v1/terraform/GCS_Text_to_Cloud_Spanner/dataflow_job.tf x: 205 lines of code y: 5 # changes v1/terraform/Jdbc_to_BigQuery/dataflow_job.tf x: 186 lines of code y: 5 # changes v1/terraform/Spanner_to_GCS_Text/dataflow_job.tf x: 167 lines of code y: 5 # changes v2/azure-eventhub-to-pubsub/terraform/Azure_Eventhub_to_PubSub/dataflow_job.tf x: 159 lines of code y: 3 # changes v2/bigquery-to-bigtable/terraform/BigQuery_to_Bigtable/dataflow_job.tf x: 237 lines of code y: 3 # changes v2/bigquery-to-parquet/terraform/BigQuery_to_Parquet/dataflow_job.tf x: 167 lines of code y: 3 # changes v2/bigtable-changestreams-to-hbase/terraform/Bigtable_Change_Streams_to_HBase/dataflow_job.tf x: 278 lines of code y: 3 # changes v2/cdc-parent/cdc-change-applier/terraform/Cdc_To_BigQuery_Template/dataflow_job.tf x: 199 lines of code y: 3 # changes v2/dataplex/terraform/Dataplex_BigQuery_to_GCS/dataflow_job.tf x: 209 lines of code y: 3 # changes v2/dataplex/terraform/Dataplex_File_Format_Conversion/dataflow_job.tf x: 172 lines of code y: 3 # changes v2/dataplex/terraform/Dataplex_JDBC_Ingestion/dataflow_job.tf x: 251 lines of code y: 3 # changes v2/datastream-to-bigquery/terraform/Cloud_Datastream_to_BigQuery/dataflow_job.tf x: 320 lines of code y: 3 # changes v2/datastream-to-sql/terraform/Cloud_Datastream_to_SQL/dataflow_job.tf x: 219 lines of code y: 3 # changes v2/file-format-conversion/terraform/File_Format_Conversion/dataflow_job.tf x: 224 lines of code y: 3 # changes v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/ProcessingContextGenerator.java x: 224 lines of code y: 17 # changes v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/ShardProgressTracker.java x: 102 lines of code y: 10 # changes v2/gcs-to-sourcedb/terraform/GCS_to_Sourcedb/dataflow_job.tf x: 216 lines of code y: 3 # changes v2/google-ads-to-googlecloud/terraform/Google_Ads_to_BigQuery/dataflow_job.tf x: 203 lines of code y: 3 # changes v2/googlecloud-to-elasticsearch/terraform/BigQuery_to_Elasticsearch/dataflow_job.tf x: 338 lines of code y: 3 # changes v2/googlecloud-to-elasticsearch/terraform/GCS_to_Elasticsearch/dataflow_job.tf x: 366 lines of code y: 3 # changes v2/googlecloud-to-elasticsearch/terraform/PubSub_to_Elasticsearch/dataflow_job.tf x: 337 lines of code y: 3 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamsToGcs.java x: 131 lines of code y: 17 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/BigtableChangeStreamsToGcs.java x: 247 lines of code y: 8 # changes v2/googlecloud-to-googlecloud/terraform/Bigtable_Change_Streams_to_BigQuery/dataflow_job.tf x: 267 lines of code y: 4 # changes v2/googlecloud-to-googlecloud/terraform/Bigtable_Change_Streams_to_Google_Cloud_Storage/dataflow_job.tf x: 275 lines of code y: 4 # changes v2/googlecloud-to-googlecloud/terraform/Bigtable_Change_Streams_to_PubSub/dataflow_job.tf x: 279 lines of code y: 4 # changes v2/googlecloud-to-googlecloud/terraform/Cloud_Spanner_to_BigQuery_Flex/dataflow_job.tf x: 208 lines of code y: 4 # changes v2/googlecloud-to-googlecloud/terraform/Firestore_to_BigQuery_Flex/dataflow_job.tf x: 209 lines of code y: 4 # changes v2/googlecloud-to-googlecloud/terraform/GCS_Text_to_BigQuery_Flex/dataflow_job.tf x: 183 lines of code y: 4 # changes v2/googlecloud-to-googlecloud/terraform/Spanner_Change_Streams_to_BigQuery/dataflow_job.tf x: 274 lines of code y: 4 # changes v2/googlecloud-to-googlecloud/terraform/Spanner_Change_Streams_to_Google_Cloud_Storage/dataflow_job.tf x: 235 lines of code y: 4 # changes v2/googlecloud-to-googlecloud/terraform/Spanner_Change_Streams_to_PubSub/dataflow_job.tf x: 229 lines of code y: 4 # changes v2/googlecloud-to-splunk/terraform/GCS_To_Splunk/dataflow_job.tf x: 272 lines of code y: 3 # changes v2/jms-to-pubsub/terraform/Jms_to_PubSub/dataflow_job.tf x: 170 lines of code y: 3 # changes v2/kafka-to-gcs/terraform/Kafka_to_GCS/dataflow_job.tf x: 178 lines of code y: 3 # changes v2/mongodb-to-googlecloud/terraform/MongoDB_to_BigQuery/dataflow_job.tf x: 197 lines of code y: 3 # changes v2/pubsub-binary-to-bigquery/terraform/PubSub_Proto_to_BigQuery/dataflow_job.tf x: 239 lines of code y: 4 # changes v2/pubsub-cdc-to-bigquery/terraform/PubSub_CDC_to_BigQuery/dataflow_job.tf x: 270 lines of code y: 4 # changes v2/pubsub-to-kafka/terraform/PubSub_to_Kafka/dataflow_job.tf x: 190 lines of code y: 3 # changes v2/streaming-data-generator/terraform/Streaming_Data_Generator/dataflow_job.tf x: 324 lines of code y: 3 # changes v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/transforms/StreamingDataGeneratorWriteToKafka.java x: 141 lines of code y: 2 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/BigQueryDynamicConverters.java x: 110 lines of code y: 7 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/dlq/DeadLetterQueueManager.java x: 111 lines of code y: 11 # changes it/splunk/src/main/java/org/apache/beam/it/splunk/CustomSplunkResourceManager.java x: 247 lines of code y: 2 # changes it/splunk/src/main/java/org/apache/beam/it/splunk/conditions/CustomSplunkEventsCheck.java x: 63 lines of code y: 2 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/templates/DataplexJdbcIngestion.java x: 395 lines of code y: 7 # changes cicd/cmd/run-terraform-schema/describe/command.go x: 128 lines of code y: 4 # changes cicd/internal/terraform/filter.go x: 18 lines of code y: 5 # changes cicd/internal/terraform/freemarker_resource_extra.ftl x: 5 lines of code y: 3 # changes cicd/internal/terraform/schemas/schemas.go x: 4 lines of code y: 4 # changes v1/src/main/java/com/google/cloud/teleport/templates/TextToDatastore.java x: 107 lines of code y: 15 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/DirectRunnerClient.java x: 197 lines of code y: 8 # changes v1/src/main/java/com/google/cloud/teleport/templates/PubSubToSplunk.java x: 271 lines of code y: 17 # changes v1/src/main/java/com/google/cloud/teleport/templates/TextToPubsubStream.java x: 53 lines of code y: 11 # changes python/src/main/java/com/google/cloud/teleport/templates/python/WordCountPython.java x: 18 lines of code y: 8 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/AvroConverters.java x: 172 lines of code y: 15 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/ParquetConverters.java x: 177 lines of code y: 13 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/PythonTextTransformer.java x: 394 lines of code y: 16 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/utils/JsonTestUtil.java x: 140 lines of code y: 6 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/DefaultPipelineLauncher.java x: 410 lines of code y: 14 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/kms/KMSResourceManager.java x: 148 lines of code y: 8 # changes v2/pubsub-to-kafka/src/main/java/com/google/cloud/teleport/v2/templates/PubsubToKafka.java x: 126 lines of code y: 8 # changes v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/constants/Constants.java x: 10 lines of code y: 5 # changes cicd/internal/repo/modules.go x: 127 lines of code y: 18 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastream/JDBCSource.java x: 59 lines of code y: 5 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastream/MySQLSource.java x: 42 lines of code y: 5 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/connection/ConnectionParams.java x: 45 lines of code y: 8 # changes metadata/src/main/java/com/google/cloud/teleport/metadata/TemplateCategory.java x: 28 lines of code y: 4 # changes v2/jdbc-common/src/main/java/com/google/cloud/teleport/v2/auto/blocks/ReadFromJdbc.java x: 74 lines of code y: 4 # changes v1/src/main/java/com/google/cloud/teleport/templates/DatastoreToDatastoreDelete.java x: 113 lines of code y: 12 # changes v1/src/main/java/com/google/cloud/teleport/templates/DatastoreToText.java x: 89 lines of code y: 11 # changes v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/cdc/merge/BigQueryMergeValidatorTemplate.java x: 86 lines of code y: 2 # changes v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/cdc/merge/BigQueryMerger.java x: 197 lines of code y: 2 # changes v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/cdc/merge/MergeInfo.java x: 153 lines of code y: 2 # changes v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/cdc/merge/MergeStatementBuilder.java x: 189 lines of code y: 2 # changes v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/io/CdcJdbcIO.java x: 403 lines of code y: 2 # changes v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/mappers/MergeInfoMapper.java x: 115 lines of code y: 2 # changes v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/transforms/FormatDatastreamRecord.java x: 77 lines of code y: 2 # changes v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/utils/DataStreamClient.java x: 461 lines of code y: 2 # changes v2/datastream-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/StatefulRowCleaner.java x: 160 lines of code y: 8 # changes v2/datastream-to-postgres/src/main/java/com/google/cloud/teleport/v2/utils/DatabaseMigrationUtils.java x: 456 lines of code y: 8 # changes v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/transforms/ProcessDml.java x: 71 lines of code y: 6 # changes v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/utils/DatastreamToMySQLDML.java x: 47 lines of code y: 5 # changes v1/src/main/java/com/google/cloud/teleport/spanner/AvroTableFileAsMutations.java x: 80 lines of code y: 3 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/io/AvroSinkWithJodaDatesConversion.java x: 70 lines of code y: 3 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryTableToGcsTransform.java x: 217 lines of code y: 5 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/Schemas.java x: 156 lines of code y: 3 # changes v2/file-format-conversion/src/main/java/com/google/cloud/teleport/v2/templates/FileFormatConversionFactory.java x: 133 lines of code y: 10 # changes v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/transforms/StreamingDataGeneratorWriteToGcs.java x: 155 lines of code y: 11 # changes v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/JavascriptDocumentTransformer.java x: 175 lines of code y: 2 # changes v1/src/main/java/com/google/cloud/teleport/datadog/DatadogEventPublisher.java x: 182 lines of code y: 12 # changes v1/src/main/java/com/google/cloud/teleport/splunk/HttpEventPublisher.java x: 237 lines of code y: 6 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/mappers/BigQueryMapper.java x: 254 lines of code y: 26 # changes v2/jdbc-common/src/main/java/com/google/cloud/teleport/v2/utils/JdbcIngestionWriteDisposition.java x: 39 lines of code y: 4 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/clients/DefaultDataplexClient.java x: 243 lines of code y: 2 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/templates/DataplexBigQueryToGcs.java x: 299 lines of code y: 2 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/transforms/DataplexBigQueryToGcsUpdateMetadata.java x: 214 lines of code y: 2 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/transforms/DeleteBigQueryDataFn.java x: 122 lines of code y: 2 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/BigQueryMetadataLoader.java x: 158 lines of code y: 2 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/DataplexBigQueryToGcsFilter.java x: 163 lines of code y: 2 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/DataplexJdbcIngestionFilter.java x: 103 lines of code y: 2 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/DataplexJdbcPartitionUtils.java x: 100 lines of code y: 2 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/DataplexUtils.java x: 316 lines of code y: 2 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/values/DataplexCompression.java x: 56 lines of code y: 2 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/JdbcConverters.java x: 216 lines of code y: 7 # changes v2/jdbc-common/src/main/java/com/google/cloud/teleport/v2/utils/JdbcConverters.java x: 101 lines of code y: 3 # changes v2/cdc-parent/cdc-embedded-connector/src/main/java/com/google/cloud/dataflow/cdc/connector/DebeziumSourceRecordToDataflowCdcFormatTranslator.java x: 257 lines of code y: 8 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Index.java x: 147 lines of code y: 3 # changes v1/src/main/java/com/google/cloud/teleport/templates/JdbcToBigQuery.java x: 81 lines of code y: 10 # changes v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/transforms/WriterGCS.java x: 106 lines of code y: 3 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManager.java x: 405 lines of code y: 14 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TemplateLoadTestBase.java x: 43 lines of code y: 4 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/SubprocessTextTransformer.java x: 290 lines of code y: 4 # changes it/datadog/src/main/java/com/google/cloud/teleport/it/datadog/conditions/DatadogLogEntriesCheck.java x: 54 lines of code y: 4 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/UDFTextTransformer.java x: 96 lines of code y: 8 # changes v2/kafka-to-pubsub/src/main/java/com/google/cloud/teleport/v2/transforms/FormatTransform.java x: 70 lines of code y: 11 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastore/DatastoreResourceManager.java x: 110 lines of code y: 5 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub/PubsubUtils.java x: 48 lines of code y: 5 # changes v1/src/main/java/com/google/cloud/teleport/datadog/DatadogEventWriter.java x: 367 lines of code y: 13 # changes v1/src/main/java/com/google/cloud/teleport/datadog/DatadogIO.java x: 153 lines of code y: 13 # changes v1/src/main/java/com/google/cloud/teleport/io/WindowedFilenamePolicy.java x: 302 lines of code y: 5 # changes v1/src/main/java/com/google/cloud/teleport/spanner/TextSource.java x: 183 lines of code y: 5 # changes v1/src/main/java/com/google/cloud/teleport/splunk/SplunkIO.java x: 198 lines of code y: 6 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/io/WindowedFilenamePolicy.java x: 236 lines of code y: 10 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/utils/DurationUtils.java x: 28 lines of code y: 8 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/utils/GCSUtils.java x: 82 lines of code y: 7 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/values/FailsafeElement.java x: 74 lines of code y: 6 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/WriteChangeStreamMutationsToGcsText.java x: 117 lines of code y: 5 # changes v2/kafka-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToPubsub.java x: 107 lines of code y: 9 # changes v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/transforms/StreamingDataGeneratorWriteToBigQuery.java x: 88 lines of code y: 8 # changes v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/transforms/StreamingDataGeneratorWriteToPubSub.java x: 206 lines of code y: 10 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/JsonStringToMutationFn.java x: 82 lines of code y: 3 # changes python/src/main/python/streaming-llm/main.py x: 117 lines of code y: 2 # changes v2/astradb-to-bigquery/src/main/java/com/google/cloud/teleport/v2/astradb/templates/AstraDbToBigQuery.java x: 161 lines of code y: 5 # changes v2/googlecloud-to-mongodb/src/main/java/com/google/cloud/teleport/v2/mongodb/templates/BigQueryToMongoDb.java x: 76 lines of code y: 12 # changes plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/model/json/TemplatesCategoryJsonModel.java x: 81 lines of code y: 1 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/GCPBaseIT.java x: 24 lines of code y: 5 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/secretmanager/SecretManagerResourceManager.java x: 180 lines of code y: 3 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsublite/PubsubliteResourceManager.java x: 156 lines of code y: 2 # changes v2/bigtable-changestreams-to-hbase/src/main/java/com/google/cloud/teleport/v2/templates/utils/RowMutationsBuilder.java x: 203 lines of code y: 2 # changes v1/src/main/java/com/google/cloud/teleport/templates/DatastoreToPubsub.java x: 36 lines of code y: 4 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/mappers/BigQueryDefaultSchemas.java x: 39 lines of code y: 7 # changes v2/pubsub-to-redis/src/main/java/com/google/cloud/teleport/v2/templates/transforms/MessageTransformation.java x: 137 lines of code y: 2 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/FileSystemUtils.java x: 17 lines of code y: 7 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/utils/MappedObjectCache.java x: 67 lines of code y: 7 # changes v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/BigQueryStatementIssuingFn.java x: 89 lines of code y: 8 # changes v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/BigQueryChangeApplier.java x: 204 lines of code y: 10 # changes v2/cdc-parent/cdc-common/src/main/java/com/google/cloud/dataflow/cdc/common/DataCatalogSchemaUtils.java x: 237 lines of code y: 10 # changes v1/src/main/java/com/google/cloud/teleport/datadog/DatadogEvent.java x: 54 lines of code y: 3 # changes v1/src/main/java/com/google/cloud/teleport/util/DatadogApiKeyNestedValueProvider.java x: 100 lines of code y: 3 # changes v2/bigtable-common/src/main/java/com/google/cloud/teleport/v2/bigtable/utils/BigtableConfig.java x: 79 lines of code y: 4 # changes v2/kafka-to-pubsub/src/main/java/com/google/cloud/teleport/v2/kafka/consumer/Utils.java x: 89 lines of code y: 10 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/mappers/BigQueryMappers.java x: 70 lines of code y: 5 # changes cicd/cmd/run-spotless/main.go x: 15 lines of code y: 12 # changes v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/utils/ConnectionInformation.java x: 90 lines of code y: 6 # changes v2/kudu-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KuduToBigQuery.java x: 100 lines of code y: 5 # changes v1/src/main/java/com/google/cloud/teleport/util/TokenNestedValueProvider.java x: 100 lines of code y: 1 # changes cicd/internal/op/run-cmd.go x: 35 lines of code y: 6 # changes v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/CdcPCollectionsFetchers.java x: 163 lines of code y: 3 # changes v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/PubsubUtils.java x: 94 lines of code y: 5 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/coders/FailsafeElementCoder.java x: 66 lines of code y: 3 # changes v2/flex-wordcount-python/wordcount.py x: 125 lines of code y: 1 # changes
74.0
# changes
  min: 1.0
  average: 5.82
  25th percentile: 2.0
  median: 3.0
  75th percentile: 6.0
  max: 74.0
0 1746.0
lines of code
min: 1.0 | average: 98.76 | 25th percentile: 9.0 | median: 49.0 | 75th percentile: 144.0 | max: 1746.0

Number of Contributors vs. Number of Changes: 1642 points

v2/bigtable-common/src/main/java/com/google/cloud/teleport/v2/bigtable/options/BigtableCommonOptions.java x: 15 # contributors y: 23 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/BigtableChangeStreamsToBigQuery.java x: 6 # contributors y: 16 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/model/Mod.java x: 5 # contributors y: 6 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/schemautils/BigQueryUtils.java x: 4 # contributors y: 5 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/BigtableUtils.java x: 4 # contributors y: 7 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/BigtableChangeStreamsToPubSub.java x: 10 # contributors y: 12 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/schemautils/PubSubUtils.java x: 3 # contributors y: 3 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToSpanner.java x: 33 # contributors y: 74 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/BigQueryResourceManager.java x: 5 # contributors y: 8 # changes v2/bigquery-to-parquet/src/main/java/com/google/cloud/teleport/v2/templates/BigQueryToParquet.java x: 15 # contributors y: 22 # changes python/src/main/python/yaml-template/main.py x: 11 # contributors y: 17 # changes v2/cdc-parent/cdc-embedded-connector/src/main/java/com/google/cloud/dataflow/cdc/connector/App.java x: 5 # contributors y: 11 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/SourceDbToSpanner.java x: 11 # contributors y: 29 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/SpannerToSourceDb.java x: 5 # contributors y: 9 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/CassandraDMLGenerator.java x: 2 # contributors y: 4 # changes v2/failure-injected-spanner-service/src/main/java/com/google/cloud/teleport/v2/spanner/service/SpannerService.java x: 1 # contributors y: 1 # changes v2/spanner-custom-shard/src/main/java/com/custom/CustomTransformationWithCassandraForIT.java x: 2 # contributors y: 2 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/CassandraTypeHandler.java x: 2 # contributors y: 7 # changes plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesStageMojo.java x: 18 # contributors y: 65 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/SpannerChangeStreamsToBigQuery.java x: 14 # contributors y: 41 # changes plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/TemplateDefinitionsParser.java x: 6 # contributors y: 7 # changes plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/TemplateSpecsGenerator.java x: 12 # contributors y: 19 # changes plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesBaseMojo.java x: 2 # contributors y: 3 # changes plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesReleaseMojo.java x: 6 # contributors y: 17 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/options/SourceDbToSpannerOptions.java x: 14 # contributors y: 38 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraDataSource.java x: 1 # contributors y: 5 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraIOWrapperFactory.java x: 1 # contributors y: 3 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/MigrateTableTransform.java x: 3 # contributors y: 6 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/writer/SpannerWriter.java x: 4 # contributors y: 6 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/SpannerResourceManager.java x: 8 # contributors y: 17 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/transformer/SourceRowToMutationDoFn.java x: 8 # contributors y: 22 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TemplateTestBase.java x: 20 # contributors y: 44 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/avro/GenericRecordTypeConvertor.java x: 8 # contributors y: 35 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/ISchemaMapper.java x: 9 # contributors y: 14 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/IdentityMapper.java x: 9 # contributors y: 13 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SessionBasedMapper.java x: 10 # contributors y: 19 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ddl/DatabaseOptionAllowlist.java x: 4 # contributors y: 4 # changes cicd/internal/flags/common-flags.go x: 10 # contributors y: 16 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/mappings/CassandraMappingsProvider.java x: 1 # contributors y: 4 # changes v1/src/main/java/com/google/cloud/teleport/spanner/BuildReadFromTableOperations.java x: 8 # contributors y: 10 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ExportPipeline.java x: 13 # contributors y: 28 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ExportTransform.java x: 9 # contributors y: 15 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ImportPipeline.java x: 9 # contributors y: 28 # changes v1/src/main/java/com/google/cloud/teleport/spanner/TextImportPipeline.java x: 18 # contributors y: 31 # changes v1/src/main/java/com/google/cloud/teleport/spanner/TextImportTransform.java x: 9 # contributors y: 12 # changes v1/src/main/java/com/google/cloud/teleport/templates/SpannerToText.java x: 6 # contributors y: 15 # changes v1/src/main/java/com/google/cloud/teleport/templates/SpannerVectorEmbeddingExport.java x: 14 # contributors y: 14 # changes v1/src/main/java/com/google/cloud/teleport/templates/TextToSpanner.java x: 8 # contributors y: 7 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/SpannerConverters.java x: 15 # contributors y: 24 # changes plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/PromoteHelper.java x: 1 # contributors y: 2 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/storage/GcsResourceManager.java x: 8 # contributors y: 13 # changes v1/src/main/java/com/google/cloud/teleport/templates/CSVToBigQuery.java x: 8 # contributors y: 11 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/CsvConverters.java x: 9 # contributors y: 10 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/SpannerTransactionWriterDoFn.java x: 15 # contributors y: 38 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/options/KafkaReadOptions.java x: 14 # contributors y: 26 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/options/KafkaWriteOptions.java x: 6 # contributors y: 12 # changes v1/src/main/java/com/google/cloud/teleport/spanner/AvroSchemaToDdlConverter.java x: 18 # contributors y: 26 # changes v1/src/main/java/com/google/cloud/teleport/spanner/AvroUtil.java x: 10 # contributors y: 14 # changes v1/src/main/java/com/google/cloud/teleport/spanner/DdlToAvroSchemaConverter.java x: 22 # contributors y: 31 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ddl/InformationSchemaScanner.java x: 15 # contributors y: 31 # changes v1/src/main/java/com/google/cloud/teleport/templates/BigQueryToTFRecord.java x: 14 # contributors y: 25 # changes v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/transforms/FormatDatastreamRecordToJson.java x: 11 # contributors y: 19 # changes v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/SourceWriterFn.java x: 4 # contributors y: 13 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/avro/AvroToValueMapper.java x: 8 # contributors y: 15 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/MySqlChangeEventSequence.java x: 7 # contributors y: 15 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/PostgresChangeEventSequence.java x: 4 # contributors y: 12 # changes v1/src/main/java/com/google/cloud/teleport/spanner/SpannerRecordConverter.java x: 13 # contributors y: 19 # changes v1/src/main/java/com/google/cloud/teleport/spanner/common/SizedType.java x: 14 # contributors y: 18 # changes v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Column.java x: 17 # contributors y: 21 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/UnifiedTypeMapping.java x: 3 # contributors y: 4 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/UnifiedMappingProvider.java x: 3 # contributors y: 5 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/database/Neo4jConnection.java x: 12 # contributors y: 27 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/Schema.java x: 10 # contributors y: 11 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventContextFactory.java x: 9 # contributors y: 22 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventSequenceFactory.java x: 6 # contributors y: 13 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/MySqlChangeEventContext.java x: 7 # contributors y: 14 # changes v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/PostgresChangeEventContext.java x: 4 # contributors y: 11 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/matchers/ArtifactsSubject.java x: 4 # contributors y: 8 # changes cicd/internal/workflows/maven-workflows.go x: 20 # contributors y: 59 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/templates/GoogleCloudToNeo4j.java x: 6 # contributors y: 38 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/BeamBlock.java x: 5 # contributors y: 12 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/transforms/Neo4jRowWriterTransform.java x: 8 # contributors y: 28 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/ModelUtils.java x: 7 # contributors y: 26 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/spanner/SpannerSchema.java x: 3 # contributors y: 2 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub/PubsubResourceManager.java x: 6 # contributors y: 14 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/PipelineController.java x: 7 # contributors y: 18 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/mysql/MysqlDialectAdapter.java x: 14 # contributors y: 30 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/JdbcIoWrapper.java x: 10 # contributors y: 34 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/SourceColumnIndexInfo.java x: 3 # contributors y: 7 # changes plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/model/ImageSpecParameter.java x: 12 # contributors y: 25 # changes v1/src/main/java/com/google/cloud/teleport/bigtable/AvroToBigtable.java x: 13 # contributors y: 21 # changes v1/src/main/java/com/google/cloud/teleport/bigtable/BigtableToVectorEmbeddings.java x: 14 # contributors y: 20 # changes v1/src/main/java/com/google/cloud/teleport/bigtable/CassandraToBigtable.java x: 13 # contributors y: 26 # changes v1/src/main/java/com/google/cloud/teleport/bigtable/ParquetToBigtable.java x: 10 # contributors y: 22 # changes v1/src/main/java/com/google/cloud/teleport/options/WindowedFilenamePolicyOptions.java x: 15 # contributors y: 17 # changes v1/src/main/java/com/google/cloud/teleport/templates/DLPTextToBigQueryStreaming.java x: 10 # contributors y: 24 # changes v1/src/main/java/com/google/cloud/teleport/templates/PubsubToAvro.java x: 12 # contributors y: 24 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/BigQueryConverters.java x: 11 # contributors y: 14 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/DatastoreConverters.java x: 15 # contributors y: 26 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/PubsubConverters.java x: 11 # contributors y: 9 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/SplunkConverters.java x: 11 # contributors y: 15 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/TextConverters.java x: 15 # contributors y: 16 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/options/CommonTemplateOptions.java x: 15 # contributors y: 21 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/options/WindowedFilenamePolicyOptions.java x: 13 # contributors y: 16 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryConverters.java x: 22 # contributors y: 51 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/CsvConverters.java x: 19 # contributors y: 36 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/JavascriptTextTransformer.java x: 21 # contributors y: 37 # changes v2/datastream-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToBigQuery.java x: 22 # contributors y: 55 # changes v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options/ElasticsearchWriteOptions.java x: 19 # contributors y: 45 # changes v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/GCSToSourceDb.java x: 13 # contributors y: 29 # changes v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options/GCSToElasticsearchOptions.java x: 11 # contributors y: 13 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/BigtableChangeStreamToBigQueryOptions.java x: 14 # contributors y: 15 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/BigtableChangeStreamsToPubSubOptions.java x: 10 # contributors y: 13 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/SpannerChangeStreamsToBigQueryOptions.java x: 10 # contributors y: 26 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/SpannerChangeStreamsToGcsOptions.java x: 10 # contributors y: 18 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/PubSubToBigQuery.java x: 24 # contributors y: 45 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/pubsubtotext/PubsubToText.java x: 21 # contributors y: 30 # changes v2/googlecloud-to-mongodb/src/main/java/com/google/cloud/teleport/v2/mongodb/options/BigQueryToMongoDbOptions.java x: 7 # contributors y: 13 # changes v2/jms-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/JmsToPubsub.java x: 12 # contributors y: 18 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/options/SchemaRegistryOptions.java x: 7 # contributors y: 8 # changes v2/kafka-to-pubsub/src/main/java/com/google/cloud/teleport/v2/options/KafkaToPubsubOptions.java x: 7 # contributors y: 11 # changes v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/options/MongoDbToBigQueryOptions.java x: 20 # contributors y: 31 # changes v2/pubsub-binary-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/PubsubProtoToBigQuery.java x: 21 # contributors y: 49 # changes v2/pubsub-to-redis/src/main/java/com/google/cloud/teleport/v2/templates/PubSubToRedis.java x: 15 # contributors y: 25 # changes cicd/internal/flags/it-flags.go x: 10 # contributors y: 25 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/bigquery/BigQueryImpl.java x: 6 # contributors y: 10 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/options/OptionsToConfigBuilder.java x: 11 # contributors y: 23 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/SpannerToBigQueryOptions.java x: 9 # contributors y: 21 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/provider/MysqlJdbcValueMappings.java x: 10 # contributors y: 10 # changes v2/mqtt-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/MqttToPubsub.java x: 17 # contributors y: 25 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/DialectAdapter.java x: 8 # contributors y: 8 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/SourceSchemaReference.java x: 8 # contributors y: 6 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/BeamUtils.java x: 8 # contributors y: 12 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/config/defaults/MySqlConfigDefaults.java x: 7 # contributors y: 16 # changes v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/ShardFileReader.java x: 7 # contributors y: 9 # changes metadata/src/main/java/com/google/cloud/teleport/metadata/Template.java x: 14 # contributors y: 31 # changes cicd/cmd/run-build/main.go x: 5 # contributors y: 16 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/KafkaTransform.java x: 13 # contributors y: 17 # changes v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQuery.java x: 20 # contributors y: 46 # changes v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryFlex.java x: 16 # contributors y: 31 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/BigQueryDynamicDestinations.java x: 9 # contributors y: 18 # changes v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/StringMessageToTableRow.java x: 10 # contributors y: 7 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/ActionDoFnFactory.java x: 4 # contributors y: 3 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/preload/PreloadCypherAction.java x: 5 # contributors y: 14 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/InputValidator.java x: 6 # contributors y: 25 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/MappingMapper.java x: 5 # contributors y: 13 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/OptionsParamsMapper.java x: 5 # contributors y: 10 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/job/ActionContext.java x: 5 # contributors y: 7 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/LineToRowFn.java x: 7 # contributors y: 7 # changes v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/TextTargetToRow.java x: 5 # contributors y: 5 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/JdbcSourceRowMapper.java x: 12 # contributors y: 15 # changes v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/templates/MongoDbUtils.java x: 5 # contributors y: 22 # changes v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/transforms/AvroWriteTransform.java x: 13 # contributors y: 24 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/FailsafeModJsonToTableRowTransformer.java x: 12 # contributors y: 30 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/model/Mod.java x: 7 # contributors y: 12 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/OptionsUtils.java x: 6 # contributors y: 8 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/SchemaUpdateUtils.java x: 5 # contributors y: 4 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/SpannerToBigQueryUtils.java x: 8 # contributors y: 14 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/utils/SchemaUtils.java x: 10 # contributors y: 17 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/DLPTextToBigQueryStreaming.java x: 17 # contributors y: 26 # changes v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToSQL.java x: 15 # contributors y: 35 # changes v1/src/main/java/com/google/cloud/teleport/bigtable/BigtableToAvro.java x: 8 # contributors y: 19 # changes v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/processing/handler/InputRecordProcessor.java x: 5 # contributors y: 15 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeCountDoFn.java x: 2 # contributors y: 5 # changes v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms/WriteToElasticsearch.java x: 15 # contributors y: 39 # changes v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/templates/MongoDbToBigQuery.java x: 6 # contributors y: 24 # changes v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToGcsFlex.java x: 6 # contributors y: 18 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/AbstractPipelineLauncher.java x: 4 # contributors y: 10 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/DatadogConverters.java x: 12 # contributors y: 22 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/dlq/package-info.java x: 2 # contributors y: 1 # changes metadata/src/main/java/com/google/cloud/teleport/metadata/TemplateParameter.java x: 13 # contributors y: 22 # changes v2/kafka-to-kafka/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToKafka.java x: 9 # contributors y: 16 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/LoadTestBase.java x: 4 # contributors y: 14 # changes v2/bigtable-changestreams-to-hbase/src/main/java/com/google/cloud/teleport/v2/templates/BigtableChangeStreamsToHBase.java x: 11 # contributors y: 22 # changes v2/dataplex/src/main/java/com/google/cloud/teleport/v2/options/DataplexJdbcIngestionOptions.java x: 6 # contributors y: 9 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/FirestoreToBigQuery.java x: 13 # contributors y: 30 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/options/BigQueryCommonOptions.java x: 12 # contributors y: 20 # changes v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/TextIOToBigQuery.java x: 19 # contributors y: 46 # changes v2/pubsub-to-mongodb/src/main/java/com/google/cloud/teleport/v2/templates/PubSubToMongoDB.java x: 20 # contributors y: 41 # changes v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamsToShardedFileSink.java x: 12 # contributors y: 23 # changes v1/src/main/java/com/google/cloud/teleport/templates/ExportJobPlaceholder.java x: 11 # contributors y: 16 # changes v1/src/main/java/com/google/cloud/teleport/templates/PubsubToText.java x: 11 # contributors y: 20 # changes v1/src/main/java/com/google/cloud/teleport/templates/TextIOToBigQuery.java x: 5 # contributors y: 19 # changes v2/sourcedb-to-spanner/terraform/Sourcedb_to_Spanner_Flex/dataflow_job.tf x: 6 # contributors y: 5 # changes plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/model/TemplateDefinitions.java x: 18 # contributors y: 50 # changes v1/src/main/java/com/google/cloud/teleport/templates/common/JavascriptTextTransformer.java x: 17 # contributors y: 31 # changes cicd/internal/op/maven.go x: 10 # contributors y: 15 # changes v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/GCSReader.java x: 9 # contributors y: 20 # changes v2/googlecloud-to-splunk/src/main/java/com/google/cloud/teleport/v2/templates/GCSToSplunk.java x: 13 # contributors y: 25 # changes v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/BinaryAvroDeserializer.java x: 9 # contributors y: 9 # changes v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/templates/StreamingDataGenerator.java x: 18 # contributors y: 37 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/options/BigQueryStorageApiStreamingOptions.java x: 13 # contributors y: 13 # changes v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/options/package-info.java x: 8 # contributors y: 5 # changes v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/exception/RetriableSchemaDiscoveryException.java x: 7 # contributors y: 5 # changes v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates/BigQueryToElasticsearch.java x: 14 # contributors y: 28 # changes v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates/PubSubToElasticsearch.java x: 16 # contributors y: 36 # changes metadata/src/main/java/com/google/cloud/teleport/metadata/util/EnumBasedExperimentValueProvider.java x: 6 # contributors y: 6 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/PythonExternalTextTransformer.java x: 7 # contributors y: 10 # changes v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/utils/ElasticsearchIO.java x: 15 # contributors y: 40 # changes v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/ProcessingContextGenerator.java x: 7 # contributors y: 17 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/dlq/DeadLetterQueueManager.java x: 9 # contributors y: 11 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/dlq/PubSubNotifiedDlqIO.java x: 3 # contributors y: 1 # changes v2/spanner-migrations-sdk/src/main/java/com/google/cloud/teleport/v2/spanner/utils/IShardIdFetcher.java x: 4 # contributors y: 2 # changes v1/src/main/java/com/google/cloud/teleport/templates/TextToDatastore.java x: 4 # contributors y: 15 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/PythonTextTransformer.java x: 3 # contributors y: 16 # changes it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/kms/KMSResourceManager.java x: 3 # contributors y: 8 # changes v1/src/main/java/com/google/cloud/teleport/templates/DatastoreToDatastoreDelete.java x: 3 # contributors y: 12 # changes v1/src/main/java/com/google/cloud/teleport/templates/DatastoreToText.java x: 3 # contributors y: 11 # changes v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/transforms/StreamingDataGeneratorWriteToGcs.java x: 6 # contributors y: 11 # changes v1/src/main/java/com/google/cloud/teleport/splunk/HttpEventPublisher.java x: 2 # contributors y: 6 # changes v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/dlq/FileBasedDeadLetterQueueReconsumer.java x: 5 # contributors y: 17 # changes v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms/ProcessFailsafePubSubFn.java x: 3 # contributors y: 14 # changes v1/src/main/java/com/google/cloud/teleport/templates/JdbcToBigQuery.java x: 3 # contributors y: 10 # changes v1/src/main/java/com/google/cloud/teleport/datadog/DatadogEventWriter.java x: 3 # contributors y: 13 # changes
74.0
# changes
  min: 1.0
  average: 5.82
  25th percentile: 2.0
  median: 3.0
  75th percentile: 6.0
  max: 74.0
0 33.0
# contributors
min: 1.0 | average: 3.75 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 4.0 | max: 33.0

Number of Contributors vs. File Size: 1642 points

v2/bigtable-common/src/main/java/com/google/cloud/teleport/v2/bigtable/options/BigtableCommonOptions.java x: 15 # contributors y: 231 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/BigtableChangeStreamsToBigQuery.java x: 6 # contributors y: 285 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/model/Mod.java x: 5 # contributors y: 204 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstobigquery/schemautils/BigQueryUtils.java x: 4 # contributors y: 240 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/BigtableUtils.java x: 4 # contributors y: 278 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/BigtableChangeStreamsToPubSub.java x: 10 # contributors y: 532 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/model/Mod.java x: 5 # contributors y: 190 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstopubsub/schemautils/PubSubUtils.java x: 3 # contributors y: 363 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/utils/BigtableSource.java x: 3 # contributors y: 90 lines of code v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToSpanner.java x: 33 # contributors y: 785 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/SpannerTemplateITBase.java x: 3 # contributors y: 129 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/BigQueryResourceManager.java x: 5 # contributors y: 320 lines of code v2/bigquery-to-parquet/src/main/java/com/google/cloud/teleport/v2/templates/BigQueryToParquet.java x: 15 # contributors y: 188 lines of code python/src/main/python/yaml-template/main.py x: 11 # contributors y: 11 lines of code v2/cdc-parent/cdc-embedded-connector/src/main/java/com/google/cloud/dataflow/cdc/connector/App.java x: 5 # contributors y: 129 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/SourceDbToSpanner.java x: 11 # contributors y: 83 lines of code v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/SpannerToSourceDb.java x: 5 # contributors y: 679 lines of code v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/CassandraDMLGenerator.java x: 2 # contributors y: 262 lines of code v2/failure-injected-spanner-service/src/main/java/com/google/cloud/teleport/v2/spanner/service/SpannerService.java x: 1 # contributors y: 83 lines of code v2/failure-injected-spanner-service/src/main/java/com/google/cloud/teleport/v2/spanner/service/package-info.java x: 1 # contributors y: 1 lines of code v2/failure-injected-spanner-service/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerServiceFactoryImpl.java x: 1 # contributors y: 10 lines of code v2/real-spanner-service/src/main/java/com/google/cloud/teleport/v2/spanner/service/SpannerService.java x: 1 # contributors y: 14 lines of code v2/spanner-custom-shard/src/main/java/com/custom/CustomTransformationWithCassandraForIT.java x: 2 # contributors y: 35 lines of code v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/CassandraTypeHandler.java x: 2 # contributors y: 372 lines of code plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesStageMojo.java x: 18 # contributors y: 1198 lines of code v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/io/DynamicJdbcIO.java x: 1 # contributors y: 121 lines of code v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/JdbcToBigQueryOptions.java x: 1 # contributors y: 224 lines of code v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/JdbcToPubsubOptions.java x: 1 # contributors y: 91 lines of code v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/PubsubToJdbcOptions.java x: 1 # contributors y: 109 lines of code v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/JdbcToBigQuery.java x: 1 # contributors y: 246 lines of code v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/JdbcToPubSubAuto.java x: 1 # contributors y: 29 lines of code v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/PubsubToJdbc.java x: 1 # contributors y: 103 lines of code v2/jdbc-and-googlecloud/terraform/Jdbc_to_BigQuery_Flex/dataflow_job.tf x: 1 # contributors y: 282 lines of code v2/jdbc-and-googlecloud/terraform/Jdbc_to_PubSub/dataflow_job.tf x: 1 # contributors y: 200 lines of code v2/jdbc-and-googlecloud/terraform/Jdbc_to_PubSub_Auto/dataflow_job.tf x: 1 # contributors y: 218 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerAccessor.java x: 2 # contributors y: 251 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/SpannerChangeStreamsToBigQuery.java x: 14 # contributors y: 421 lines of code plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/TemplateDefinitionsParser.java x: 6 # contributors y: 64 lines of code plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/TemplateSpecsGenerator.java x: 12 # contributors y: 206 lines of code plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesBaseMojo.java x: 2 # contributors y: 58 lines of code plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesReleaseMojo.java x: 6 # contributors y: 164 lines of code plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesSpecMojo.java x: 2 # contributors y: 33 lines of code plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesTerraformMojo.java x: 6 # contributors y: 78 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/options/SourceDbToSpannerOptions.java x: 14 # contributors y: 214 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraIoWrapper.java x: 1 # contributors y: 47 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraTableReaderFactoryCassandraIoImpl.java x: 1 # contributors y: 128 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/MigrateTableTransform.java x: 3 # contributors y: 110 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/writer/SpannerWriter.java x: 4 # contributors y: 48 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TestConstants.java x: 2 # contributors y: 18 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/SpannerResourceManager.java x: 8 # contributors y: 468 lines of code test-infra/cleanup_spanner_databases.py x: 2 # contributors y: 26 lines of code v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/CassandraIO.java x: 1 # contributors y: 699 lines of code v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/ConnectionManager.java x: 1 # contributors y: 59 lines of code v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/DefaultObjectMapper.java x: 1 # contributors y: 27 lines of code v2/sourcedb-to-spanner/src/main/java/org/apache/beam/sdk/io/localcassandra/ReadFn.java x: 1 # contributors y: 116 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/transformer/SourceRowToMutationDoFn.java x: 8 # contributors y: 95 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TemplateTestBase.java x: 20 # contributors y: 562 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Column.java x: 5 # contributors y: 360 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/annotations/cassandra/CassandraAnnotations.java x: 1 # contributors y: 41 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/annotations/cassandra/CassandraType.java x: 1 # contributors y: 49 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/avro/AvroJsonToCassandraMapConvertor.java x: 1 # contributors y: 163 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/avro/GenericRecordTypeConvertor.java x: 8 # contributors y: 538 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/ISchemaMapper.java x: 9 # contributors y: 26 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/IdentityMapper.java x: 9 # contributors y: 105 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/SessionBasedMapper.java x: 10 # contributors y: 262 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/ddl/DatabaseOptionAllowlist.java x: 4 # contributors y: 11 lines of code cicd/internal/flags/common-flags.go x: 10 # contributors y: 58 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/mappings/CassandraMappingsProvider.java x: 1 # contributors y: 168 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/ApplyDDLTransform.java x: 3 # contributors y: 73 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/BuildReadFromTableOperations.java x: 8 # contributors y: 154 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/ExportPipeline.java x: 13 # contributors y: 217 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/ExportTransform.java x: 9 # contributors y: 841 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/ImportPipeline.java x: 9 # contributors y: 187 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/ImportTransform.java x: 10 # contributors y: 787 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/ReadDialect.java x: 2 # contributors y: 43 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/ReadInformationSchema.java x: 2 # contributors y: 71 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/TextImportPipeline.java x: 18 # contributors y: 233 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/TextImportTransform.java x: 9 # contributors y: 502 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationKeyEncoder.java x: 1 # contributors y: 189 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationSizeEstimator.java x: 1 # contributors y: 173 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationUtils.java x: 1 # contributors y: 371 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/NaiveSpannerRead.java x: 1 # contributors y: 135 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/OrderedCode.java x: 1 # contributors y: 450 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerIO.java x: 1 # contributors y: 1602 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerReadSchemaTransformProvider.java x: 1 # contributors y: 213 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerSchema.java x: 1 # contributors y: 185 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerTransformRegistrar.java x: 1 # contributors y: 315 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/StructUtils.java x: 1 # contributors y: 413 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/MetadataSpannerConfigFactory.java x: 1 # contributors y: 73 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action/DetectNewPartitionsAction.java x: 1 # contributors y: 143 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao/PartitionMetadataAdminDao.java x: 1 # contributors y: 198 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao/PartitionMetadataDao.java x: 1 # contributors y: 499 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/mapper/ChangeStreamRecordMapper.java x: 1 # contributors y: 408 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/ChangeStreamRecordMetadata.java x: 1 # contributors y: 272 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/restriction/TimestampRangeTracker.java x: 1 # contributors y: 147 lines of code v1/src/main/java/com/google/cloud/teleport/templates/SpannerToText.java x: 6 # contributors y: 131 lines of code v1/src/main/java/com/google/cloud/teleport/templates/SpannerVectorEmbeddingExport.java x: 14 # contributors y: 227 lines of code v1/src/main/java/com/google/cloud/teleport/templates/TextToSpanner.java x: 8 # contributors y: 364 lines of code v1/src/main/java/com/google/cloud/teleport/templates/common/SpannerConverters.java x: 15 # contributors y: 714 lines of code plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/PromoteHelper.java x: 1 # contributors y: 228 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/storage/GcsResourceManager.java x: 8 # contributors y: 291 lines of code v1/src/main/java/com/google/cloud/teleport/templates/CSVToBigQuery.java x: 8 # contributors y: 263 lines of code v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/SpannerTransactionWriterDoFn.java x: 15 # contributors y: 377 lines of code v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/connection/JdbcConnectionHelper.java x: 2 # contributors y: 79 lines of code v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/options/KafkaReadOptions.java x: 14 # contributors y: 225 lines of code v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/options/KafkaWriteOptions.java x: 6 # contributors y: 178 lines of code v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/utils/KafkaConfig.java x: 5 # contributors y: 170 lines of code v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/values/KafkaAuthenticationMethod.java x: 5 # contributors y: 9 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/AvroSchemaToDdlConverter.java x: 18 # contributors y: 656 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/AvroUtil.java x: 10 # contributors y: 73 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/DdlToAvroSchemaConverter.java x: 22 # contributors y: 478 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/ddl/InformationSchemaScanner.java x: 15 # contributors y: 1746 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Table.java x: 4 # contributors y: 224 lines of code v1/src/main/java/com/google/cloud/teleport/templates/BigQueryToTFRecord.java x: 14 # contributors y: 299 lines of code v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/transforms/FormatDatastreamRecordToJson.java x: 11 # contributors y: 522 lines of code v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/SourceWriterFn.java x: 4 # contributors y: 260 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/avro/AvroToValueMapper.java x: 8 # contributors y: 406 lines of code v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/MySqlChangeEventSequence.java x: 7 # contributors y: 123 lines of code v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/OracleChangeEventSequence.java x: 7 # contributors y: 93 lines of code v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/PostgresChangeEventSequence.java x: 4 # contributors y: 108 lines of code v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/utils/DatastreamToDML.java x: 4 # contributors y: 448 lines of code v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/utils/DatastreamToPostgresDML.java x: 6 # contributors y: 166 lines of code v2/kinesis-to-pubsub/src/main/java/com/google/cloud/teleport/v2/options/KinesisToPubsubOptions.java x: 4 # contributors y: 66 lines of code v2/kinesis-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/KinesisToPubsub.java x: 4 # contributors y: 78 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/matchers/SpannerAsserts.java x: 4 # contributors y: 97 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/AvroRecordConverter.java x: 8 # contributors y: 639 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/CSVRecordToMutation.java x: 9 # contributors y: 228 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/SpannerRecordConverter.java x: 13 # contributors y: 423 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/common/SizedType.java x: 14 # contributors y: 318 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/common/Type.java x: 10 # contributors y: 410 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Column.java x: 17 # contributors y: 289 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/UnifiedTypeMapping.java x: 3 # contributors y: 7 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/UnifiedMappingProvider.java x: 3 # contributors y: 88 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Index.java x: 6 # contributors y: 223 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/database/Neo4jCapabilities.java x: 5 # contributors y: 157 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/database/Neo4jConnection.java x: 12 # contributors y: 176 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/schema/Schema.java x: 10 # contributors y: 207 lines of code v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/constants/Constants.java x: 4 # contributors y: 26 lines of code v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/processor/InputRecordProcessor.java x: 2 # contributors y: 110 lines of code v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/processor/SourceProcessorFactory.java x: 3 # contributors y: 137 lines of code v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/models/DMLGeneratorRequest.java x: 2 # contributors y: 87 lines of code v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/SpannerTransactionWriter.java x: 8 # contributors y: 111 lines of code v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventContext.java x: 8 # contributors y: 57 lines of code v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventContextFactory.java x: 9 # contributors y: 47 lines of code v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventSequenceFactory.java x: 6 # contributors y: 60 lines of code v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/MySqlChangeEventContext.java x: 7 # contributors y: 49 lines of code v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/OracleChangeEventContext.java x: 7 # contributors y: 42 lines of code v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ShadowTableReadUtils.java x: 1 # contributors y: 82 lines of code v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/spanner/ProcessInformationSchema.java x: 8 # contributors y: 201 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/config/SQLDialect.java x: 2 # contributors y: 6 lines of code plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/DockerfileGenerator.java x: 3 # contributors y: 219 lines of code plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesReleaseFinishMojo.java x: 4 # contributors y: 181 lines of code cicd/internal/workflows/maven-workflows.go x: 20 # contributors y: 183 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/templates/GoogleCloudToNeo4j.java x: 6 # contributors y: 479 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/BeamBlock.java x: 5 # contributors y: 55 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/transforms/Neo4jRowWriterTransform.java x: 8 # contributors y: 212 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/ModelUtils.java x: 7 # contributors y: 208 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/monitoring/MonitoringClient.java x: 4 # contributors y: 370 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub/PubsubResourceManager.java x: 6 # contributors y: 341 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/PipelineController.java x: 7 # contributors y: 274 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/JarFileReader.java x: 3 # contributors y: 49 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/mysql/MysqlDialectAdapter.java x: 14 # contributors y: 499 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/JdbcIoWrapper.java x: 10 # contributors y: 349 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/BoundaryExtractorFactory.java x: 4 # contributors y: 121 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/BoundarySplitterFactory.java x: 3 # contributors y: 138 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/unified/CustomSchema.java x: 3 # contributors y: 121 lines of code plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/model/ImageSpecParameter.java x: 12 # contributors y: 615 lines of code v1/src/main/java/com/google/cloud/teleport/bigtable/AvroToBigtable.java x: 13 # contributors y: 170 lines of code v1/src/main/java/com/google/cloud/teleport/bigtable/BigtableToJson.java x: 14 # contributors y: 266 lines of code v1/src/main/java/com/google/cloud/teleport/bigtable/BigtableToParquet.java x: 13 # contributors y: 177 lines of code v1/src/main/java/com/google/cloud/teleport/bigtable/BigtableToVectorEmbeddings.java x: 14 # contributors y: 555 lines of code v1/src/main/java/com/google/cloud/teleport/bigtable/CassandraToBigtable.java x: 13 # contributors y: 202 lines of code v1/src/main/java/com/google/cloud/teleport/bigtable/ParquetToBigtable.java x: 10 # contributors y: 183 lines of code v1/src/main/java/com/google/cloud/teleport/options/WindowedFilenamePolicyOptions.java x: 15 # contributors y: 96 lines of code v1/src/main/java/com/google/cloud/teleport/templates/DLPTextToBigQueryStreaming.java x: 10 # contributors y: 544 lines of code v1/src/main/java/com/google/cloud/teleport/templates/PubsubToAvro.java x: 12 # contributors y: 166 lines of code v1/src/main/java/com/google/cloud/teleport/templates/common/BigQueryConverters.java x: 11 # contributors y: 339 lines of code v1/src/main/java/com/google/cloud/teleport/templates/common/DatastoreConverters.java x: 15 # contributors y: 643 lines of code v1/src/main/java/com/google/cloud/teleport/templates/common/PubsubConverters.java x: 11 # contributors y: 37 lines of code v1/src/main/java/com/google/cloud/teleport/templates/common/SplunkConverters.java x: 11 # contributors y: 263 lines of code v1/src/main/java/com/google/cloud/teleport/templates/common/TextConverters.java x: 15 # contributors y: 85 lines of code v2/cdc-parent/cdc-change-applier/src/main/java/com/google/cloud/dataflow/cdc/applier/CdcToBigQueryChangeApplierPipeline.java x: 14 # contributors y: 150 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/auto/blocks/WriteToPubSub.java x: 4 # contributors y: 35 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/options/CommonTemplateOptions.java x: 15 # contributors y: 30 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/options/WindowedFilenamePolicyOptions.java x: 13 # contributors y: 106 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryConverters.java x: 22 # contributors y: 571 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/CsvConverters.java x: 19 # contributors y: 574 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/JavascriptTextTransformer.java x: 21 # contributors y: 365 lines of code v2/datastream-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToBigQuery.java x: 22 # contributors y: 487 lines of code v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options/ElasticsearchWriteOptions.java x: 19 # contributors y: 256 lines of code v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/GCSToSourceDb.java x: 13 # contributors y: 307 lines of code v2/google-ads-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/GoogleAdsToBigQuery.java x: 11 # contributors y: 169 lines of code v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options/GCSToElasticsearchOptions.java x: 11 # contributors y: 28 lines of code v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options/PubSubToElasticsearchOptions.java x: 12 # contributors y: 55 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/BigtableChangeStreamToBigQueryOptions.java x: 14 # contributors y: 111 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/BigtableChangeStreamsToPubSubOptions.java x: 10 # contributors y: 138 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/SpannerChangeStreamsToBigQueryOptions.java x: 10 # contributors y: 190 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/PubSubToBigQuery.java x: 24 # contributors y: 334 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/TextToBigQueryStreaming.java x: 21 # contributors y: 382 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/pubsubtotext/PubsubToText.java x: 21 # contributors y: 164 lines of code v2/googlecloud-to-mongodb/src/main/java/com/google/cloud/teleport/v2/mongodb/options/BigQueryToMongoDbOptions.java x: 7 # contributors y: 41 lines of code v2/jms-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/JmsToPubsub.java x: 12 # contributors y: 155 lines of code v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/options/SchemaRegistryOptions.java x: 7 # contributors y: 201 lines of code v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/options/KafkaToBigQueryFlexOptions.java x: 13 # contributors y: 192 lines of code v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/mongodb/options/MongoDbToBigQueryOptions.java x: 20 # contributors y: 114 lines of code v2/pubsub-binary-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/PubsubProtoToBigQuery.java x: 21 # contributors y: 376 lines of code v2/pubsub-to-redis/src/main/java/com/google/cloud/teleport/v2/templates/PubSubToRedis.java x: 15 # contributors y: 226 lines of code cicd/internal/flags/it-flags.go x: 10 # contributors y: 113 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Sequence.java x: 3 # contributors y: 97 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/BigQuerySpec.java x: 1 # contributors y: 66 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/sources/BigQuerySource.java x: 2 # contributors y: 68 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/bigquery/BigQueryImpl.java x: 6 # contributors y: 85 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/bigquery/BqQueryToRow.java x: 6 # contributors y: 48 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/options/OptionsToConfigBuilder.java x: 11 # contributors y: 229 lines of code v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/transforms/FormatDatastreamJsonToJson.java x: 3 # contributors y: 174 lines of code v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/SourceWriterTransform.java x: 2 # contributors y: 138 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/SpannerToBigQueryOptions.java x: 9 # contributors y: 72 lines of code v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/utils/BigQueryAvroUtils.java x: 9 # contributors y: 444 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/ErrorConverters.java x: 10 # contributors y: 436 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Ddl.java x: 10 # contributors y: 683 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/provider/MysqlJdbcValueMappings.java x: 10 # contributors y: 168 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/provider/MysqlMappingProvider.java x: 10 # contributors y: 52 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/auth/dbauth/LocalCredentialsProvider.java x: 6 # contributors y: 33 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/ReadWithUniformPartitions.java x: 3 # contributors y: 355 lines of code v2/mqtt-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/MqttToPubsub.java x: 17 # contributors y: 129 lines of code v1/src/main/java/com/google/cloud/teleport/spanner/ddl/ForeignKey.java x: 4 # contributors y: 132 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/JobSpecMapper.java x: 6 # contributors y: 120 lines of code v2/mysql-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/MySQLToBigQuery.java x: 3 # contributors y: 24 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/IoWrapper.java x: 6 # contributors y: 12 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/DialectAdapter.java x: 8 # contributors y: 49 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/dialectadapter/postgresql/PostgreSQLDialectAdapter.java x: 3 # contributors y: 384 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/config/JdbcIOWrapperConfig.java x: 9 # contributors y: 176 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/iowrapper/package-info.java x: 6 # contributors y: 1 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/RetriableSchemaDiscovery.java x: 8 # contributors y: 20 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/SchemaDiscovery.java x: 8 # contributors y: 21 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/SchemaDiscoveryImpl.java x: 8 # contributors y: 72 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/SourceSchemaReference.java x: 8 # contributors y: 32 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/BeamUtils.java x: 8 # contributors y: 137 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/type/Type.java x: 8 # contributors y: 334 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/writer/DeadLetterQueue.java x: 5 # contributors y: 224 lines of code v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/sources/ReadFileRangesFn.java x: 5 # contributors y: 87 lines of code v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventConvertor.java x: 12 # contributors y: 136 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventSessionConvertor.java x: 5 # contributors y: 218 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Ddl.java x: 4 # contributors y: 288 lines of code plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/TemplatePluginUtils.java x: 3 # contributors y: 28 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/Boundary.java x: 3 # contributors y: 148 lines of code v1/src/main/java/com/google/cloud/teleport/templates/PubSubToDatadog.java x: 9 # contributors y: 266 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/shard/Shard.java x: 7 # contributors y: 157 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/utils/ShardFileReader.java x: 7 # contributors y: 198 lines of code metadata/src/main/java/com/google/cloud/teleport/metadata/Template.java x: 14 # contributors y: 55 lines of code cicd/cmd/run-build/main.go x: 5 # contributors y: 24 lines of code v2/sqlserver-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/SQLServerToBigQueryOptions.java x: 3 # contributors y: 20 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/stringmapper/CollationMapper.java x: 2 # contributors y: 201 lines of code v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/constants/DatastreamToSpannerConstants.java x: 4 # contributors y: 20 lines of code v2/spanner-custom-shard/src/main/java/com/custom/CustomTransformationWithShardForBulkIT.java x: 2 # contributors y: 121 lines of code v1/src/main/java/com/google/cloud/teleport/bigtable/BeamRowToBigtableFn.java x: 3 # contributors y: 347 lines of code v1/src/main/java/com/google/cloud/teleport/bigtable/CassandraKeyUtils.java x: 3 # contributors y: 45 lines of code v1/src/main/java/com/google/cloud/teleport/bigtable/CassandraRowMapperFn.java x: 3 # contributors y: 183 lines of code v1/terraform/Cassandra_To_Cloud_Bigtable/dataflow_job.tf x: 5 # contributors y: 180 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/provider/PostgreSQLJdbcValueMappings.java x: 2 # contributors y: 136 lines of code v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/AssignShardIdFn.java x: 1 # contributors y: 432 lines of code v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/KafkaTransform.java x: 13 # contributors y: 114 lines of code v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQuery.java x: 20 # contributors y: 471 lines of code v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryFlex.java x: 16 # contributors y: 470 lines of code v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/sources/DataStreamIO.java x: 4 # contributors y: 332 lines of code v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/DatastreamConstants.java x: 5 # contributors y: 116 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/BigQueryDynamicDestinations.java x: 9 # contributors y: 203 lines of code v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/transforms/StringMessageToTableRow.java x: 10 # contributors y: 104 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/function/CypherActionFn.java x: 5 # contributors y: 79 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/actions/preload/PreloadBigQueryAction.java x: 5 # contributors y: 37 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/database/CypherGenerator.java x: 8 # contributors y: 376 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/InputValidator.java x: 6 # contributors y: 40 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/MappingListener.java x: 1 # contributors y: 374 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/MappingMapper.java x: 5 # contributors y: 443 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/OptionsParamsMapper.java x: 5 # contributors y: 17 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/TargetMapper.java x: 7 # contributors y: 259 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/model/helpers/TargetQuerySpec.java x: 4 # contributors y: 130 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/ListOfStringToRowFn.java x: 5 # contributors y: 32 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/TextSourceFileToRow.java x: 5 # contributors y: 62 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/providers/text/TextTargetToRow.java x: 5 # contributors y: 69 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/transforms/Neo4jBlockingUnwindFn.java x: 8 # contributors y: 124 lines of code v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/DataCastingUtils.java x: 7 # contributors y: 496 lines of code v2/google-ads-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/utils/GoogleAdsRateLimitPolicyFactory.java x: 3 # contributors y: 39 lines of code v2/google-ads-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/utils/GoogleAdsUtils.java x: 3 # contributors y: 65 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/JdbcSourceRowMapper.java x: 12 # contributors y: 80 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamsToPubSub.java x: 8 # contributors y: 149 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/FileFormatFactorySpannerChangeStreamsToPubSub.java x: 4 # contributors y: 165 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToAvro.java x: 3 # contributors y: 188 lines of code v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/AvroDynamicTransform.java x: 4 # contributors y: 91 lines of code v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/transforms/WriteTransform.java x: 11 # contributors y: 72 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/FailsafeModJsonToTableRowTransformer.java x: 12 # contributors y: 354 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/model/Mod.java x: 7 # contributors y: 185 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/model/TrackedSpannerTable.java x: 7 # contributors y: 113 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/SchemaUpdateUtils.java x: 5 # contributors y: 96 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/SpannerChangeStreamsUtils.java x: 8 # contributors y: 430 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/SpannerToBigQueryUtils.java x: 8 # contributors y: 275 lines of code v1/src/main/proto/export.proto x: 4 # contributors y: 60 lines of code v1/src/main/java/com/google/cloud/teleport/templates/TextToBigQueryStreaming.java x: 11 # contributors y: 272 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/DLPTextToBigQueryStreaming.java x: 17 # contributors y: 592 lines of code v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToSQL.java x: 15 # contributors y: 277 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/InitialSplitRangeDoFn.java x: 3 # contributors y: 59 lines of code v2/spanner-to-sourcedb/terraform/Spanner_Change_Streams_to_Sharded_File_Sink/dataflow_job.tf x: 1 # contributors y: 250 lines of code python/src/main/java/com/google/cloud/teleport/templates/python/YAMLTemplate.java x: 10 # contributors y: 48 lines of code v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/processing/dml/DMLGenerator.java x: 9 # contributors y: 373 lines of code v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/processing/handler/InputRecordProcessor.java x: 5 # contributors y: 135 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/utils/SpannerUtils.java x: 4 # contributors y: 163 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/conditions/BigQueryRowsCheck.java x: 3 # contributors y: 77 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventTypeConvertor.java x: 4 # contributors y: 210 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/Range.java x: 2 # contributors y: 223 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/range/BoundaryExtractor.java x: 2 # contributors y: 12 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/uniformsplitter/transforms/RangeBoundaryDoFn.java x: 2 # contributors y: 92 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/InformationSchemaScanner.java x: 2 # contributors y: 501 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Table.java x: 2 # contributors y: 228 lines of code v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToGcsFlex.java x: 6 # contributors y: 151 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/AbstractPipelineLauncher.java x: 4 # contributors y: 289 lines of code v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/processing/handler/GCSToSourceStreamingHandler.java x: 7 # contributors y: 151 lines of code v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/transforms/GcsToSourceStreamer.java x: 9 # contributors y: 179 lines of code v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/convertors/ChangeEventToMapConvertor.java x: 2 # contributors y: 99 lines of code v1/src/main/java/com/google/cloud/teleport/templates/common/DatadogConverters.java x: 12 # contributors y: 232 lines of code v1/terraform/Cloud_PubSub_to_Datadog/dataflow_job.tf x: 6 # contributors y: 187 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastream/DatastreamResourceManager.java x: 5 # contributors y: 421 lines of code metadata/src/main/java/com/google/cloud/teleport/metadata/TemplateParameter.java x: 13 # contributors y: 406 lines of code v2/kafka-to-kafka/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToKafka.java x: 9 # contributors y: 148 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/cloudsql/CloudSqlContainer.java x: 2 # contributors y: 51 lines of code v2/pubsub-cdc-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/PubSubCdcToBigQuery.java x: 15 # contributors y: 389 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/row/SourceRow.java x: 6 # contributors y: 75 lines of code v2/astradb-to-bigquery/src/main/java/com/google/cloud/teleport/v2/astradb/options/AstraDbToBigQueryOptions.java x: 9 # contributors y: 91 lines of code v2/bigtable-changestreams-to-hbase/src/main/java/com/google/cloud/teleport/v2/templates/BigtableChangeStreamsToHBase.java x: 11 # contributors y: 159 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/WriteToGCSParquet.java x: 5 # contributors y: 102 lines of code v2/dataplex/src/main/java/com/google/cloud/teleport/v2/options/DataplexJdbcIngestionOptions.java x: 6 # contributors y: 214 lines of code v2/dataplex/src/main/java/com/google/cloud/teleport/v2/templates/DataplexFileFormatConversion.java x: 4 # contributors y: 659 lines of code v2/datastream-to-mongodb/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToMongoDB.java x: 8 # contributors y: 195 lines of code v2/datastream-to-postgres/src/main/java/com/google/cloud/teleport/v2/templates/DataStreamToPostgres.java x: 8 # contributors y: 164 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/options/BigtableChangeStreamsToGcsOptions.java x: 10 # contributors y: 130 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/utils/FirestoreConverters.java x: 5 # contributors y: 692 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/auto/blocks/ReadFromPubSub.java x: 4 # contributors y: 33 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/options/BigQueryCommonOptions.java x: 12 # contributors y: 64 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/options/PubsubCommonOptions.java x: 10 # contributors y: 41 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/PubsubToAvro.java x: 9 # contributors y: 160 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/TextIOToBigQuery.java x: 19 # contributors y: 361 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/WriteDataChangeRecordsToGcsAvro.java x: 5 # contributors y: 120 lines of code v2/pubsub-to-jms/src/main/java/com/google/cloud/teleport/v2/templates/PubsubToJms.java x: 8 # contributors y: 143 lines of code v2/pubsub-to-mongodb/src/main/java/com/google/cloud/teleport/v2/templates/PubSubToMongoDB.java x: 20 # contributors y: 422 lines of code v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/SpannerChangeStreamsToShardedFileSink.java x: 12 # contributors y: 421 lines of code v1/src/main/java/com/google/cloud/teleport/templates/BulkDecompressor.java x: 5 # contributors y: 213 lines of code v1/src/main/java/com/google/cloud/teleport/templates/ExportJobPlaceholder.java x: 11 # contributors y: 112 lines of code v1/src/main/java/com/google/cloud/teleport/templates/ImportJobPlaceholder.java x: 8 # contributors y: 82 lines of code v1/src/main/java/com/google/cloud/teleport/templates/PubsubToPubsub.java x: 9 # contributors y: 196 lines of code v1/src/main/java/com/google/cloud/teleport/templates/PubsubToText.java x: 11 # contributors y: 177 lines of code v1/src/main/java/com/google/cloud/teleport/templates/TextToPubsub.java x: 9 # contributors y: 66 lines of code v2/sourcedb-to-spanner/terraform/Sourcedb_to_Spanner_Flex/dataflow_job.tf x: 6 # contributors y: 236 lines of code v2/file-format-conversion/src/main/java/com/google/cloud/teleport/v2/templates/FileFormatConversion.java x: 7 # contributors y: 103 lines of code v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/transforms/AssignShardIdFn.java x: 10 # contributors y: 419 lines of code plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/model/TemplateDefinitions.java x: 18 # contributors y: 421 lines of code v1/src/main/java/com/google/cloud/teleport/templates/common/JavascriptTextTransformer.java x: 17 # contributors y: 371 lines of code v2/bigquery-to-bigtable/src/main/java/com/google/cloud/teleport/v2/templates/BigQueryToBigtable.java x: 11 # contributors y: 79 lines of code cicd/internal/op/maven.go x: 10 # contributors y: 22 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/storage/conditions/package-info.java x: 4 # contributors y: 1 lines of code v1/src/main/java/com/google/cloud/teleport/templates/PubSubToBigQuery.java x: 13 # contributors y: 279 lines of code v2/googlecloud-to-splunk/src/main/java/com/google/cloud/teleport/v2/transforms/SplunkConverters.java x: 7 # contributors y: 249 lines of code v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/BinaryAvroDeserializer.java x: 9 # contributors y: 33 lines of code v2/kafka-common/src/main/java/com/google/cloud/teleport/v2/kafka/transforms/BinaryAvroSerializer.java x: 9 # contributors y: 37 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/auth/dbauth/package-info.java x: 5 # contributors y: 1 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/JdbcValueMappingsProvider.java x: 9 # contributors y: 6 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/jdbc/rowmapper/ResultSetValueExtractor.java x: 9 # contributors y: 9 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/transform/AccumulatingTableReader.java x: 7 # contributors y: 81 lines of code v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/utils/SpannerDao.java x: 7 # contributors y: 420 lines of code v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/templates/StreamingDataGenerator.java x: 18 # contributors y: 617 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/options/BigQueryStorageApiStreamingOptions.java x: 13 # contributors y: 56 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/coders/GenericRecordCoder.java x: 8 # contributors y: 41 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/options/BigQueryStorageApiBatchOptions.java x: 11 # contributors y: 26 lines of code v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/options/package-info.java x: 8 # contributors y: 1 lines of code v2/kafka-to-gcs/src/main/java/com/google/cloud/teleport/v2/transforms/JsonWriteTransform.java x: 8 # contributors y: 65 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/exception/RetriableSchemaDiscoveryException.java x: 7 # contributors y: 6 lines of code v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/options/BigQueryToElasticsearchOptions.java x: 7 # contributors y: 7 lines of code v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates/BigQueryToElasticsearch.java x: 14 # contributors y: 124 lines of code v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates/GCSToElasticsearch.java x: 14 # contributors y: 183 lines of code v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/templates/PubSubToElasticsearch.java x: 16 # contributors y: 177 lines of code v2/googlecloud-to-elasticsearch/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms/PubSubMessageToJsonDocument.java x: 8 # contributors y: 108 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/schema/typemapping/package-info.java x: 3 # contributors y: 1 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/PythonExternalTextTransformer.java x: 7 # contributors y: 286 lines of code v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/utils/ElasticsearchIO.java x: 15 # contributors y: 1067 lines of code v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/row/SerializableGenericRecord.java x: 5 # contributors y: 53 lines of code yaml/src/main/java/com/google/cloud/teleport/templates/yaml/KafkaToBigQueryYaml.java x: 6 # contributors y: 111 lines of code yaml/src/main/python/main.py x: 6 # contributors y: 18 lines of code v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dao/SpannerDao.java x: 6 # contributors y: 335 lines of code v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/utils/DataSeenTracker.java x: 5 # contributors y: 48 lines of code v1/src/main/java/com/google/cloud/teleport/splunk/SplunkEventWriter.java x: 3 # contributors y: 377 lines of code cicd/internal/terraform/templates.go x: 7 # contributors y: 137 lines of code v1/terraform/Bulk_Compress_GCS_Files/dataflow_job.tf x: 4 # contributors y: 138 lines of code v1/terraform/Cloud_BigQuery_to_Cloud_Datastore/dataflow_job.tf x: 4 # contributors y: 157 lines of code v1/terraform/Cloud_Bigtable_to_GCS_Parquet/dataflow_job.tf x: 4 # contributors y: 146 lines of code v1/terraform/Cloud_Bigtable_to_Vector_Embeddings/dataflow_job.tf x: 4 # contributors y: 193 lines of code v1/terraform/Cloud_PubSub_to_Avro/dataflow_job.tf x: 4 # contributors y: 175 lines of code v1/terraform/GCS_Text_to_Cloud_Spanner/dataflow_job.tf x: 4 # contributors y: 205 lines of code v1/terraform/Jdbc_to_BigQuery/dataflow_job.tf x: 4 # contributors y: 186 lines of code v2/dataplex/terraform/Dataplex_JDBC_Ingestion/dataflow_job.tf x: 4 # contributors y: 251 lines of code v2/datastream-to-bigquery/terraform/Cloud_Datastream_to_BigQuery/dataflow_job.tf x: 4 # contributors y: 320 lines of code v2/datastream-to-sql/terraform/Cloud_Datastream_to_SQL/dataflow_job.tf x: 4 # contributors y: 219 lines of code v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/utils/ProcessingContextGenerator.java x: 7 # contributors y: 224 lines of code v2/googlecloud-to-elasticsearch/terraform/BigQuery_to_Elasticsearch/dataflow_job.tf x: 4 # contributors y: 338 lines of code v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/bigtablechangestreamstogcs/BigtableChangeStreamsToGcs.java x: 6 # contributors y: 247 lines of code v2/googlecloud-to-googlecloud/terraform/Bigtable_Change_Streams_to_BigQuery/dataflow_job.tf x: 4 # contributors y: 267 lines of code v2/googlecloud-to-googlecloud/terraform/Spanner_Change_Streams_to_BigQuery/dataflow_job.tf x: 4 # contributors y: 274 lines of code v2/googlecloud-to-googlecloud/terraform/Spanner_Change_Streams_to_PubSub/dataflow_job.tf x: 4 # contributors y: 229 lines of code v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/transforms/ChangeDataProgressTrackerFn.java x: 4 # contributors y: 71 lines of code v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/utils/ShardIdFetcherImpl.java x: 7 # contributors y: 71 lines of code v2/streaming-data-generator/terraform/Streaming_Data_Generator/dataflow_job.tf x: 4 # contributors y: 324 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/cdc/dlq/DeadLetterQueueManager.java x: 9 # contributors y: 111 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryDynamicConverters.java x: 6 # contributors y: 103 lines of code v2/datastream-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/BigQueryDynamicConverters.java x: 7 # contributors y: 104 lines of code it/splunk/src/main/java/org/apache/beam/it/splunk/CustomSplunkResourceManager.java x: 3 # contributors y: 247 lines of code v2/dataplex/src/main/java/com/google/cloud/teleport/v2/templates/DataplexJdbcIngestion.java x: 4 # contributors y: 395 lines of code cicd/internal/terraform/matcher.go x: 4 # contributors y: 53 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/DirectRunnerClient.java x: 5 # contributors y: 197 lines of code v1/src/main/java/com/google/cloud/teleport/templates/PubSubToSplunk.java x: 6 # contributors y: 271 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/ParquetConverters.java x: 5 # contributors y: 177 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/transforms/PythonTextTransformer.java x: 3 # contributors y: 394 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/DefaultPipelineLauncher.java x: 4 # contributors y: 410 lines of code cicd/internal/repo/modules.go x: 6 # contributors y: 127 lines of code v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/cdc/merge/BigQueryMerger.java x: 2 # contributors y: 197 lines of code v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/cdc/merge/MergeInfo.java x: 2 # contributors y: 153 lines of code v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/cdc/merge/MergeStatementBuilder.java x: 2 # contributors y: 189 lines of code v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/io/CdcJdbcIO.java x: 2 # contributors y: 403 lines of code v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/utils/DataStreamClient.java x: 2 # contributors y: 461 lines of code v2/datastream-to-postgres/src/main/java/com/google/cloud/teleport/v2/utils/DatabaseMigrationUtils.java x: 3 # contributors y: 456 lines of code v2/dataplex/src/main/java/com/google/cloud/teleport/v2/transforms/BigQueryTableToGcsTransform.java x: 2 # contributors y: 217 lines of code v2/streaming-data-generator/src/main/java/com/google/cloud/teleport/v2/transforms/StreamingDataGeneratorWriteToGcs.java x: 6 # contributors y: 155 lines of code v2/mongodb-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/transforms/JavascriptDocumentTransformer.java x: 2 # contributors y: 175 lines of code v1/src/main/java/com/google/cloud/teleport/splunk/HttpEventPublisher.java x: 2 # contributors y: 237 lines of code v2/dataplex/src/main/java/com/google/cloud/teleport/v2/clients/DefaultDataplexClient.java x: 2 # contributors y: 243 lines of code v2/dataplex/src/main/java/com/google/cloud/teleport/v2/templates/DataplexBigQueryToGcs.java x: 2 # contributors y: 299 lines of code v2/dataplex/src/main/java/com/google/cloud/teleport/v2/transforms/GenericRecordsToGcsPartitioned.java x: 2 # contributors y: 147 lines of code v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/DataplexBigQueryToGcsFilter.java x: 2 # contributors y: 163 lines of code v2/dataplex/src/main/java/com/google/cloud/teleport/v2/utils/DataplexUtils.java x: 2 # contributors y: 316 lines of code v2/spanner-change-streams-to-sharded-file-sink/src/main/java/com/google/cloud/teleport/v2/templates/transforms/WriterGCS.java x: 2 # contributors y: 106 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManager.java x: 6 # contributors y: 405 lines of code v1/src/main/java/com/google/cloud/teleport/templates/common/SubprocessTextTransformer.java x: 2 # contributors y: 290 lines of code it/datadog/src/main/java/com/google/cloud/teleport/it/datadog/DatadogResourceManager.java x: 2 # contributors y: 184 lines of code metadata/src/main/java/com/google/cloud/teleport/metadata/auto/AutoTemplate.java x: 3 # contributors y: 235 lines of code v1/src/main/java/com/google/cloud/teleport/datadog/DatadogEventWriter.java x: 3 # contributors y: 367 lines of code v1/src/main/java/com/google/cloud/teleport/datadog/DatadogIO.java x: 3 # contributors y: 153 lines of code v1/src/main/java/com/google/cloud/teleport/io/WindowedFilenamePolicy.java x: 4 # contributors y: 302 lines of code v2/common/src/main/java/com/google/cloud/teleport/v2/io/WindowedFilenamePolicy.java x: 5 # contributors y: 236 lines of code v2/kafka-to-pubsub/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToPubsub.java x: 5 # contributors y: 107 lines of code v2/astradb-to-bigquery/src/main/java/com/google/cloud/teleport/v2/astradb/templates/AstraDbToBigQuery.java x: 3 # contributors y: 161 lines of code
1746.0
lines of code
  min: 1.0
  average: 98.76
  25th percentile: 9.0
  median: 49.0
  75th percentile: 144.0
  max: 1746.0
0 33.0
# contributors
min: 1.0 | average: 3.75 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 4.0 | max: 33.0