GoogleCloudPlatform / pubsub
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 76 files with 4,944 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 2 files changed 21-50 times (727 lines of code)
    • 10 files changed 6-20 times (1,681 lines of code)
    • 64 files changed 1-5 times (2,536 lines of code)
0% | 0% | 14% | 34% | 51%
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 76 files with 4,944 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 4 files changed by 11-25 contributors (980 lines of code)
    • 1 file changed by 6-10 contributors (281 lines of code)
    • 62 files changed by 2-5 contributors (3,000 lines of code)
    • 9 files changed by 1 contributor (683 lines of code)
0% | 19% | 5% | 60% | 13%
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, py, js, go, md, xml, sh, properties, proto, json, txt, yaml, mod, gitignore
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 15% | 34% | 50%
py0% | 0% | 0% | 0% | 100%
proto0% | 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
kafka-connector0% | 0% | 31% | 28% | 39%
ordering-keys-prober0% | 0% | 0% | 59% | 40%
flink-connector0% | 0% | 0% | 35% | 64%
sql-streaming-copier0% | 0% | 0% | 6% | 93%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
CloudPubSubSourceTask.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 325 11 2016-09-12 2021-07-21 38 18 kamal.aboulhosn@gmail.com dpcollins@google.com
CloudPubSubSinkTask.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/sink
 402 13 2016-09-12 2021-07-21 25 13 kamal.aboulhosn@gmail.com dpcollins@google.com
CloudPubSubSourceConnector.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 281 9 2016-09-12 2021-07-21 19 10 kamal.aboulhosn@gmail.com dpcollins@google.com
ConnectorUtils.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/common
 35 2 2016-09-12 2021-07-21 17 12 kamal.aboulhosn@gmail.com dpcollins@google.com
CloudPubSubSinkConnector.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/sink
 218 8 2016-09-12 2021-07-21 16 11 kamal.aboulhosn@gmail.com samarth.singal@gmail.com
PubSubSource.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink
 183 11 2023-09-07 2024-05-29 12 4 mattkwong@google.com matt-kwong@users.noreply.gi...
CloudPubSubGRPCSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 82 3 2016-09-12 2021-07-21 9 5 kamal.aboulhosn@gmail.com dpcollins@google.com
CloudPubSubRoundRobinSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 39 3 2016-09-12 2021-03-22 7 5 kamal.aboulhosn@gmail.com 40498610+dpcollins-google@u...
PubSubSink.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink
 84 3 2023-09-07 2024-04-19 7 4 mattkwong@google.com matt-kwong@users.noreply.gi...
Prober.java
in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober
 616 38 2020-10-07 2023-02-01 7 3 kamal.aboulhosn@gmail.com kamal.aboulhosn@gmail.com
TableSpec.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 38 3 2021-02-24 2021-06-23 6 3 dpcollins@google.com samarth.singal@gmail.com
PubSubNotifyingPullSubscriber.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 105 8 2023-09-07 2024-05-29 6 4 mattkwong@google.com matt-kwong@users.noreply.gi...
AckTracker.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 9 - 2023-09-07 2024-05-29 5 3 mattkwong@google.com matt-kwong@users.noreply.gi...
TemplateMain.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 13 1 2021-03-17 2021-06-23 5 3 dpcollins@google.com samarth.singal@gmail.com
RunPipeline.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 39 4 2021-03-17 2021-06-23 5 3 dpcollins@google.com samarth.singal@gmail.com
PubSubAckTracker.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 54 5 2023-09-07 2024-05-29 5 3 mattkwong@google.com matt-kwong@users.noreply.gi...
PubSubExample.java
in flink-connector/flink-examples-gcp-pubsub/pubsub-streaming/src/main/java/com/google/pubsub/flink
 69 1 2023-10-09 2024-04-19 5 3 mattkwong@google.com matt-kwong@users.noreply.gi...
ProberStarter.java
in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober
 156 1 2020-10-07 2022-04-18 5 4 kamal.aboulhosn@gmail.com 74616323+amfisher-404@users...
CloudPubSubSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 11 - 2016-09-12 2021-03-22 4 3 kamal.aboulhosn@gmail.com 40498610+dpcollins-google@u...
PubSubLiteSinkConnector.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 33 5 2020-11-15 2020-11-24 4 2 dpcollins@google.com 40498610+dpcollins-google@u...
PubSubSplitEnumerator.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator
 69 8 2023-09-07 2024-04-09 4 3 mattkwong@google.com matt-kwong@users.noreply.gi...
copy_tool.py
in kafka-connector
 76 6 2020-12-01 2022-06-14 4 1 40498610+dpcollins-google@u... 40498610+dpcollins-google@u...
AckBatchingSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 80 4 2021-03-16 2021-07-21 4 2 dpcollins@google.com dpcollins@google.com
CloudPubsubProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 94 5 2021-02-24 2021-03-24 4 2 dpcollins@google.com 40498610+dpcollins-google@u...
PubSubSplitReader.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 103 7 2023-09-07 2024-02-22 4 2 mattkwong@google.com 52459909+hannahrogers-googl...
SqlStreamingOptions.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 4 - 2021-04-13 2021-06-23 3 3 dpcollins@google.com samarth.singal@gmail.com
StandardSourceProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 5 - 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
StandardSinkProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 5 - 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
UITemplateOptions.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 13 - 2021-04-13 2021-06-23 3 3 dpcollins@google.com samarth.singal@gmail.com
BigQueryProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 14 2 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
UITemplateMain.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 14 1 2021-04-13 2021-06-23 3 3 dpcollins@google.com samarth.singal@gmail.com
TableLoader.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 17 3 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
StandardSqlSink.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 20 1 2021-02-24 2021-03-24 3 2 dpcollins@google.com 40498610+dpcollins-google@u...
StandardSqlSource.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 20 1 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
EmulatorEndpoint.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/util
 20 2 2024-03-14 2024-04-19 3 2 mattkwong@google.com matt-kwong@users.noreply.gi...
Rows.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 27 1 2021-02-24 2021-03-24 3 2 dpcollins@google.com 40498610+dpcollins-google@u...
TemplateOptions.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 31 - 2021-04-13 2021-06-23 3 3 dpcollins@google.com samarth.singal@gmail.com
PubSubRecordEmitter.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 31 2 2023-09-07 2024-05-29 3 3 mattkwong@google.com matt-kwong@users.noreply.gi...
PubsubLiteProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 36 3 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
PubSubSourceReader.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 56 6 2023-09-07 2024-05-29 3 3 mattkwong@google.com matt-kwong@users.noreply.gi...
Compiler.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 66 3 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
KafkaProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 68 4 2021-02-24 2021-03-24 3 2 dpcollins@google.com 40498610+dpcollins-google@u...
StreamingPullSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 139 10 2021-03-09 2021-03-22 3 2 dpcollins@google.com 40498610+dpcollins-google@u...
package-info.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 2 - 2021-02-24 2021-03-24 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
package-info.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 2 - 2021-03-17 2021-03-24 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
PollerFactory.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 5 - 2020-11-19 2020-11-24 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
StreamingPullSubscriberFactory.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 6 - 2021-03-09 2021-03-22 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
FlushablePublisher.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink
 6 - 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
Poller.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 9 - 2020-11-19 2020-11-24 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
StandardSink.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 9 - 2021-03-17 2021-03-24 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
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
CloudPubSubSourceTask.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 325 11 2016-09-12 2021-07-21 38 18 kamal.aboulhosn@gmail.com dpcollins@google.com
CloudPubSubSinkTask.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/sink
 402 13 2016-09-12 2021-07-21 25 13 kamal.aboulhosn@gmail.com dpcollins@google.com
ConnectorUtils.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/common
 35 2 2016-09-12 2021-07-21 17 12 kamal.aboulhosn@gmail.com dpcollins@google.com
CloudPubSubSinkConnector.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/sink
 218 8 2016-09-12 2021-07-21 16 11 kamal.aboulhosn@gmail.com samarth.singal@gmail.com
