apache / flink-connector-kafka
File Size

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

Intro
Learn more...
File Size Overall
9% | 13% | 36% | 18% | 21%
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
java9% | 13% | 36% | 18% | 21%
xml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
flink-connector-kafka9% | 13% | 36% | 18% | 21%
tools0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
FlinkKafkaProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 1262 87
FlinkKafkaConsumerBase.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 677 29
KafkaConnectorOptionsUtil.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 538 24
KafkaDynamicSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 512 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
 410 26
KafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 372 7
KafkaWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 370 18
KafkaDynamicSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 360 14
UpsertKafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 331 20
AbstractFetcher.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 324 11
FlinkKafkaInternalProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 314 29
KafkaConsumerThread.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 310 9
FlinkKafkaInternalProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 292 32
FlinkKafkaProducerBase.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 281 14
KafkaConnectorOptions.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 276 5
ClosableBlockingQueue.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 262 19
KafkaShuffleFetcher.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 211 14
KafkaSourceBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 211 21
KafkaSourceReaderMetrics.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics
 194 13
KafkaRecordSerializationSchemaBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 194 17
FlinkKafkaConsumer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 180 12
DynamicKafkaDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 179 10
KafkaSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 167 13
KafkaFetcher.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 159 11
KafkaSourceReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 159 8
FlinkKafkaShuffleProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle
 153 2
ReducingUpsertWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 148 13
DynamicKafkaRecordSerializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 142 5
FlinkKafkaShuffle.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle
 135 7
KafkaSourceEnumStateSerializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 128 4
TypeInformationKeyValueSerializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization
 115 5
AbstractPartitionDiscoverer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 107 8
KafkaPartitionSplit.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split
 106 13
KafkaCommitter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 105 3
KafkaSinkBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 99 9
Handover.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 86 5
KafkaTopicPartition.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 82 10
KafkaSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 76 7
KafkaTopicPartitionLeader.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 73 6
SpecifiedOffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 73 3
KafkaSerializationSchemaWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 72 8
KafkaPartitionDiscoverer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 71 6
ReducingUpsertSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 71 3
KafkaValueOnlyDeserializerWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer
 71 3
KafkaCommittable.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 70 8
KafkaSourceFetcherManager.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher
 69 3
FlinkKafkaShuffleConsumer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle
 63 1
KafkaSerializerWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 60 1
KafkaSourceEnumState.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 59 6
Files With Most Units (Top 50)
File# lines# units
FlinkKafkaProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 1262 87
FlinkKafkaInternalProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 292 32
KafkaSourceEnumerator.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 451 31
FlinkKafkaConsumerBase.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 677 29
FlinkKafkaInternalProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 314 29
KafkaPartitionSplitReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 410 26
KafkaConnectorOptionsUtil.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 538 24
KafkaDynamicSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 512 21
KafkaSourceBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 211 21
UpsertKafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 331 20
ClosableBlockingQueue.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 262 19
KafkaWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 370 18
KafkaRecordSerializationSchemaBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 194 17
FlinkKafkaProducerBase.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 281 14
KafkaShuffleFetcher.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 211 14
KafkaTopicPartitionState.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 58 14
KafkaDynamicSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 360 14
ReducingUpsertWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 148 13
KafkaPartitionSplit.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split
 106 13
KafkaSourceReaderMetrics.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics
 194 13
KafkaSource.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 167 13
FlinkKafkaConsumer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 180 12
AbstractFetcher.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 324 11
KafkaFetcher.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 159 11
KafkaTopicPartition.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 82 10
DynamicKafkaDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 179 10
KafkaConsumerThread.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 310 9
KafkaSinkBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 99 9
KafkaSerializationSchemaWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 72 8
AbstractPartitionDiscoverer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 107 8
KafkaSourceReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 159 8
OffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 51 8
KafkaCommittable.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 70 8
FlinkKafkaShuffle.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle
 135 7
KafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 372 7
KafkaSink.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 76 7
KafkaTopicPartitionLeader.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 73 6
KafkaDeserializationSchemaWrapper.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 36 6
KafkaTopicsDescriptor.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 49 6
KafkaPartitionDiscoverer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 71 6
SinkBufferFlushMode.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 48 6
KafkaRecordEmitter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 49 6
KafkaSourceEnumState.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator
 59 6
Handover.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 86 5
KafkaTopicPartitionStateWithWatermarkGenerator.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 45 5
DynamicKafkaRecordSerializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 142 5
KafkaConnectorOptions.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 276 5
JSONKeyValueDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization
 49 5
TypeInformationKeyValueSerializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization
 115 5
TransactionAborter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 58 5
Files With Long Lines (Top 16)

There are 16 files with lines longer than 120 characters. In total, there are 57 long lines.

File# lines# units# long lines
KafkaConnectorOptions.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 276 5 15
FlinkKafkaConsumerBase.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 677 29 11
AbstractFetcher.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 324 11 6
KafkaConnectorOptionsUtil.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 538 24 4
FlinkKafkaProducer.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 1262 87 3
KafkaShuffleFetcher.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 211 14 3
UpsertKafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 331 20 3
KafkaCommitter.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 105 3 3
KafkaSinkBuilder.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink
 99 9 2
KafkaConsumerThread.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals
 310 9 1
ReducingUpsertWriter.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 148 13 1
DynamicKafkaDeserializationSchema.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 179 10 1
KafkaDynamicTableFactory.java
in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table
 372 7 1
KafkaPartitionSplitReader.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader
 410 26 1
KafkaSourceOptions.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source
 40 1 1
SpecifiedOffsetsInitializer.java
in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer
 73 3 1
Correlations

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

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/KafkaConnectorOptions.java x: 5 commits (all time) y: 276 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java x: 23 commits (all time) y: 372 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java x: 5 commits (all time) y: 76 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java x: 26 commits (all time) y: 370 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java x: 1 commits (all time) y: 17 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java x: 26 commits (all time) y: 360 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java x: 6 commits (all time) y: 71 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/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java x: 13 commits (all time) y: 331 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/KafkaSource.java x: 17 commits (all time) y: 167 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/connector/kafka/source/enumerator/KafkaSourceEnumState.java x: 5 commits (all time) y: 59 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java x: 5 commits (all time) y: 128 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java x: 17 commits (all time) y: 451 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java x: 7 commits (all time) y: 194 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/HeaderProvider.java x: 1 commits (all time) y: 9 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java x: 8 commits (all time) y: 538 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java x: 11 commits (all time) y: 292 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java x: 16 commits (all time) y: 410 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java x: 6 commits (all time) y: 314 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/BoundedMode.java x: 1 commits (all time) y: 10 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java x: 19 commits (all time) y: 512 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffle.java x: 8 commits (all time) y: 135 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaConsumerThread.java x: 4 commits (all time) y: 310 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriberUtils.java x: 4 commits (all time) y: 25 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer.java x: 5 commits (all time) y: 51 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionAssigner.java x: 3 commits (all time) y: 12 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleProducer.java x: 4 commits (all time) y: 153 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchema.java x: 4 commits (all time) y: 24 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java x: 14 commits (all time) y: 211 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher/KafkaSourceFetcherManager.java x: 8 commits (all time) y: 69 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReader.java x: 14 commits (all time) y: 159 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java x: 4 commits (all time) y: 324 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricWrapper.java x: 4 commits (all time) y: 15 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java x: 4 commits (all time) y: 49 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/DefaultKafkaSinkContext.java x: 2 commits (all time) y: 45 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplit.java x: 5 commits (all time) y: 106 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java x: 10 commits (all time) y: 105 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriber.java x: 5 commits (all time) y: 21 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java x: 7 commits (all time) y: 99 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchema.java x: 5 commits (all time) y: 33 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/source/split/KafkaPartitionSplitState.java x: 3 commits (all time) y: 25 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/FlinkKafkaProducer.java x: 38 commits (all time) y: 1262 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/Recyclable.java x: 2 commits (all time) y: 25 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java x: 12 commits (all time) y: 180 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicListSubscriber.java x: 4 commits (all time) y: 33 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java x: 4 commits (all time) y: 70 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java x: 2 commits (all time) y: 35 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionAborter.java x: 1 commits (all time) y: 58 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionalIdFactory.java x: 2 commits (all time) y: 12 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionsToAbortChecker.java x: 1 commits (all time) y: 50 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java x: 2 commits (all time) y: 142 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/SourceContextWatermarkOutputAdapter.java x: 3 commits (all time) y: 22 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/PartitionSetSubscriber.java x: 3 commits (all time) y: 46 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicPatternSubscriber.java x: 3 commits (all time) y: 37 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaDeserializationSchemaWrapper.java x: 1 commits (all time) y: 32 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaValueOnlyDeserializationSchemaWrapper.java x: 1 commits (all time) y: 26 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/FlinkKafkaConsumerBase.java x: 5 commits (all time) y: 677 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaErrorCode.java x: 2 commits (all time) y: 7 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaException.java x: 2 commits (all time) y: 19 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java x: 3 commits (all time) y: 281 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractPartitionDiscoverer.java x: 2 commits (all time) y: 107 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java x: 2 commits (all time) y: 262 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/Handover.java x: 2 commits (all time) y: 86 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaFetcher.java x: 2 commits (all time) y: 159 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaPartitionDiscoverer.java x: 2 commits (all time) y: 71 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaShuffleFetcher.java x: 2 commits (all time) y: 211 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartition.java x: 2 commits (all time) y: 82 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionState.java x: 2 commits (all time) y: 58 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java x: 3 commits (all time) y: 31 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java x: 4 commits (all time) y: 63 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/StreamKafkaShuffleSink.java x: 3 commits (all time) y: 16 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java x: 5 commits (all time) y: 179 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/TypeInformationKeyValueSerializationSchema.java x: 2 commits (all time) y: 115 lines of code
1262.0
lines of code
  min: 6.0
  average: 114.55
  25th percentile: 22.5
  median: 49.0
  75th percentile: 145.0
  max: 1262.0
