apache / rocketmq-flink
File Size

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

Intro
Learn more...
File Size Overall
0% | 19% | 22% | 27% | 30%
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% | 19% | 23% | 26% | 30%
xml0% | 0% | 0% | 51% | 48%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
src0% | 19% | 23% | 26% | 30%
style0% | 0% | 0% | 51% | 48%
Longest Files (Top 50)
File# lines# units
RocketMQSourceEnumerator.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator
587 27
RocketMQSourceFunction.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
543 19
RowDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
526 30
InnerConsumerImpl.java
in src/main/java/org/apache/flink/connector/rocketmq/source
421 23
RocketMQCatalog.java
in src/main/java/org/apache/flink/connector/rocketmq/catalog
416 41
RowKeyValueDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
351 18
RocketMQSplitReader.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
261 16
InnerProducerImpl.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
258 10
RocketMQDynamicTableSink.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
256 13
RocketMQSourceReader.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
199 10
RocketMQScanTableSource.java
in src/main/java/org/apache/flink/connector/rocketmq/source/table
196 12
RocketMQSink.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
187 12
RocketMQRowDataConverter.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
178 4
RocketMQDynamicTableSourceFactory.java
in src/main/java/org/apache/flink/connector/rocketmq/source/table
156 3
140 -
RocketMQSource.java
in src/main/java/org/apache/flink/connector/rocketmq/source
136 9
RocketMQSourceOptions.java
in src/main/java/org/apache/flink/connector/rocketmq/source
133 -
ByteSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/util
128 4
RocketMQSourceSplit.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
127 17
StringSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/util
123 4
MessageViewExt.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
123 14
RocketMQConfig.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
115 4
RocketMQOptions.java
in src/main/java/org/apache/flink/connector/rocketmq/common/config
109 -
RocketMQDynamicTableSinkFactory.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
108 2
SendCommittable.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/committer
106 19
RocketMQWriter.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/writer
102 6
RocketMQSourceBuilder.java
in src/main/java/org/apache/flink/connector/rocketmq/source
98 16
ByteUtils.java
in src/main/java/org/apache/flink/connector/rocketmq/source/util
97 15
RocketMQConfigBuilder.java
in src/main/java/org/apache/flink/connector/rocketmq/common/config
84 8
79 -
RocketMQCommitter.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/committer
76 5
RocketMQSinkBuilder.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
73 12
MetricUtils.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util
72 8
RocketMQSinkOptions.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
72 -
RocketMQRowDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
70 6
RocketMQSourceEnumStateSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator
66 3
RocketMQSourceFetcherManager.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
60 4
RocketMQConfigValidator.java
in src/main/java/org/apache/flink/connector/rocketmq/common/config
59 6
OffsetsSelectorBySpecified.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset
56 3
RocketMQConfiguration.java
in src/main/java/org/apache/flink/connector/rocketmq/common/config
54 5
RocketMQUtils.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util
52 6
RetryUtil.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util
48 4
OffsetsSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset
48 8
RocketMQPartitionSplitSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
48 2
profiles_settings.xml
in style/copyright
47 -
SimpleTopicSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector
44 3
SendCommittableSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/committer
44 2
RocketMQRecordEmitter.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
44 6
RocketMQSink.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
42 4
BoundedOutOfOrdernessGeneratorPerQueue.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark
41 5
Files With Most Units (Top 50)
File# lines# units
RocketMQCatalog.java
in src/main/java/org/apache/flink/connector/rocketmq/catalog
416 41
RowDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
526 30
RocketMQSourceEnumerator.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator
587 27
InnerConsumerImpl.java
in src/main/java/org/apache/flink/connector/rocketmq/source
421 23
RocketMQSourceFunction.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
543 19
SendCommittable.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/committer
106 19
RowKeyValueDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
351 18
RocketMQSourceSplit.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
127 17
RocketMQSourceBuilder.java
in src/main/java/org/apache/flink/connector/rocketmq/source
98 16
RocketMQSplitReader.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
261 16
ByteUtils.java
in src/main/java/org/apache/flink/connector/rocketmq/source/util
97 15
MessageViewExt.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
123 14
RocketMQDynamicTableSink.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
256 13
RocketMQSink.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
187 12
RocketMQSinkBuilder.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
73 12
RocketMQScanTableSource.java
in src/main/java/org/apache/flink/connector/rocketmq/source/table
196 12
InnerProducerImpl.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
258 10
RocketMQSourceReader.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
199 10
RocketMQSource.java
in src/main/java/org/apache/flink/connector/rocketmq/source
136 9
MetricUtils.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util
72 8
RocketMQConfigBuilder.java
in src/main/java/org/apache/flink/connector/rocketmq/common/config
84 8
SourceReportOffsetEvent.java
in src/main/java/org/apache/flink/connector/rocketmq/common/event
32 8
OffsetsSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset
48 8
RocketMQUtils.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util
52 6
RocketMQConfigValidator.java
in src/main/java/org/apache/flink/connector/rocketmq/common/config
59 6
RocketMQSinkContextImpl.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/writer/context
41 6
RocketMQWriter.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/writer
102 6
RocketMQRecordEmitter.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
44 6
RocketMQRowDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
70 6
BoundedOutOfOrdernessGenerator.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark
31 5
BoundedOutOfOrdernessGeneratorPerQueue.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark
41 5
WaterMarkPerQueue.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark
35 5
RocketMQConfiguration.java
in src/main/java/org/apache/flink/connector/rocketmq/common/config
54 5
RocketMQCommitter.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/committer
76 5
RocketMQRowDataSink.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
36 5
BytesMessage.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
25 5
RetryUtil.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util
48 4
DefaultTopicSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector
20 4
WaterMarkForAll.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark
16 4
RocketMQConfig.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
115 4
RocketMQSink.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
42 4
RocketMQRowDataConverter.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
178 4
ByteSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/util
128 4
StringSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/util
123 4
RocketMQSourceSplitState.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
28 4
RocketMQDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
27 4
RocketMQSourceFetcherManager.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
60 4
SimpleTopicSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector
44 3
SimpleKeyValueDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
37 3
TimeLagWatermarkGenerator.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark
23 3
Files With Long Lines (Top 5)