CloudPubSubSourceConnector.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 281 9 2016-09-12 2021-07-21 19 10 kamal.aboulhosn@gmail.com dpcollins@google.com
CloudPubSubGRPCSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 82 3 2016-09-12 2021-07-21 9 5 kamal.aboulhosn@gmail.com dpcollins@google.com
CloudPubSubRoundRobinSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 39 3 2016-09-12 2021-03-22 7 5 kamal.aboulhosn@gmail.com 40498610+dpcollins-google@u...
PubSubSource.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink
 183 11 2023-09-07 2024-05-29 12 4 mattkwong@google.com matt-kwong@users.noreply.gi...
PubSubSink.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink
 84 3 2023-09-07 2024-04-19 7 4 mattkwong@google.com matt-kwong@users.noreply.gi...
PubSubNotifyingPullSubscriber.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 105 8 2023-09-07 2024-05-29 6 4 mattkwong@google.com matt-kwong@users.noreply.gi...
ProberStarter.java
in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober
 156 1 2020-10-07 2022-04-18 5 4 kamal.aboulhosn@gmail.com 74616323+amfisher-404@users...
Prober.java
in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober
 616 38 2020-10-07 2023-02-01 7 3 kamal.aboulhosn@gmail.com kamal.aboulhosn@gmail.com
TableSpec.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 38 3 2021-02-24 2021-06-23 6 3 dpcollins@google.com samarth.singal@gmail.com
PubSubExample.java
in flink-connector/flink-examples-gcp-pubsub/pubsub-streaming/src/main/java/com/google/pubsub/flink
 69 1 2023-10-09 2024-04-19 5 3 mattkwong@google.com matt-kwong@users.noreply.gi...
PubSubAckTracker.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 54 5 2023-09-07 2024-05-29 5 3 mattkwong@google.com matt-kwong@users.noreply.gi...
AckTracker.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 9 - 2023-09-07 2024-05-29 5 3 mattkwong@google.com matt-kwong@users.noreply.gi...
RunPipeline.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 39 4 2021-03-17 2021-06-23 5 3 dpcollins@google.com samarth.singal@gmail.com
TemplateMain.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 13 1 2021-03-17 2021-06-23 5 3 dpcollins@google.com samarth.singal@gmail.com
PubSubSplitEnumerator.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator
 69 8 2023-09-07 2024-04-09 4 3 mattkwong@google.com matt-kwong@users.noreply.gi...
CloudPubSubSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 11 - 2016-09-12 2021-03-22 4 3 kamal.aboulhosn@gmail.com 40498610+dpcollins-google@u...
PubSubSourceReader.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 56 6 2023-09-07 2024-05-29 3 3 mattkwong@google.com matt-kwong@users.noreply.gi...
PubSubRecordEmitter.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 31 2 2023-09-07 2024-05-29 3 3 mattkwong@google.com matt-kwong@users.noreply.gi...
SqlStreamingOptions.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 4 - 2021-04-13 2021-06-23 3 3 dpcollins@google.com samarth.singal@gmail.com
UITemplateMain.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 14 1 2021-04-13 2021-06-23 3 3 dpcollins@google.com samarth.singal@gmail.com
TemplateOptions.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 31 - 2021-04-13 2021-06-23 3 3 dpcollins@google.com samarth.singal@gmail.com
UITemplateOptions.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 13 - 2021-04-13 2021-06-23 3 3 dpcollins@google.com samarth.singal@gmail.com
PubSubSplitReader.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 103 7 2023-09-07 2024-02-22 4 2 mattkwong@google.com 52459909+hannahrogers-googl...
CloudPubsubProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 94 5 2021-02-24 2021-03-24 4 2 dpcollins@google.com 40498610+dpcollins-google@u...
AckBatchingSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 80 4 2021-03-16 2021-07-21 4 2 dpcollins@google.com dpcollins@google.com
PubSubLiteSinkConnector.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 33 5 2020-11-15 2020-11-24 4 2 dpcollins@google.com 40498610+dpcollins-google@u...
EmulatorEndpoint.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/util
 20 2 2024-03-14 2024-04-19 3 2 mattkwong@google.com matt-kwong@users.noreply.gi...
