apache / flink-connector-kafka
File Size

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

Intro
Learn more...
File Size Overall
0% | 8% | 44% | 18% | 27%
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% | 9% | 42% | 19% | 28%
py0% | 0% | 83% | 0% | 16%
in0% | 0% | 0% | 0% | 100%
xml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
flink-connector-kafka0% | 9% | 42% | 19% | 28%
flink-python0% | 0% | 80% | 0% | 19%
tools0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
KafkaConnectorOptionsUtil.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 519 23
KafkaDynamicSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 517 21
KafkaSourceEnumerator.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 451 31
KafkaPartitionSplitReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 425 29
DynamicKafkaSourceReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader
 420 21
DynamicKafkaSourceEnumerator.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator
 408 15
KafkaDynamicSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 391 15
KafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 389 7
UpsertKafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 332 19
FlinkKafkaInternalProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 294 34
KafkaConnectorOptions.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 293 5
ExactlyOnceKafkaWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 291 14
kafka.py
in flink-python/pyflink/datastream/connectors
 276 48
KafkaRecordSerializationSchemaBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 274 22
KafkaWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 260 15
KafkaSourceBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 257 23
DynamicKafkaRecordSerializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 246 9
KafkaSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 213 14
pyflink_gateway_server.py
in flink-python/pyflink
 204 11
DynamicKafkaSourceBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source
 197 17
StoppableKafkaEnumContextProxy.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator
 196 17
ProducerPoolImpl.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 196 13
KafkaSourceReaderMetrics.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics
 194 13
DynamicKafkaDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 173 8
KafkaCommitter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 163 8
KafkaSourceReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 158 8
KafkaSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 157 9
ReducingUpsertWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 148 13
DynamicKafkaSourceEnumStateSerializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator
 135 5
KafkaSourceEnumStateSerializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 128 4
DynamicKafkaSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source
 114 8
KafkaSinkBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 113 9
KafkaPartitionSplit.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split
 106 13
AdminUtils.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/util
 105 8
TransactionOwnership.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 96 4
setup.py
in flink-python
 95 4
KafkaClusterMetricGroup.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/metrics
 92 15
TransactionAbortStrategyImpl.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 90 5
TransactionAbortStrategyContextImpl.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 87 9
KafkaWriterState.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 85 9
LineageUtil.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage
 82 6
BackchannelImpl.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 79 12
KafkaCommittable.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 73 8
SpecifiedOffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 73 3
SingleClusterTopicMetadataService.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata
 72 7
KafkaValueOnlyDeserializerWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer
 71 3
ReducingUpsertSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 71 5
KafkaSourceFetcherManager.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher
 69 3
KafkaPartitionSplitReaderWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader
 65 6
KafkaWriterStateSerializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 64 2
Files With Most Units (Top 50)
File# lines# units
kafka.py
in flink-python/pyflink/datastream/connectors
 276 48
FlinkKafkaInternalProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 294 34
KafkaSourceEnumerator.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 451 31
KafkaPartitionSplitReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 425 29
KafkaSourceBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 257 23
KafkaConnectorOptionsUtil.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 519 23
KafkaRecordSerializationSchemaBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 274 22
DynamicKafkaSourceReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader
 420 21
KafkaDynamicSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 517 21
UpsertKafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 332 19
StoppableKafkaEnumContextProxy.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator
 196 17
DynamicKafkaSourceBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source
 197 17
KafkaClusterMetricGroup.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/metrics
 92 15
DynamicKafkaSourceEnumerator.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator
 408 15
KafkaWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 260 15
KafkaDynamicSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 391 15
ExactlyOnceKafkaWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 291 14
KafkaSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 213 14
ProducerPoolImpl.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 196 13
KafkaSourceReaderMetrics.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics
 194 13
KafkaPartitionSplit.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split
 106 13
ReducingUpsertWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 148 13
BackchannelImpl.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 79 12
pyflink_gateway_server.py
in flink-python/pyflink
 204 11
TransactionNamingStrategyContextImpl.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 59 10
KafkaSinkBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 113 9
KafkaWriterState.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 85 9
KafkaSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 157 9
TransactionAbortStrategyContextImpl.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 87 9
DynamicKafkaRecordSerializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 246 9
DefaultKafkaDatasetFacet.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage
 49 8
AdminUtils.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/util
 105 8
DynamicKafkaSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source
 114 8
KafkaCommitter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 163 8
KafkaCommittable.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 73 8
TransactionFinished.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 49 8
OffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 50 8
KafkaSourceReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 158 8
DynamicKafkaDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 173 8
DefaultKafkaDatasetIdentifier.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage
 46 7
SingleClusterTopicMetadataService.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata
 72 7
DynamicKafkaSourceSplit.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split
 56 7
KafkaSourceEnumState.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 59 7
KafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 389 7
LineageUtil.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage
 82 6
ClusterMetadata.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata
 40 6
KafkaStream.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata
 46 6
KafkaPartitionSplitReaderWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader
 65 6
BackchannelFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 60 6
CheckpointTransaction.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 45 6
Files With Long Lines (Top 17)

There are 17 files with lines longer than 120 characters. In total, there are 49 long lines.

File# lines# units# long lines
KafkaConnectorOptions.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 293 5 18
KafkaCommitter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 163 8 6
KafkaConnectorOptionsUtil.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 519 23 4
DynamicKafkaSourceOptions.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source
 31 2 3
KafkaSinkBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 113 9 3
UpsertKafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 332 19 3
TransactionOwnership.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 96 4 2
AdminUtils.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/util
 105 8 1
KafkaClusterMetricGroupManager.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/metrics
 49 4 1
ExactlyOnceKafkaWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 291 14 1
BackchannelFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal
 60 6 1
SpecifiedOffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 73 3 1
KafkaPartitionSplitReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 425 29 1
KafkaSourceOptions.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 40 1 1
KafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 389 7 1
DynamicKafkaDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 173 8 1
ReducingUpsertWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 148 13 1
Correlations

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