There are 5 files with lines longer than 120 characters. In total, there are 9 long lines.

File# lines# units# long lines
InnerConsumerImpl.java
in src/main/java/org/apache/flink/connector/rocketmq/source
421 23 4
RowKeyValueDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
351 18 2
79 - 1
Apache.xml
in style/copyright
7 - 1
RocketMQDynamicTableSinkFactory.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
108 2 1
Correlations

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

src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java x: 1 commits (all time) y: 14 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java x: 1 commits (all time) y: 11 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java x: 1 commits (all time) y: 13 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java x: 1 commits (all time) y: 32 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java x: 3 commits (all time) y: 543 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java x: 3 commits (all time) y: 421 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java x: 2 commits (all time) y: 136 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java x: 3 commits (all time) y: 66 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java x: 3 commits (all time) y: 587 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategy.java x: 2 commits (all time) y: 16 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java x: 2 commits (all time) y: 32 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategy.java x: 1 commits (all time) y: 33 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java x: 2 commits (all time) y: 27 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java x: 2 commits (all time) y: 33 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java x: 2 commits (all time) y: 24 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java x: 2 commits (all time) y: 60 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java x: 2 commits (all time) y: 199 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java x: 3 commits (all time) y: 261 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java x: 2 commits (all time) y: 48 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java x: 2 commits (all time) y: 127 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplitState.java x: 2 commits (all time) y: 28 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java x: 2 commits (all time) y: 187 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java x: 2 commits (all time) y: 256 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java x: 2 commits (all time) y: 108 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java x: 2 commits (all time) y: 133 lines of code src/main/java/org/apache/flink/connector/rocketmq/MetricUtil.java x: 1 commits (all time) y: 2 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalog.java x: 1 commits (all time) y: 416 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactory.java x: 1 commits (all time) y: 41 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactoryOptions.java x: 1 commits (all time) y: 26 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigBuilder.java x: 1 commits (all time) y: 84 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigValidator.java x: 1 commits (all time) y: 59 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfiguration.java x: 1 commits (all time) y: 54 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQOptions.java x: 1 commits (all time) y: 109 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/constant/RocketMqCatalogConstant.java x: 1 commits (all time) y: 7 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/constant/SchemaRegistryConstant.java x: 1 commits (all time) y: 5 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQConfig.java x: 1 commits (all time) y: 115 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/DefaultTopicSelector.java x: 1 commits (all time) y: 20 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/MessageQueueSelector.java x: 1 commits (all time) y: 4 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/SimpleTopicSelector.java x: 1 commits (all time) y: 44 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java x: 1 commits (all time) y: 351 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueDeserializationSchema.java x: 1 commits (all time) y: 37 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleTupleDeserializationSchema.java x: 1 commits (all time) y: 18 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/MetricUtils.java x: 1 commits (all time) y: 72 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtil.java x: 1 commits (all time) y: 48 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RocketMQUtils.java x: 1 commits (all time) y: 52 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/TimeLagWatermarkGenerator.java x: 1 commits (all time) y: 23 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkPerQueue.java x: 1 commits (all time) y: 35 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java x: 1 commits (all time) y: 258 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSink.java x: 1 commits (all time) y: 42 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/committer/RocketMQCommitter.java x: 1 commits (all time) y: 76 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittable.java x: 1 commits (all time) y: 106 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataConverter.java x: 1 commits (all time) y: 178 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java x: 1 commits (all time) y: 102 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceBuilder.java x: 1 commits (all time) y: 98 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorBySpecified.java x: 1 commits (all time) y: 56 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java x: 1 commits (all time) y: 123 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/BytesMessage.java x: 1 commits (all time) y: 25 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQRowDeserializationSchema.java x: 1 commits (all time) y: 70 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java x: 1 commits (all time) y: 526 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactory.java x: 1 commits (all time) y: 156 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQScanTableSource.java x: 1 commits (all time) y: 196 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java x: 1 commits (all time) y: 128 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteUtils.java x: 1 commits (all time) y: 97 lines of code style/rmq_checkstyle.xml x: 4 commits (all time) y: 79 lines of code style/rmq_codeStyle.xml x: 1 commits (all time) y: 140 lines of code
587.0
lines of code
  min: 2.0
  average: 75.89
  25th percentile: 14.0
  median: 34.0
  75th percentile: 87.25
  max: 587.0