Compiler.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 66 3 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
TableLoader.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 17 3 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
Rows.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 27 1 2021-02-24 2021-03-24 3 2 dpcollins@google.com 40498610+dpcollins-google@u...
StandardSqlSource.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 20 1 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
StandardSinkProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 5 - 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
PubsubLiteProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 36 3 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
KafkaProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 68 4 2021-02-24 2021-03-24 3 2 dpcollins@google.com 40498610+dpcollins-google@u...
StandardSourceProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 5 - 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
BigQueryProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 14 2 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
StandardSqlSink.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 20 1 2021-02-24 2021-03-24 3 2 dpcollins@google.com 40498610+dpcollins-google@u...
StreamingPullSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 139 10 2021-03-09 2021-03-22 3 2 dpcollins@google.com 40498610+dpcollins-google@u...
PubSubDeserializationSchema.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink
 28 1 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
PubSubSerializationSchema.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink
 23 1 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
PubSubFlushablePublisher.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink
 28 3 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
PubSubPublisherCache.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink
 29 3 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
PubSubSinkWriter.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink
 24 4 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
FlushablePublisher.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink
 6 - 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
PubSubCheckpointSerializer.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator
 19 2 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
SubscriptionSplit.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split
 31 5 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
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
OrderedProber.java
in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober
 272 9 2020-10-07 2020-10-07 1 1 kamal.aboulhosn@gmail.com kamal.aboulhosn@gmail.com
Schemas.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 123 6 2020-11-24 2020-11-24 1 1 40498610+dpcollins-google@u... 40498610+dpcollins-google@u...
PubSubLiteSinkTask.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 117 7 2020-11-24 2020-11-24 1 1 40498610+dpcollins-google@u... 40498610+dpcollins-google@u...
copy_tool.py
in kafka-connector
 76 6 2020-12-01 2022-06-14 4 1 40498610+dpcollins-google@u... 40498610+dpcollins-google@u...
PublisherFactoryImpl.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 31 1 2020-11-24 2020-11-24 1 1 40498610+dpcollins-google@u... 40498610+dpcollins-google@u...
ConnectorCredentialsProvider.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/common
 29 3 2018-11-30 2018-11-30 1 1 htn@aiven.io htn@aiven.io
ConfigDefs.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 19 2 2020-11-24 2020-11-24 1 1 40498610+dpcollins-google@u... 40498610+dpcollins-google@u...
Constants.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 9 1 2020-11-24 2020-11-24 1 1 40498610+dpcollins-google@u... 40498610+dpcollins-google@u...
PublisherFactory.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 7 - 2020-11-24 2020-11-24 1 1 40498610+dpcollins-google@u... 40498610+dpcollins-google@u...
StreamingPullSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 139 10 2021-03-09 2021-03-22 3 2 dpcollins@google.com 40498610+dpcollins-google@u...
PubSubSplitReader.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 103 7 2023-09-07 2024-02-22 4 2 mattkwong@google.com 52459909+hannahrogers-googl...
CloudPubsubProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 94 5 2021-02-24 2021-03-24 4 2 dpcollins@google.com 40498610+dpcollins-google@u...
AckBatchingSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 80 4 2021-03-16 2021-07-21 4 2 dpcollins@google.com dpcollins@google.com
KafkaProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 68 4 2021-02-24 2021-03-24 3 2 dpcollins@google.com 40498610+dpcollins-google@u...
Compiler.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 66 3 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
PollerImpl.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 61 2 2020-11-19 2020-11-24 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
PubSubLiteSourceTask.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 47 5 2020-11-19 2020-11-24 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
ConfigDefs.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 41 2 2020-11-19 2020-11-24 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
PubsubLiteProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 36 3 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
PubSubLiteSourceConnector.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 34 5 2020-11-19 2020-11-24 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
PollerFactoryImpl.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 34 1 2020-11-19 2020-11-24 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
PubSubLiteSinkConnector.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 33 5 2020-11-15 2020-11-24 4 2 dpcollins@google.com 40498610+dpcollins-google@u...
proto
split.proto
in flink-connector/flink-connector-gcp-pubsub/src/main/proto
 32 - 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
SubscriptionSplit.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split
 31 5 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
PubSubPublisherCache.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink
 29 3 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