tools/maven/suppressions.xml x: 1 commits (all time) y: 9 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReader.java x: 5 commits (all time) y: 420 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java x: 2 commits (all time) y: 40 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java x: 2 commits (all time) y: 46 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java x: 2 commits (all time) y: 36 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java x: 6 commits (all time) y: 408 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber/StreamPatternSubscriber.java x: 2 commits (all time) y: 27 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java x: 2 commits (all time) y: 56 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java x: 12 commits (all time) y: 274 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java x: 7 commits (all time) y: 246 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/ExactlyOnceKafkaWriter.java x: 9 commits (all time) y: 291 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/FlinkKafkaInternalProducer.java x: 7 commits (all time) y: 294 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java x: 8 commits (all time) y: 293 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java x: 30 commits (all time) y: 391 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java x: 28 commits (all time) y: 389 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java x: 16 commits (all time) y: 332 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java x: 15 commits (all time) y: 163 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java x: 13 commits (all time) y: 157 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java x: 11 commits (all time) y: 113 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionNamingStrategy.java x: 2 commits (all time) y: 26 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionNamingStrategyContextImpl.java x: 2 commits (all time) y: 59 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionNamingStrategyImpl.java x: 3 commits (all time) y: 63 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionalIdFactory.java x: 3 commits (all time) y: 25 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java x: 3 commits (all time) y: 85 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterStateSerializer.java x: 3 commits (all time) y: 64 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPool.java x: 4 commits (all time) y: 11 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPoolImpl.java x: 6 commits (all time) y: 196 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionAbortStrategyContextImpl.java x: 2 commits (all time) y: 87 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionAbortStrategyImpl.java x: 2 commits (all time) y: 90 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionOwnership.java x: 1 commits (all time) y: 96 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/PartitionSetSubscriber.java x: 5 commits (all time) y: 58 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicListSubscriber.java x: 6 commits (all time) y: 40 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicPatternSubscriber.java x: 6 commits (all time) y: 42 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/util/AdminUtils.java x: 1 commits (all time) y: 105 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/Backchannel.java x: 2 commits (all time) y: 9 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ReadableBackchannel.java x: 2 commits (all time) y: 8 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/WritableBackchannel.java x: 2 commits (all time) y: 6 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java x: 32 commits (all time) y: 260 lines of code flink-python/pyflink/datastream/connectors/kafka.py x: 3 commits (all time) y: 276 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionFinished.java x: 1 commits (all time) y: 49 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java x: 2 commits (all time) y: 20 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReader.java x: 17 commits (all time) y: 158 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchema.java x: 7 commits (all time) y: 28 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher/KafkaSourceFetcherManager.java x: 9 commits (all time) y: 69 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java x: 7 commits (all time) y: 173 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java x: 12 commits (all time) y: 519 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java x: 22 commits (all time) y: 517 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java x: 8 commits (all time) y: 71 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java x: 7 commits (all time) y: 49 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java x: 5 commits (all time) y: 32 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java x: 19 commits (all time) y: 425 lines of code flink-python/setup.py x: 2 commits (all time) y: 95 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java x: 6 commits (all time) y: 73 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/CheckpointTransaction.java x: 1 commits (all time) y: 45 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelFactory.java x: 1 commits (all time) y: 60 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelImpl.java x: 1 commits (all time) y: 79 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java x: 17 commits (all time) y: 257 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultTypeDatasetFacet.java x: 1 commits (all time) y: 33 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/KafkaDatasetFacetProvider.java x: 1 commits (all time) y: 7 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/KafkaDatasetIdentifier.java x: 1 commits (all time) y: 19 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageUtil.java x: 1 commits (all time) y: 82 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchema.java x: 5 commits (all time) y: 24 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java x: 19 commits (all time) y: 213 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriber.java x: 6 commits (all time) y: 21 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumState.java x: 7 commits (all time) y: 59 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java x: 6 commits (all time) y: 128 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java x: 18 commits (all time) y: 451 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSourceOptions.java x: 2 commits (all time) y: 31 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/StoppableKafkaEnumContextProxy.java x: 2 commits (all time) y: 196 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaMetadataService.java x: 1 commits (all time) y: 12 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/SingleClusterTopicMetadataService.java x: 1 commits (all time) y: 72 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSource.java x: 1 commits (all time) y: 114 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSourceBuilder.java x: 1 commits (all time) y: 197 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/GetMetadataUpdateEvent.java x: 1 commits (all time) y: 5 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumState.java x: 1 commits (all time) y: 29 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumStateSerializer.java x: 1 commits (all time) y: 135 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber/KafkaStreamSetSubscriber.java x: 1 commits (all time) y: 17 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/metrics/KafkaClusterMetricGroup.java x: 1 commits (all time) y: 92 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader/KafkaPartitionSplitReaderWrapper.java x: 1 commits (all time) y: 65 lines of code flink-python/pyflink/pyflink_gateway_server.py x: 1 commits (all time) y: 204 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplit.java x: 7 commits (all time) y: 106 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer.java x: 6 commits (all time) y: 50 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/ReaderHandledOffsetsInitializer.java x: 4 commits (all time) y: 43 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/util/JacksonMapperFactory.java x: 1 commits (all time) y: 25 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceOptions.java x: 8 commits (all time) y: 40 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriter.java x: 8 commits (all time) y: 148 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/SpecifiedOffsetsInitializer.java x: 5 commits (all time) y: 73 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/TimestampOffsetsInitializer.java x: 4 commits (all time) y: 37 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/AssignmentStatus.java x: 1 commits (all time) y: 22 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricMutableWrapper.java x: 4 commits (all time) y: 19 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java x: 7 commits (all time) y: 194 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaRecordEmitter.java x: 4 commits (all time) y: 49 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplitSerializer.java x: 3 commits (all time) y: 42 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSerializerWrapper.java x: 2 commits (all time) y: 60 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaValueOnlyDeserializerWrapper.java x: 3 commits (all time) y: 71 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/MetricUtil.java x: 2 commits (all time) y: 33 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java x: 2 commits (all time) y: 48 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/StartupMode.java x: 4 commits (all time) y: 18 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/NoStoppingOffsetsInitializer.java x: 2 commits (all time) y: 23 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionStateSentinel.java x: 2 commits (all time) y: 12 lines of code
519.0
lines of code
  min: 5.0
  average: 99.24
  25th percentile: 22.75
  median: 49.0
  75th percentile: 117.5
  max: 519.0
