GoogleCloudPlatform / pubsub
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
0% | 12% | 30% | 18% | 38%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 12% | 30% | 19% | 37%
py0% | 0% | 0% | 0% | 100%
proto0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
ordering-keys-prober0% | 59% | 26% | 14% | 0%
kafka-connector0% | 0% | 53% | 16% | 30%
flink-connector0% | 0% | 0% | 37% | 62%
sql-streaming-copier0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
Prober.java
in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober
 616 38
CloudPubSubSinkTask.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/sink
 402 13
CloudPubSubSourceTask.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 325 11
CloudPubSubSourceConnector.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 281 9
OrderedProber.java
in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober
 272 9
CloudPubSubSinkConnector.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/sink
 218 8
PubSubSource.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink
 183 11
ProberStarter.java
in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober
 156 1
StreamingPullSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 139 10
Schemas.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 123 6
PubSubLiteSinkTask.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 117 7
PubSubNotifyingPullSubscriber.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 105 8
PubSubSplitReader.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 103 7
CloudPubsubProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 94 5
PubSubSink.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink
 84 3
CloudPubSubGRPCSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 82 3
AckBatchingSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 80 4
copy_tool.py
in kafka-connector
 76 6
PubSubExample.java
in flink-connector/flink-examples-gcp-pubsub/pubsub-streaming/src/main/java/com/google/pubsub/flink
 69 1
PubSubSplitEnumerator.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator
 69 8
KafkaProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 68 4
Compiler.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 66 3
PollerImpl.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 61 2
PubSubSourceReader.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 56 6
PubSubAckTracker.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 54 5
PubSubLiteSourceTask.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 47 5
ConfigDefs.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 41 2
RunPipeline.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 39 4
CloudPubSubRoundRobinSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 39 3
TableSpec.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 38 3
PubsubLiteProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 36 3
ConnectorUtils.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/common
 35 2
PubSubLiteSourceConnector.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 34 5
PollerFactoryImpl.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 34 1
PubSubLiteSinkConnector.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 33 5
proto
split.proto
in flink-connector/flink-connector-gcp-pubsub/src/main/proto
 32 -
SubscriptionSplit.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split
 31 5
PubSubRecordEmitter.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 31 2
TemplateOptions.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 31 -
PublisherFactoryImpl.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 31 1
PubSubPublisherCache.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink
 29 3
ConnectorCredentialsProvider.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/common
 29 3
PubSubDeserializationSchema.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink
 28 1
PubSubFlushablePublisher.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink
 28 3
Rows.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 27 1
PubSubSinkWriter.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink
 24 4
PubSubSerializationSchema.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink
 23 1
EmulatorEndpoint.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/util
 20 2
StandardSqlSource.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 20 1
StandardSqlSink.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 20 1
Files With Most Units (Top 50)
File# lines# units
Prober.java
in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober
 616 38
CloudPubSubSinkTask.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/sink
 402 13
PubSubSource.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink
 183 11
CloudPubSubSourceTask.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 325 11
StreamingPullSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 139 10
OrderedProber.java
in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober
 272 9
CloudPubSubSourceConnector.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 281 9
PubSubSplitEnumerator.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator
 69 8
PubSubNotifyingPullSubscriber.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 105 8
CloudPubSubSinkConnector.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/sink
 218 8
PubSubSplitReader.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 103 7
PubSubLiteSinkTask.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 117 7
PubSubSourceReader.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 56 6
Schemas.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 123 6
copy_tool.py
in kafka-connector
 76 6
SubscriptionSplit.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split
 31 5
PubSubAckTracker.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 54 5
CloudPubsubProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 94 5
PubSubLiteSinkConnector.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 33 5
PubSubLiteSourceConnector.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 34 5
PubSubLiteSourceTask.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 47 5
PubSubSinkWriter.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink
 24 4
RunPipeline.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 39 4
KafkaProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 68 4
AckBatchingSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 80 4
PubSubFlushablePublisher.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink
 28 3
PubSubPublisherCache.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink
 29 3
PubSubSink.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink
 84 3
Compiler.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 66 3
TableLoader.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 17 3
TableSpec.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 38 3
PubsubLiteProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 36 3
ConnectorCredentialsProvider.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/common
 29 3
CloudPubSubRoundRobinSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 39 3
CloudPubSubGRPCSubscriber.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 82 3
EmulatorEndpoint.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/util
 20 2
PubSubCheckpointSerializer.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator
 19 2
SubscriptionSplitSerializer.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split
 19 2
SubscriptionSplitState.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split
 10 2
PubSubRecordEmitter.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader
 31 2
BigQueryProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 14 2
MakePtransform.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 18 2
ConnectorUtils.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/common
 35 2
ConfigDefs.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink
 19 2
ConfigDefs.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 41 2
PollerImpl.java
in kafka-connector/src/main/java/com/google/pubsublite/kafka/source
 61 2
PubSubExample.java
in flink-connector/flink-examples-gcp-pubsub/pubsub-streaming/src/main/java/com/google/pubsub/flink
 69 1
PubSubDeserializationSchema.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink
 28 1
PubSubSerializationSchema.java
in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink
 23 1
TemplateMain.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql
 13 1
Files With Long Lines (Top 4)

There are 4 files with lines longer than 120 characters. In total, there are 7 long lines.

File# lines# units# long lines
CloudPubSubSourceConnector.java
in kafka-connector/src/main/java/com/google/pubsub/kafka/source
 281 9 4
PubsubLiteProvider.java
in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers
 36 3 1
ProberStarter.java
in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober
 156 1 1
copy_tool.py
in kafka-connector
 76 6 1
Correlations

File Size vs. Commits (all time): 76 points

flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSource.java x: 17 commits (all time) y: 183 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/AckTracker.java x: 5 commits (all time) y: 9 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubAckTracker.java x: 5 commits (all time) y: 54 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubNotifyingPullSubscriber.java x: 7 commits (all time) 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 commits (all time) 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 commits (all time) y: 56 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSink.java x: 10 commits (all time) y: 84 lines of code flink-connector/flink-examples-gcp-pubsub/pubsub-streaming/src/main/java/com/google/pubsub/flink/PubSubExample.java x: 5 commits (all time) y: 69 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/util/EmulatorEndpoint.java x: 4 commits (all time) y: 20 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator/PubSubSplitEnumerator.java x: 4 commits (all time) y: 69 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubDeserializationSchema.java x: 2 commits (all time) y: 28 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSerializationSchema.java x: 2 commits (all time) y: 23 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink/FlushablePublisher.java x: 2 commits (all time) 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 commits (all time) 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 commits (all time) y: 10 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubSplitReader.java x: 5 commits (all time) 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 commits (all time) y: 31 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/proto/split.proto x: 2 commits (all time) y: 32 lines of code ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java x: 8 commits (all time) y: 616 lines of code kafka-connector/copy_tool.py x: 5 commits (all time) y: 76 lines of code ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/ProberStarter.java x: 6 commits (all time) y: 156 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkConnector.java x: 19 commits (all time) y: 218 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkTask.java x: 37 commits (all time) y: 402 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/common/ConnectorUtils.java x: 26 commits (all time) y: 35 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/AckBatchingSubscriber.java x: 5 commits (all time) y: 80 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubGRPCSubscriber.java x: 11 commits (all time) y: 82 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceConnector.java x: 25 commits (all time) y: 281 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java x: 52 commits (all time) y: 325 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/RunPipeline.java x: 6 commits (all time) y: 39 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/SqlStreamingOptions.java x: 4 commits (all time) y: 4 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/TableSpec.java x: 8 commits (all time) y: 38 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/TemplateMain.java x: 7 commits (all time) y: 13 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/TemplateOptions.java x: 4 commits (all time) y: 31 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/UITemplateMain.java x: 4 commits (all time) y: 14 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/CloudPubsubProvider.java x: 7 commits (all time) y: 94 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/Compiler.java x: 4 commits (all time) y: 66 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/MakePtransform.java x: 3 commits (all time) y: 18 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/Rows.java x: 4 commits (all time) y: 27 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/TableLoader.java x: 4 commits (all time) y: 17 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/package-info.java x: 2 commits (all time) y: 2 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/BigQueryProvider.java x: 5 commits (all time) y: 14 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/PubsubLiteProvider.java x: 7 commits (all time) y: 36 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSink.java x: 3 commits (all time) y: 9 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSinkProvider.java x: 4 commits (all time) y: 5 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSource.java x: 3 commits (all time) y: 10 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSqlSink.java x: 3 commits (all time) y: 20 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSqlSource.java x: 5 commits (all time) y: 20 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubRoundRobinSubscriber.java x: 8 commits (all time) y: 39 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSubscriber.java x: 4 commits (all time) y: 11 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/StreamingPullSubscriber.java x: 3 commits (all time) y: 139 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PubSubLiteSinkConnector.java x: 6 commits (all time) y: 33 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/source/ConfigDefs.java x: 3 commits (all time) y: 41 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PollerFactory.java x: 3 commits (all time) y: 5 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PollerFactoryImpl.java x: 3 commits (all time) y: 34 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PollerImpl.java x: 3 commits (all time) y: 61 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PubSubLiteSourceTask.java x: 3 commits (all time) y: 47 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/ConfigDefs.java x: 1 commits (all time) y: 19 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/Constants.java x: 1 commits (all time) y: 9 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PubSubLiteSinkTask.java x: 1 commits (all time) y: 117 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PublisherFactory.java x: 1 commits (all time) y: 7 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PublisherFactoryImpl.java x: 1 commits (all time) y: 31 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/Schemas.java x: 1 commits (all time) y: 123 lines of code ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/OrderedProber.java x: 1 commits (all time) y: 272 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/common/ConnectorCredentialsProvider.java x: 1 commits (all time) 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 52.0
commits (all time)
min: 1.0 | average: 5.79 | 25th percentile: 2.0 | median: 4.0 | 75th percentile: 5.0 | max: 52.0