0 38.0
commits (all time)
min: 1.0 | average: 5.04 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 5.0 | max: 38.0

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

flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceOptions.java x: 6 contributors (all time) y: 40 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java x: 4 contributors (all time) y: 276 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java x: 14 contributors (all time) y: 372 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java x: 3 contributors (all time) y: 76 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java x: 9 contributors (all time) y: 370 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java x: 1 contributors (all time) y: 17 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java x: 14 contributors (all time) y: 360 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java x: 3 contributors (all time) y: 71 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/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java x: 10 contributors (all time) y: 331 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/KafkaSource.java x: 11 contributors (all time) y: 167 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/connector/kafka/source/enumerator/KafkaSourceEnumState.java x: 5 contributors (all time) y: 59 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java x: 5 contributors (all time) y: 128 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java x: 11 contributors (all time) y: 451 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java x: 5 contributors (all time) y: 194 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/HeaderProvider.java x: 1 contributors (all time) y: 9 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java x: 7 contributors (all time) y: 538 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java x: 4 contributors (all time) y: 292 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java x: 9 contributors (all time) y: 410 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java x: 5 contributors (all time) y: 314 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/BoundedMode.java x: 1 contributors (all time) y: 10 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java x: 12 contributors (all time) y: 512 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffle.java x: 6 contributors (all time) y: 135 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaConsumerThread.java x: 4 contributors (all time) y: 310 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriberUtils.java x: 4 contributors (all time) y: 25 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/OffsetsInitializer.java x: 5 contributors (all time) y: 51 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionAssigner.java x: 3 contributors (all time) y: 12 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleProducer.java x: 3 contributors (all time) y: 153 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchema.java x: 3 contributors (all time) y: 24 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java x: 10 contributors (all time) y: 211 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/fetcher/KafkaSourceFetcherManager.java x: 5 contributors (all time) y: 69 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReader.java x: 6 contributors (all time) y: 159 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java x: 4 contributors (all time) y: 324 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricWrapper.java x: 4 contributors (all time) y: 15 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java x: 3 contributors (all time) y: 49 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/DefaultKafkaSinkContext.java x: 2 contributors (all time) y: 45 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/split/KafkaPartitionSplit.java x: 5 contributors (all time) y: 106 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java x: 4 contributors (all time) y: 105 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriber.java x: 5 contributors (all time) y: 21 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java x: 4 contributors (all time) y: 99 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/reader/deserializer/KafkaRecordDeserializationSchema.java x: 3 contributors (all time) y: 33 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/MetricUtil.java x: 2 contributors (all time) y: 33 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java x: 25 contributors (all time) y: 1262 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/Recyclable.java x: 1 contributors (all time) y: 25 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java x: 11 contributors (all time) y: 180 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicListSubscriber.java x: 4 contributors (all time) y: 33 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java x: 2 contributors (all time) y: 70 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java x: 2 contributors (all time) y: 35 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionAborter.java x: 1 contributors (all time) y: 58 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionalIdFactory.java x: 2 contributors (all time) y: 12 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TransactionsToAbortChecker.java x: 1 contributors (all time) y: 50 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java x: 1 contributors (all time) y: 142 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicPatternSubscriber.java x: 3 contributors (all time) y: 37 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaDeserializationSchemaWrapper.java x: 1 contributors (all time) y: 32 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/FlinkKafkaConsumerBase.java x: 5 contributors (all time) y: 677 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaErrorCode.java x: 2 contributors (all time) y: 7 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaException.java x: 2 contributors (all time) y: 19 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java x: 3 contributors (all time) y: 281 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractPartitionDiscoverer.java x: 2 contributors (all time) y: 107 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java x: 2 contributors (all time) y: 262 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/Handover.java x: 2 contributors (all time) y: 86 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaFetcher.java x: 2 contributors (all time) y: 159 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaShuffleFetcher.java x: 2 contributors (all time) y: 211 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartition.java x: 2 contributors (all time) y: 82 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionState.java x: 2 contributors (all time) y: 58 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KeyedSerializationSchemaWrapper.java x: 2 contributors (all time) y: 27 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java x: 3 contributors (all time) y: 63 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaDeserializationSchema.java x: 3 contributors (all time) y: 179 lines of code flink-connector-kafka/src/main/java/org/apache/flink/streaming/util/serialization/TypeInformationKeyValueSerializationSchema.java x: 2 contributors (all time) y: 115 lines of code
1262.0
lines of code
  min: 6.0
  average: 114.55
  25th percentile: 22.5
  median: 49.0
  75th percentile: 145.0
  max: 1262.0