0 32.0
commits (all time)
min: 1.0 | average: 4.9 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 6.0 | max: 32.0

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

tools/maven/suppressions.xml x: 1 contributors (all time) y: 9 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReader.java x: 2 contributors (all time) y: 420 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java x: 2 contributors (all time) y: 40 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java x: 2 contributors (all time) y: 46 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java x: 2 contributors (all time) y: 36 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java x: 5 contributors (all time) y: 408 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber/StreamPatternSubscriber.java x: 2 contributors (all time) y: 27 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java x: 2 contributors (all time) y: 56 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java x: 10 contributors (all time) y: 274 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java x: 4 contributors (all time) y: 246 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/ExactlyOnceKafkaWriter.java x: 2 contributors (all time) y: 291 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/FlinkKafkaInternalProducer.java x: 1 contributors (all time) y: 294 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java x: 7 contributors (all time) y: 293 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java x: 18 contributors (all time) y: 391 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java x: 19 contributors (all time) y: 389 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java x: 13 contributors (all time) y: 332 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java x: 5 contributors (all time) y: 163 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java x: 6 contributors (all time) y: 157 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java x: 7 contributors (all time) y: 113 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionNamingStrategy.java x: 1 contributors (all time) y: 26 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionNamingStrategyContextImpl.java x: 1 contributors (all time) y: 59 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionNamingStrategyImpl.java x: 1 contributors (all time) y: 63 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java x: 3 contributors (all time) y: 85 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterStateSerializer.java x: 3 contributors (all time) y: 64 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPool.java x: 1 contributors (all time) y: 11 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPoolImpl.java x: 1 contributors (all time) y: 196 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionAbortStrategyContextImpl.java x: 1 contributors (all time) y: 87 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionAbortStrategyImpl.java x: 1 contributors (all time) y: 90 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionOwnership.java x: 1 contributors (all time) y: 96 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/PartitionSetSubscriber.java x: 5 contributors (all time) y: 58 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicListSubscriber.java x: 6 contributors (all time) y: 40 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicPatternSubscriber.java x: 6 contributors (all time) y: 42 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/util/AdminUtils.java x: 1 contributors (all time) y: 105 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ReadableBackchannel.java x: 1 contributors (all time) y: 8 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/WritableBackchannel.java x: 1 contributors (all time) y: 6 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java x: 12 contributors (all time) y: 260 lines of code flink-python/pyflink/datastream/connectors/kafka.py x: 3 contributors (all time) y: 276 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionFinished.java x: 1 contributors (all time) y: 49 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java x: 2 contributors (all time) y: 20 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReader.java x: 9 contributors (all time) y: 158 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchema.java x: 5 contributors (all time) y: 28 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher/KafkaSourceFetcherManager.java x: 6 contributors (all time) y: 69 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java x: 5 contributors (all time) y: 173 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java x: 10 contributors (all time) y: 519 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java x: 14 contributors (all time) y: 517 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java x: 5 contributors (all time) y: 71 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java x: 6 contributors (all time) y: 49 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java x: 5 contributors (all time) y: 32 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java x: 12 contributors (all time) y: 425 lines of code flink-python/setup.py x: 2 contributors (all time) y: 95 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java x: 3 contributors (all time) y: 73 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/CheckpointTransaction.java x: 1 contributors (all time) y: 45 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelFactory.java x: 1 contributors (all time) y: 60 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelImpl.java x: 1 contributors (all time) y: 79 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java x: 13 contributors (all time) y: 257 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultTypeDatasetFacet.java x: 1 contributors (all time) y: 33 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/KafkaDatasetIdentifier.java x: 1 contributors (all time) y: 19 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageUtil.java x: 1 contributors (all time) y: 82 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchema.java x: 4 contributors (all time) y: 24 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java x: 13 contributors (all time) y: 213 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriber.java x: 6 contributors (all time) y: 21 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumState.java x: 7 contributors (all time) y: 59 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java x: 6 contributors (all time) y: 128 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java x: 12 contributors (all time) y: 451 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSourceOptions.java x: 1 contributors (all time) y: 31 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/SingleClusterTopicMetadataService.java x: 1 contributors (all time) y: 72 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSource.java x: 1 contributors (all time) y: 114 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSourceBuilder.java x: 1 contributors (all time) y: 197 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumState.java x: 1 contributors (all time) y: 29 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumStateSerializer.java x: 1 contributors (all time) y: 135 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber/KafkaStreamSetSubscriber.java x: 1 contributors (all time) y: 17 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/metrics/KafkaClusterMetricGroup.java x: 1 contributors (all time) y: 92 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader/KafkaPartitionSplitReaderWrapper.java x: 1 contributors (all time) y: 65 lines of code flink-python/pyflink/pyflink_gateway_server.py x: 1 contributors (all time) y: 204 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplit.java x: 7 contributors (all time) y: 106 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer.java x: 6 contributors (all time) y: 50 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/ReaderHandledOffsetsInitializer.java x: 4 contributors (all time) y: 43 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriter.java x: 4 contributors (all time) y: 148 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/SpecifiedOffsetsInitializer.java x: 5 contributors (all time) y: 73 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/TimestampOffsetsInitializer.java x: 4 contributors (all time) y: 37 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/AssignmentStatus.java x: 1 contributors (all time) y: 22 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricMutableWrapper.java x: 3 contributors (all time) y: 19 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java x: 3 contributors (all time) y: 194 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaRecordEmitter.java x: 4 contributors (all time) y: 49 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplitSerializer.java x: 3 contributors (all time) y: 42 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplitState.java x: 3 contributors (all time) y: 25 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSerializerWrapper.java x: 2 contributors (all time) y: 60 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaValueOnlyDeserializerWrapper.java x: 3 contributors (all time) y: 71 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/MetricUtil.java x: 2 contributors (all time) y: 33 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java x: 2 contributors (all time) y: 48 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/StartupMode.java x: 4 contributors (all time) y: 18 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/NoStoppingOffsetsInitializer.java x: 2 contributors (all time) y: 23 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionStateSentinel.java x: 2 contributors (all time) y: 12 lines of code
519.0
lines of code
  min: 5.0
  average: 99.24
  25th percentile: 22.75
  median: 49.0
  75th percentile: 117.5
  max: 519.0