0 4.0
commits (all time)
min: 1.0 | average: 1.25 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 4.0

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

src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java x: 1 contributors (all time) y: 14 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java x: 1 contributors (all time) y: 11 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java x: 1 contributors (all time) y: 13 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java x: 1 contributors (all time) y: 32 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java x: 3 contributors (all time) y: 543 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java x: 3 contributors (all time) y: 421 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java x: 2 contributors (all time) y: 136 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java x: 3 contributors (all time) y: 66 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java x: 3 contributors (all time) y: 587 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategy.java x: 2 contributors (all time) y: 16 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java x: 2 contributors (all time) y: 32 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategy.java x: 1 contributors (all time) y: 33 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java x: 2 contributors (all time) y: 27 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java x: 2 contributors (all time) y: 33 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java x: 2 contributors (all time) y: 24 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java x: 2 contributors (all time) y: 60 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java x: 2 contributors (all time) y: 199 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java x: 3 contributors (all time) y: 261 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java x: 2 contributors (all time) y: 48 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java x: 2 contributors (all time) y: 127 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplitState.java x: 2 contributors (all time) y: 28 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java x: 2 contributors (all time) y: 187 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java x: 2 contributors (all time) y: 256 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java x: 2 contributors (all time) y: 108 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java x: 2 contributors (all time) y: 133 lines of code src/main/java/org/apache/flink/connector/rocketmq/MetricUtil.java x: 1 contributors (all time) y: 2 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalog.java x: 1 contributors (all time) y: 416 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactory.java x: 1 contributors (all time) y: 41 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactoryOptions.java x: 1 contributors (all time) y: 26 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigBuilder.java x: 1 contributors (all time) y: 84 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigValidator.java x: 1 contributors (all time) y: 59 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfiguration.java x: 1 contributors (all time) y: 54 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQOptions.java x: 1 contributors (all time) y: 109 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/constant/RocketMqCatalogConstant.java x: 1 contributors (all time) y: 7 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/constant/SchemaRegistryConstant.java x: 1 contributors (all time) y: 5 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQConfig.java x: 1 contributors (all time) y: 115 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/DefaultTopicSelector.java x: 1 contributors (all time) y: 20 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/MessageQueueSelector.java x: 1 contributors (all time) y: 4 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/SimpleTopicSelector.java x: 1 contributors (all time) y: 44 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java x: 1 contributors (all time) y: 351 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueDeserializationSchema.java x: 1 contributors (all time) y: 37 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleTupleDeserializationSchema.java x: 1 contributors (all time) y: 18 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/MetricUtils.java x: 1 contributors (all time) y: 72 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtil.java x: 1 contributors (all time) y: 48 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RocketMQUtils.java x: 1 contributors (all time) y: 52 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/TimeLagWatermarkGenerator.java x: 1 contributors (all time) y: 23 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkPerQueue.java x: 1 contributors (all time) y: 35 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java x: 1 contributors (all time) y: 258 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSink.java x: 1 contributors (all time) y: 42 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/committer/RocketMQCommitter.java x: 1 contributors (all time) y: 76 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittable.java x: 1 contributors (all time) y: 106 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataConverter.java x: 1 contributors (all time) y: 178 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java x: 1 contributors (all time) y: 102 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceBuilder.java x: 1 contributors (all time) y: 98 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorBySpecified.java x: 1 contributors (all time) y: 56 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java x: 1 contributors (all time) y: 123 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/BytesMessage.java x: 1 contributors (all time) y: 25 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQRowDeserializationSchema.java x: 1 contributors (all time) y: 70 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java x: 1 contributors (all time) y: 526 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactory.java x: 1 contributors (all time) y: 156 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQScanTableSource.java x: 1 contributors (all time) y: 196 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java x: 1 contributors (all time) y: 128 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteUtils.java x: 1 contributors (all time) y: 97 lines of code style/rmq_checkstyle.xml x: 3 contributors (all time) y: 79 lines of code style/rmq_codeStyle.xml x: 1 contributors (all time) y: 140 lines of code
587.0
lines of code
  min: 2.0
  average: 75.89
  25th percentile: 14.0
  median: 34.0
  75th percentile: 87.25
  max: 587.0