PubSubDeserializationSchema.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink
 28 1 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
PubSubFlushablePublisher.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink
 28 3 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
Rows.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 27 1 2021-02-24 2021-03-24 3 2 dpcollins@google.com 40498610+dpcollins-google@u...
PubSubSinkWriter.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink
 24 4 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
PubSubSerializationSchema.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink
 23 1 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
EmulatorEndpoint.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/util
 20 2 2024-03-14 2024-04-19 3 2 mattkwong@google.com matt-kwong@users.noreply.gi...
StandardSqlSource.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 20 1 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
StandardSqlSink.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 20 1 2021-02-24 2021-03-24 3 2 dpcollins@google.com 40498610+dpcollins-google@u...
PubSubCheckpointSerializer.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator
 19 2 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
SubscriptionSplitSerializer.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split
 19 2 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
MakePtransform.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 18 2 2021-03-17 2021-03-24 2 2 dpcollins@google.com dpcollins@google.com
TableLoader.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 17 3 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
BigQueryProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 14 2 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
SubscriptionSplitState.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split
 10 2 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
NotifyingPullSubscriber.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 10 - 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
StandardSource.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 10 - 2021-03-17 2021-03-24 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
StandardSink.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 9 - 2021-03-17 2021-03-24 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
Poller.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 9 - 2020-11-19 2020-11-24 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
FlushablePublisher.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink
 6 - 2023-09-07 2024-02-22 2 2 mattkwong@google.com 52459909+hannahrogers-googl...
StreamingPullSubscriberFactory.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 6 - 2021-03-09 2021-03-22 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
StandardSinkProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 5 - 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
StandardSourceProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 5 - 2021-02-24 2021-03-24 3 2 dpcollins@google.com dpcollins@google.com
PollerFactory.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 5 - 2020-11-19 2020-11-24 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
package-info.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 2 - 2021-03-17 2021-03-24 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
package-info.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 2 - 2021-02-24 2021-03-24 2 2 dpcollins@google.com 40498610+dpcollins-google@u...
Correlations

File Size vs. Number of Changes: 76 points

flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSource.java x: 183 lines of code y: 12 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/AckTracker.java x: 9 lines of code y: 5 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubAckTracker.java x: 54 lines of code y: 5 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubNotifyingPullSubscriber.java x: 105 lines of code y: 6 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubRecordEmitter.java x: 31 lines of code y: 3 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubSourceReader.java x: 56 lines of code y: 3 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSink.java x: 84 lines of code y: 7 # changes flink-connector/flink-examples-gcp-pubsub/pubsub-streaming/src/main/java/com/google/pubsub/flink/PubSubExample.java x: 69 lines of code y: 5 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/util/EmulatorEndpoint.java x: 20 lines of code y: 3 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator/PubSubSplitEnumerator.java x: 69 lines of code y: 4 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubDeserializationSchema.java x: 28 lines of code y: 2 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSerializationSchema.java x: 23 lines of code y: 2 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink/FlushablePublisher.java x: 6 lines of code y: 2 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink/PubSubPublisherCache.java x: 29 lines of code y: 2 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink/PubSubSinkWriter.java x: 24 lines of code y: 2 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator/PubSubCheckpointSerializer.java x: 19 lines of code y: 2 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/NotifyingPullSubscriber.java x: 10 lines of code y: 2 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubSplitReader.java x: 103 lines of code y: 4 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split/SubscriptionSplit.java x: 31 lines of code y: 2 # changes flink-connector/flink-connector-gcp-pubsub/src/main/proto/split.proto x: 32 lines of code y: 2 # changes ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java x: 616 lines of code y: 7 # changes kafka-connector/copy_tool.py x: 76 lines of code y: 4 # changes ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/ProberStarter.java x: 156 lines of code y: 5 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkConnector.java x: 218 lines of code y: 16 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkTask.java x: 402 lines of code y: 25 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/common/ConnectorUtils.java x: 35 lines of code y: 17 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/source/AckBatchingSubscriber.java x: 80 lines of code y: 4 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubGRPCSubscriber.java x: 82 lines of code y: 9 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceConnector.java x: 281 lines of code y: 19 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java x: 325 lines of code y: 38 # changes sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/RunPipeline.java x: 39 lines of code y: 5 # changes sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/SqlStreamingOptions.java x: 4 lines of code y: 3 # changes sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/TableSpec.java x: 38 lines of code y: 6 # changes sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/TemplateMain.java x: 13 lines of code y: 5 # changes sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/UITemplateMain.java x: 14 lines of code y: 3 # changes sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/UITemplateOptions.java x: 13 lines of code y: 3 # changes sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/CloudPubsubProvider.java x: 94 lines of code y: 4 # changes sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/Compiler.java x: 66 lines of code y: 3 # changes sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/MakePtransform.java x: 18 lines of code y: 2 # changes sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/Rows.java x: 27 lines of code y: 3 # changes sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/TableLoader.java x: 17 lines of code y: 3 # changes sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/package-info.java x: 2 lines of code y: 2 # changes sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/KafkaProvider.java x: 68 lines of code y: 3 # changes sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/PubsubLiteProvider.java x: 36 lines of code y: 3 # changes sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSinkProvider.java x: 5 lines of code y: 3 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubRoundRobinSubscriber.java x: 39 lines of code y: 7 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSubscriber.java x: 11 lines of code y: 4 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/source/StreamingPullSubscriber.java x: 139 lines of code y: 3 # changes kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PubSubLiteSinkConnector.java x: 33 lines of code y: 4 # changes kafka-connector/src/main/java/com/google/pubsublite/kafka/source/ConfigDefs.java x: 41 lines of code y: 2 # changes kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PollerFactory.java x: 5 lines of code y: 2 # changes kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PollerFactoryImpl.java x: 34 lines of code y: 2 # changes kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PollerImpl.java x: 61 lines of code y: 2 # changes kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PubSubLiteSourceTask.java x: 47 lines of code y: 2 # changes kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/ConfigDefs.java x: 19 lines of code y: 1 # changes kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/Constants.java x: 9 lines of code y: 1 # changes kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PubSubLiteSinkTask.java x: 117 lines of code y: 1 # changes kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PublisherFactory.java x: 7 lines of code y: 1 # changes kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PublisherFactoryImpl.java x: 31 lines of code y: 1 # changes kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/Schemas.java x: 123 lines of code y: 1 # changes ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/OrderedProber.java x: 272 lines of code y: 1 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/common/ConnectorCredentialsProvider.java x: 29 lines of code y: 1 # changes
38.0
# changes
  min: 1.0
  average: 4.46
  25th percentile: 2.0
  median: 3.0
  75th percentile: 4.0
  max: 38.0
0 616.0
lines of code
min: 2.0 | average: 65.05 | 25th percentile: 13.25 | median: 31.0 | 75th percentile: 69.0 | max: 616.0

Number of Contributors vs. Number of Changes: 76 points

flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSource.java x: 4 # contributors y: 12 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/AckTracker.java x: 3 # contributors y: 5 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubNotifyingPullSubscriber.java x: 4 # contributors y: 6 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubRecordEmitter.java x: 3 # contributors y: 3 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSink.java x: 4 # contributors y: 7 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/util/EmulatorEndpoint.java x: 2 # contributors y: 3 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator/PubSubSplitEnumerator.java x: 3 # contributors y: 4 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubDeserializationSchema.java x: 2 # contributors y: 2 # changes flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubSplitReader.java x: 2 # contributors y: 4 # changes ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java x: 3 # contributors y: 7 # changes kafka-connector/copy_tool.py x: 1 # contributors y: 4 # changes ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/ProberStarter.java x: 4 # contributors y: 5 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkConnector.java x: 11 # contributors y: 16 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkTask.java x: 13 # contributors y: 25 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/common/ConnectorUtils.java x: 12 # contributors y: 17 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubGRPCSubscriber.java x: 5 # contributors y: 9 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceConnector.java x: 10 # contributors y: 19 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java x: 18 # contributors y: 38 # changes sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/TableSpec.java x: 3 # contributors y: 6 # changes kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubRoundRobinSubscriber.java x: 5 # contributors y: 7 # changes kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/ConfigDefs.java x: 1 # contributors y: 1 # changes
38.0
# changes
  min: 1.0
  average: 4.46
  25th percentile: 2.0
  median: 3.0
  75th percentile: 4.0
  max: 38.0