0 25.0
contributors (all time)
min: 1.0 | average: 3.73 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 4.0 | max: 25.0

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

flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/SpecifiedOffsetsInitializer.java x: 1 commits (30d) y: 73 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/TimestampOffsetsInitializer.java x: 1 commits (30d) y: 37 lines of code
73.0
lines of code
  min: 37.0
  average: 55.0
  25th percentile: 37.0
  median: 55.0
  75th percentile: 73.0
  max: 73.0
0 1.0
commits (30d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

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

flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/SpecifiedOffsetsInitializer.java x: 1 contributors (30d) y: 73 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/TimestampOffsetsInitializer.java x: 1 contributors (30d) y: 37 lines of code
73.0
lines of code
  min: 37.0
  average: 55.0
  25th percentile: 37.0
  median: 55.0
  75th percentile: 73.0
  max: 73.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): 2 points

flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/SpecifiedOffsetsInitializer.java x: 1 commits (90d) y: 73 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/TimestampOffsetsInitializer.java x: 1 commits (90d) y: 37 lines of code
73.0
lines of code
  min: 37.0
  average: 55.0
  25th percentile: 37.0
  median: 55.0
  75th percentile: 73.0
  max: 73.0
0 1.0
commits (90d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

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

flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/SpecifiedOffsetsInitializer.java x: 1 contributors (90d) y: 73 lines of code flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/TimestampOffsetsInitializer.java x: 1 contributors (90d) y: 37 lines of code
73.0
lines of code
  min: 37.0
  average: 55.0
  25th percentile: 37.0
  median: 55.0
  75th percentile: 73.0
  max: 73.0
0 1.0
contributors (90d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0