0 3.0
contributors (all time)
min: 1.0 | average: 1.24 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 3.0

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

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

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

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


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

src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java x: 1 commits (90d) y: 14 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java x: 1 commits (90d) y: 11 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java x: 1 commits (90d) y: 13 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java x: 1 commits (90d) y: 32 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java x: 1 commits (90d) y: 543 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java x: 1 commits (90d) y: 421 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java x: 1 commits (90d) y: 136 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java x: 1 commits (90d) y: 66 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java x: 1 commits (90d) y: 587 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategy.java x: 1 commits (90d) y: 33 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java x: 1 commits (90d) y: 27 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java x: 1 commits (90d) y: 24 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java x: 1 commits (90d) y: 60 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java x: 1 commits (90d) y: 199 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java x: 1 commits (90d) y: 261 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java x: 1 commits (90d) y: 48 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java x: 1 commits (90d) y: 127 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplitState.java x: 1 commits (90d) y: 28 lines of code
587.0
lines of code
  min: 11.0
  average: 123.86
  25th percentile: 22.0
  median: 33.0
  75th percentile: 151.75
  max: 587.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): 22 points

src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java x: 1 contributors (90d) y: 14 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java x: 1 contributors (90d) y: 11 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java x: 1 contributors (90d) y: 13 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java x: 1 contributors (90d) y: 32 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java x: 1 contributors (90d) y: 543 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java x: 1 contributors (90d) y: 421 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java x: 1 contributors (90d) y: 136 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java x: 1 contributors (90d) y: 66 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java x: 1 contributors (90d) y: 587 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategy.java x: 1 contributors (90d) y: 33 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java x: 1 contributors (90d) y: 27 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java x: 1 contributors (90d) y: 24 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java x: 1 contributors (90d) y: 60 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java x: 1 contributors (90d) y: 199 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java x: 1 contributors (90d) y: 261 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java x: 1 contributors (90d) y: 48 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java x: 1 contributors (90d) y: 127 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplitState.java x: 1 contributors (90d) y: 28 lines of code
587.0
lines of code
  min: 11.0
  average: 123.86
  25th percentile: 22.0
  median: 33.0
  75th percentile: 151.75
  max: 587.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