0 18.0
# contributors
min: 1.0 | average: 2.97 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 3.0 | max: 18.0

Number of Contributors vs. File Size: 76 points

flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSource.java x: 4 # contributors y: 183 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/AckTracker.java x: 3 # contributors y: 9 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubAckTracker.java x: 3 # contributors y: 54 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubNotifyingPullSubscriber.java x: 4 # contributors y: 105 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubRecordEmitter.java x: 3 # contributors y: 31 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubSourceReader.java x: 3 # contributors y: 56 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSink.java x: 4 # contributors y: 84 lines of code flink-connector/flink-examples-gcp-pubsub/pubsub-streaming/src/main/java/com/google/pubsub/flink/PubSubExample.java x: 3 # contributors y: 69 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/util/EmulatorEndpoint.java x: 2 # contributors y: 20 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubDeserializationSchema.java x: 2 # contributors y: 28 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSerializationSchema.java x: 2 # contributors y: 23 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink/FlushablePublisher.java x: 2 # contributors y: 6 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator/PubSubCheckpointSerializer.java x: 2 # contributors y: 19 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/NotifyingPullSubscriber.java x: 2 # contributors y: 10 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubSplitReader.java x: 2 # contributors y: 103 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split/SubscriptionSplit.java x: 2 # contributors y: 31 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/proto/split.proto x: 2 # contributors y: 32 lines of code ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java x: 3 # contributors y: 616 lines of code kafka-connector/copy_tool.py x: 1 # contributors y: 76 lines of code ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/ProberStarter.java x: 4 # contributors y: 156 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkConnector.java x: 11 # contributors y: 218 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkTask.java x: 13 # contributors y: 402 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/common/ConnectorUtils.java x: 12 # contributors y: 35 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/AckBatchingSubscriber.java x: 2 # contributors y: 80 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubGRPCSubscriber.java x: 5 # contributors y: 82 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceConnector.java x: 10 # contributors y: 281 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java x: 18 # contributors y: 325 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/RunPipeline.java x: 3 # contributors y: 39 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/SqlStreamingOptions.java x: 3 # contributors y: 4 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/TableSpec.java x: 3 # contributors y: 38 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/TemplateMain.java x: 3 # contributors y: 13 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/CloudPubsubProvider.java x: 2 # contributors y: 94 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/Compiler.java x: 2 # contributors y: 66 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/package-info.java x: 2 # contributors y: 2 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/BigQueryProvider.java x: 2 # contributors y: 14 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/KafkaProvider.java x: 2 # contributors y: 68 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/PubsubLiteProvider.java x: 2 # contributors y: 36 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSink.java x: 2 # contributors y: 9 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubRoundRobinSubscriber.java x: 5 # contributors y: 39 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSubscriber.java x: 3 # contributors y: 11 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/StreamingPullSubscriber.java x: 2 # contributors y: 139 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/source/ConfigDefs.java x: 2 # contributors y: 41 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PollerImpl.java x: 2 # contributors y: 61 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PubSubLiteSourceTask.java x: 2 # contributors y: 47 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/ConfigDefs.java x: 1 # contributors y: 19 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/Constants.java x: 1 # contributors y: 9 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PubSubLiteSinkTask.java x: 1 # contributors y: 117 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PublisherFactory.java x: 1 # contributors y: 7 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PublisherFactoryImpl.java x: 1 # contributors y: 31 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/Schemas.java x: 1 # contributors y: 123 lines of code ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/OrderedProber.java x: 1 # contributors y: 272 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/common/ConnectorCredentialsProvider.java x: 1 # contributors y: 29 lines of code
616.0
lines of code
  min: 2.0
  average: 65.05
  25th percentile: 13.25
  median: 31.0
  75th percentile: 69.0
  max: 616.0
0 18.0
# contributors
min: 1.0 | average: 2.97 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 3.0 | max: 18.0