0 19.0
contributors (all time)
min: 1.0 | average: 3.46 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 5.0 | max: 19.0

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

tools/maven/suppressions.xml x: 1 commits (30d) y: 9 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReader.java x: 2 commits (30d) y: 420 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java x: 1 commits (30d) y: 40 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java x: 1 commits (30d) y: 46 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java x: 1 commits (30d) y: 36 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java x: 1 commits (30d) y: 408 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber/StreamPatternSubscriber.java x: 1 commits (30d) y: 27 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java x: 1 commits (30d) y: 56 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java x: 1 commits (30d) y: 274 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java x: 1 commits (30d) y: 246 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/ExactlyOnceKafkaWriter.java x: 1 commits (30d) y: 291 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/FlinkKafkaInternalProducer.java x: 1 commits (30d) y: 294 lines of code
420.0
lines of code
  min: 9.0
  average: 168.69
  25th percentile: 38.0
  median: 56.0
  75th percentile: 292.5
  max: 420.0
0 2.0
commits (30d)
min: 1.0 | average: 1.08 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 2.0

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

tools/maven/suppressions.xml x: 1 contributors (30d) y: 9 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReader.java x: 1 contributors (30d) y: 420 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java x: 1 contributors (30d) y: 40 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java x: 1 contributors (30d) y: 46 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java x: 1 contributors (30d) y: 36 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java x: 1 contributors (30d) y: 408 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber/StreamPatternSubscriber.java x: 1 contributors (30d) y: 27 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java x: 1 contributors (30d) y: 56 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java x: 1 contributors (30d) y: 274 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java x: 1 contributors (30d) y: 246 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/ExactlyOnceKafkaWriter.java x: 1 contributors (30d) y: 291 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/FlinkKafkaInternalProducer.java x: 1 contributors (30d) y: 294 lines of code
420.0
lines of code
  min: 9.0
  average: 168.69
  25th percentile: 38.0
  median: 56.0
  75th percentile: 292.5
  max: 420.0