File Size vs. Contributors (all time): 76 points

flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSource.java x: 4 contributors (all time) 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 (all time) 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 (all time) 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 (all time) 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 (all time) 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 (all time) y: 56 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSink.java x: 4 contributors (all time) 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 (all time) y: 69 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/util/EmulatorEndpoint.java x: 2 contributors (all time) y: 20 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubDeserializationSchema.java x: 2 contributors (all time) y: 28 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSerializationSchema.java x: 2 contributors (all time) 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 (all time) 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 (all time) 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 (all time) 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 (all time) 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 (all time) y: 31 lines of code flink-connector/flink-connector-gcp-pubsub/src/main/proto/split.proto x: 2 contributors (all time) y: 32 lines of code ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java x: 3 contributors (all time) y: 616 lines of code kafka-connector/copy_tool.py x: 1 contributors (all time) y: 76 lines of code ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/ProberStarter.java x: 4 contributors (all time) y: 156 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkConnector.java x: 11 contributors (all time) y: 218 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkTask.java x: 13 contributors (all time) y: 402 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/common/ConnectorUtils.java x: 12 contributors (all time) y: 35 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/AckBatchingSubscriber.java x: 2 contributors (all time) y: 80 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubGRPCSubscriber.java x: 5 contributors (all time) y: 82 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceConnector.java x: 10 contributors (all time) y: 281 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java x: 18 contributors (all time) y: 325 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/RunPipeline.java x: 3 contributors (all time) y: 39 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/SqlStreamingOptions.java x: 3 contributors (all time) y: 4 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/TableSpec.java x: 3 contributors (all time) y: 38 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/TemplateMain.java x: 3 contributors (all time) y: 13 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/CloudPubsubProvider.java x: 2 contributors (all time) y: 94 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/Compiler.java x: 2 contributors (all time) y: 66 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/package-info.java x: 2 contributors (all time) y: 2 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/BigQueryProvider.java x: 2 contributors (all time) y: 14 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/KafkaProvider.java x: 2 contributors (all time) y: 68 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/PubsubLiteProvider.java x: 2 contributors (all time) y: 36 lines of code sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSink.java x: 2 contributors (all time) y: 9 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubRoundRobinSubscriber.java x: 5 contributors (all time) y: 39 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSubscriber.java x: 3 contributors (all time) y: 11 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/source/StreamingPullSubscriber.java x: 2 contributors (all time) y: 139 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/source/ConfigDefs.java x: 2 contributors (all time) y: 41 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PollerImpl.java x: 2 contributors (all time) y: 61 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PubSubLiteSourceTask.java x: 2 contributors (all time) y: 47 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/ConfigDefs.java x: 1 contributors (all time) y: 19 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/Constants.java x: 1 contributors (all time) y: 9 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PubSubLiteSinkTask.java x: 1 contributors (all time) y: 117 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PublisherFactory.java x: 1 contributors (all time) y: 7 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PublisherFactoryImpl.java x: 1 contributors (all time) y: 31 lines of code kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/Schemas.java x: 1 contributors (all time) y: 123 lines of code ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/OrderedProber.java x: 1 contributors (all time) y: 272 lines of code kafka-connector/src/main/java/com/google/pubsub/kafka/common/ConnectorCredentialsProvider.java x: 1 contributors (all time) 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 (all time)
min: 1.0 | average: 2.97 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 3.0 | max: 18.0

File Size vs. Commits (30 days): 0 points

No data for "commits (30d)" vs. "lines of code".

File Size vs. Contributors (30 days): 0 points

No data for "contributors (30d)" vs. "lines of code".

File Size vs. Commits (90 days): 0 points

No data for "commits (90d)" vs. "lines of code".

File Size vs. Contributors (90 days): 0 points

No data for "contributors (90d)" vs. "lines of code".