0 1.0
contributors (30d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

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

tools/maven/suppressions.xml x: 1 commits (90d) y: 9 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReader.java x: 2 commits (90d) y: 420 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java x: 1 commits (90d) y: 40 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java x: 1 commits (90d) y: 46 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java x: 1 commits (90d) y: 36 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java x: 2 commits (90d) y: 408 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber/StreamPatternSubscriber.java x: 1 commits (90d) y: 27 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java x: 1 commits (90d) y: 56 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java x: 1 commits (90d) y: 274 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java x: 2 commits (90d) y: 246 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/ExactlyOnceKafkaWriter.java x: 9 commits (90d) y: 291 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/FlinkKafkaInternalProducer.java x: 7 commits (90d) y: 294 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java x: 1 commits (90d) y: 293 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java x: 2 commits (90d) y: 391 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java x: 1 commits (90d) y: 389 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java x: 1 commits (90d) y: 332 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java x: 5 commits (90d) y: 163 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java x: 7 commits (90d) y: 157 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java x: 3 commits (90d) y: 113 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionNamingStrategy.java x: 2 commits (90d) y: 26 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionNamingStrategyContextImpl.java x: 2 commits (90d) y: 59 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionNamingStrategyImpl.java x: 3 commits (90d) y: 63 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionalIdFactory.java x: 3 commits (90d) y: 25 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java x: 1 commits (90d) y: 85 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterStateSerializer.java x: 1 commits (90d) y: 64 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPool.java x: 4 commits (90d) y: 11 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPoolImpl.java x: 6 commits (90d) y: 196 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionAbortStrategyContextImpl.java x: 2 commits (90d) y: 87 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionAbortStrategyImpl.java x: 2 commits (90d) y: 90 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionOwnership.java x: 1 commits (90d) y: 96 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/PartitionSetSubscriber.java x: 1 commits (90d) y: 58 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicPatternSubscriber.java x: 1 commits (90d) y: 42 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/util/AdminUtils.java x: 1 commits (90d) y: 105 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/Backchannel.java x: 2 commits (90d) y: 9 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ReadableBackchannel.java x: 2 commits (90d) y: 8 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/WritableBackchannel.java x: 2 commits (90d) y: 6 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java x: 4 commits (90d) y: 260 lines of code flink-python/pyflink/datastream/connectors/kafka.py x: 1 commits (90d) y: 276 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionFinished.java x: 1 commits (90d) y: 49 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java x: 1 commits (90d) y: 20 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReader.java x: 1 commits (90d) y: 158 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher/KafkaSourceFetcherManager.java x: 1 commits (90d) y: 69 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java x: 1 commits (90d) y: 173 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java x: 1 commits (90d) y: 519 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java x: 2 commits (90d) y: 71 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java x: 1 commits (90d) y: 425 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java x: 2 commits (90d) y: 73 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelFactory.java x: 1 commits (90d) y: 60 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelImpl.java x: 1 commits (90d) y: 79 lines of code
519.0
lines of code
  min: 6.0
  average: 144.05
  25th percentile: 42.75
  median: 76.0
  75th percentile: 256.5
  max: 519.0
0 9.0
commits (90d)
min: 1.0 | average: 1.96 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 9.0

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

tools/maven/suppressions.xml x: 1 contributors (90d) y: 9 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/reader/DynamicKafkaSourceReader.java x: 1 contributors (90d) y: 420 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java x: 1 contributors (90d) y: 40 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java x: 1 contributors (90d) y: 46 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java x: 1 contributors (90d) y: 36 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java x: 2 contributors (90d) y: 408 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/subscriber/StreamPatternSubscriber.java x: 1 contributors (90d) y: 27 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java x: 1 contributors (90d) y: 56 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java x: 1 contributors (90d) y: 274 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java x: 1 contributors (90d) y: 246 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/ExactlyOnceKafkaWriter.java x: 2 contributors (90d) y: 291 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/FlinkKafkaInternalProducer.java x: 1 contributors (90d) y: 294 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java x: 2 contributors (90d) y: 391 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java x: 1 contributors (90d) y: 389 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java x: 1 contributors (90d) y: 332 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java x: 1 contributors (90d) y: 163 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java x: 2 contributors (90d) y: 157 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java x: 2 contributors (90d) y: 113 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionNamingStrategy.java x: 1 contributors (90d) y: 26 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionNamingStrategyContextImpl.java x: 1 contributors (90d) y: 59 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionNamingStrategyImpl.java x: 1 contributors (90d) y: 63 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java x: 1 contributors (90d) y: 85 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterStateSerializer.java x: 1 contributors (90d) y: 64 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPool.java x: 1 contributors (90d) y: 11 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPoolImpl.java x: 1 contributors (90d) y: 196 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionAbortStrategyContextImpl.java x: 1 contributors (90d) y: 87 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionAbortStrategyImpl.java x: 1 contributors (90d) y: 90 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionOwnership.java x: 1 contributors (90d) y: 96 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicPatternSubscriber.java x: 1 contributors (90d) y: 42 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/util/AdminUtils.java x: 1 contributors (90d) y: 105 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ReadableBackchannel.java x: 1 contributors (90d) y: 8 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/WritableBackchannel.java x: 1 contributors (90d) y: 6 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java x: 2 contributors (90d) y: 260 lines of code flink-python/pyflink/datastream/connectors/kafka.py x: 1 contributors (90d) y: 276 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionFinished.java x: 1 contributors (90d) y: 49 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java x: 1 contributors (90d) y: 20 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReader.java x: 1 contributors (90d) y: 158 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher/KafkaSourceFetcherManager.java x: 1 contributors (90d) y: 69 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java x: 1 contributors (90d) y: 173 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java x: 1 contributors (90d) y: 519 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java x: 2 contributors (90d) y: 71 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java x: 1 contributors (90d) y: 425 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java x: 1 contributors (90d) y: 73 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelFactory.java x: 1 contributors (90d) y: 60 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelImpl.java x: 1 contributors (90d) y: 79 lines of code
519.0
lines of code
  min: 6.0
  average: 144.05
  25th percentile: 42.75
  median: 76.0
  75th percentile: 256.5
  max: 519.0
0 2.0
contributors (90d)
min: 1.0 | average: 1.13 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 2.0