apache / rocketmq-flink
File Size

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

Intro
Learn more...
File Size Overall
0% | 13% | 27% | 25% | 33%
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% | 13% | 28% | 24% | 33%
xml0% | 0% | 0% | 51% | 48%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
src0% | 13% | 28% | 24% | 33%
style0% | 0% | 0% | 51% | 48%
Longest Files (Top 50)
File# lines# units
RocketMQSourceFunction.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
 531 19
RowDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
 526 30
RocketMQCatalog.java
in src/main/java/org/apache/flink/connector/rocketmq/catalog
 416 41
InnerConsumerImpl.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 414 23
RowKeyValueDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 351 18
RocketMQSourceEnumerator.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator
 310 23
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
 255 13
RocketMQSplitReader.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 214 14
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
 185 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
 135 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
MessageViewExt.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 123 14
StringSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/util
 123 4
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 -
RocketMQSourceReader.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 108 7
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
RocketMQDynamicTableSinkFactory.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
 100 2
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 -
RocketMQSourceSplit.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
 78 12
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
RocketMQSinkOptions.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
 72 -
MetricUtils.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util
 72 8
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
RocketMQConfigValidator.java
in src/main/java/org/apache/flink/connector/rocketmq/common/config
 59 6
RocketMQSourceFetcherManager.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 57 3
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
OffsetsSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset
 48 8
RetryUtil.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util
 48 4
profiles_settings.xml
in style/copyright
 47 -
RocketMQRecordEmitter.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 44 6
SendCommittableSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/committer
 44 2
SimpleTopicSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector
 44 3
RocketMQPartitionSplitSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
 42 2
RocketMQSink.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
 42 4
RocketMQCatalogFactory.java
in src/main/java/org/apache/flink/connector/rocketmq/catalog
 41 2
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
InnerConsumerImpl.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 414 23
RocketMQSourceEnumerator.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator
 310 23
SendCommittable.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/committer
 106 19
RocketMQSourceFunction.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
 531 19
RowKeyValueDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 351 18
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
RocketMQSplitReader.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 214 14
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
 255 13
RocketMQSourceSplit.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
 78 12
RocketMQScanTableSource.java
in src/main/java/org/apache/flink/connector/rocketmq/source/table
 196 12
RocketMQSinkBuilder.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
 73 12
RocketMQSink.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
 185 12
InnerProducerImpl.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
 258 10
RocketMQSource.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 135 9
OffsetsSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset
 48 8
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
RocketMQSourceReader.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 108 7
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
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
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
BytesMessage.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
 25 5
RocketMQRowDataSink.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
 36 5
RocketMQCommitter.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/committer
 76 5
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
RocketMQDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
 27 4
RocketMQSourceSplitState.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
 23 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
RocketMQRowDataConverter.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
 178 4
RocketMQSink.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
 42 4
RocketMQConfig.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
 115 4
DefaultTopicSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector
 20 4
RetryUtil.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util
 48 4
WaterMarkForAll.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark
 16 4
RocketMQDeserializationSchemaWrapper.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
 25 3
RocketMQSourceFetcherManager.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 57 3
UtilAll.java
in src/main/java/org/apache/flink/connector/rocketmq/source/util
 17 3
RocketMQDynamicTableSourceFactory.java
in src/main/java/org/apache/flink/connector/rocketmq/source/table
 156 3
OffsetsSelectorByStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset
 36 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
 414 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
 100 2 1
Correlations

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

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/RocketMQSink.java x: 1 commits (all time) y: 185 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java x: 1 commits (all time) y: 531 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RunningChecker.java x: 1 commits (all time) y: 11 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/HashMessageQueueSelector.java x: 1 commits (all time) y: 14 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/SimpleKeyValueSerializationSchema.java x: 1 commits (all time) y: 32 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleStringDeserializationSchema.java x: 1 commits (all time) y: 15 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/BoundedOutOfOrdernessGenerator.java x: 1 commits (all time) y: 31 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/RocketMQDynamicTableSink.java x: 1 commits (all time) y: 255 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java x: 1 commits (all time) y: 100 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/RocketMQSource.java x: 1 commits (all time) y: 135 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/RocketMQSourceOptions.java x: 1 commits (all time) y: 133 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/config/OffsetVerification.java x: 1 commits (all time) y: 21 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java x: 1 commits (all time) y: 66 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java x: 1 commits (all time) y: 310 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java x: 1 commits (all time) y: 29 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/RocketMQSourceFetcherManager.java x: 1 commits (all time) y: 57 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java x: 1 commits (all time) y: 108 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java x: 1 commits (all time) y: 214 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/DirtyDataStrategy.java x: 1 commits (all time) y: 9 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/split/RocketMQSourceSplit.java x: 1 commits (all time) y: 78 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 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
531.0
lines of code
  min: 2.0
  average: 74.14
  25th percentile: 14.25
  median: 36.0
  75th percentile: 93.75
  max: 531.0
0 4.0
commits (all time)
min: 1.0 | average: 1.03 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 4.0

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

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/RocketMQSink.java x: 1 contributors (all time) y: 185 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java x: 1 contributors (all time) y: 531 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RunningChecker.java x: 1 contributors (all time) y: 11 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/HashMessageQueueSelector.java x: 1 contributors (all time) y: 14 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/SimpleKeyValueSerializationSchema.java x: 1 contributors (all time) y: 32 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleStringDeserializationSchema.java x: 1 contributors (all time) y: 15 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/BoundedOutOfOrdernessGenerator.java x: 1 contributors (all time) y: 31 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/RocketMQDynamicTableSink.java x: 1 contributors (all time) y: 255 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java x: 1 contributors (all time) y: 100 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/RocketMQSource.java x: 1 contributors (all time) y: 135 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/RocketMQSourceOptions.java x: 1 contributors (all time) y: 133 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/config/OffsetVerification.java x: 1 contributors (all time) y: 21 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java x: 1 contributors (all time) y: 66 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java x: 1 contributors (all time) y: 310 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java x: 1 contributors (all time) y: 29 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/RocketMQSourceFetcherManager.java x: 1 contributors (all time) y: 57 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java x: 1 contributors (all time) y: 108 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java x: 1 contributors (all time) y: 214 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/DirtyDataStrategy.java x: 1 contributors (all time) y: 9 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/split/RocketMQSourceSplit.java x: 1 contributors (all time) y: 78 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 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
531.0
lines of code
  min: 2.0
  average: 74.14
  25th percentile: 14.25
  median: 36.0
  75th percentile: 93.75
  max: 531.0
0 3.0
contributors (all time)
min: 1.0 | average: 1.02 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 3.0

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

src/main/java/org/apache/flink/connector/rocketmq/MetricUtil.java x: 1 commits (30d) y: 2 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalog.java x: 1 commits (30d) y: 416 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactory.java x: 1 commits (30d) y: 41 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactoryOptions.java x: 1 commits (30d) y: 26 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigBuilder.java x: 1 commits (30d) y: 84 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigValidator.java x: 1 commits (30d) y: 59 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfiguration.java x: 1 commits (30d) y: 54 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQOptions.java x: 1 commits (30d) y: 109 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/constant/RocketMqCatalogConstant.java x: 1 commits (30d) y: 7 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/constant/SchemaRegistryConstant.java x: 1 commits (30d) y: 5 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQConfig.java x: 1 commits (30d) y: 115 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java x: 1 commits (30d) y: 185 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java x: 1 commits (30d) y: 531 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RunningChecker.java x: 1 commits (30d) y: 11 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/DefaultTopicSelector.java x: 1 commits (30d) y: 20 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/HashMessageQueueSelector.java x: 1 commits (30d) y: 14 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/MessageQueueSelector.java x: 1 commits (30d) y: 4 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/SimpleTopicSelector.java x: 1 commits (30d) y: 44 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java x: 1 commits (30d) y: 351 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueDeserializationSchema.java x: 1 commits (30d) y: 37 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueSerializationSchema.java x: 1 commits (30d) y: 32 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleStringDeserializationSchema.java x: 1 commits (30d) y: 15 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleTupleDeserializationSchema.java x: 1 commits (30d) y: 18 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/MetricUtils.java x: 1 commits (30d) y: 72 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtil.java x: 1 commits (30d) y: 48 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RocketMQUtils.java x: 1 commits (30d) y: 52 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/BoundedOutOfOrdernessGenerator.java x: 1 commits (30d) y: 31 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/TimeLagWatermarkGenerator.java x: 1 commits (30d) y: 23 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkPerQueue.java x: 1 commits (30d) y: 35 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java x: 1 commits (30d) y: 258 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSink.java x: 1 commits (30d) y: 42 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/committer/RocketMQCommitter.java x: 1 commits (30d) y: 76 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittable.java x: 1 commits (30d) y: 106 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java x: 1 commits (30d) y: 255 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java x: 1 commits (30d) y: 100 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataConverter.java x: 1 commits (30d) y: 178 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java x: 1 commits (30d) y: 102 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java x: 1 commits (30d) y: 135 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceBuilder.java x: 1 commits (30d) y: 98 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java x: 1 commits (30d) y: 133 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/config/OffsetVerification.java x: 1 commits (30d) y: 21 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java x: 1 commits (30d) y: 66 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java x: 1 commits (30d) y: 310 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java x: 1 commits (30d) y: 29 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorBySpecified.java x: 1 commits (30d) y: 56 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java x: 1 commits (30d) y: 123 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java x: 1 commits (30d) y: 57 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java x: 1 commits (30d) y: 108 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java x: 1 commits (30d) y: 214 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/DirtyDataStrategy.java x: 1 commits (30d) y: 9 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQRowDeserializationSchema.java x: 1 commits (30d) y: 70 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java x: 1 commits (30d) y: 526 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java x: 1 commits (30d) y: 78 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactory.java x: 1 commits (30d) y: 156 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQScanTableSource.java x: 1 commits (30d) y: 196 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java x: 1 commits (30d) y: 128 lines of code
531.0
lines of code
  min: 2.0
  average: 74.37
  25th percentile: 14.25
  median: 36.0
  75th percentile: 93.75
  max: 531.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): 104 points

src/main/java/org/apache/flink/connector/rocketmq/MetricUtil.java x: 1 contributors (30d) y: 2 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalog.java x: 1 contributors (30d) y: 416 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactory.java x: 1 contributors (30d) y: 41 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactoryOptions.java x: 1 contributors (30d) y: 26 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigBuilder.java x: 1 contributors (30d) y: 84 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigValidator.java x: 1 contributors (30d) y: 59 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfiguration.java x: 1 contributors (30d) y: 54 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQOptions.java x: 1 contributors (30d) y: 109 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/constant/RocketMqCatalogConstant.java x: 1 contributors (30d) y: 7 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/constant/SchemaRegistryConstant.java x: 1 contributors (30d) y: 5 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQConfig.java x: 1 contributors (30d) y: 115 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java x: 1 contributors (30d) y: 185 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java x: 1 contributors (30d) y: 531 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RunningChecker.java x: 1 contributors (30d) y: 11 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/DefaultTopicSelector.java x: 1 contributors (30d) y: 20 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/HashMessageQueueSelector.java x: 1 contributors (30d) y: 14 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/MessageQueueSelector.java x: 1 contributors (30d) y: 4 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/SimpleTopicSelector.java x: 1 contributors (30d) y: 44 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java x: 1 contributors (30d) y: 351 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueDeserializationSchema.java x: 1 contributors (30d) y: 37 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueSerializationSchema.java x: 1 contributors (30d) y: 32 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleStringDeserializationSchema.java x: 1 contributors (30d) y: 15 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleTupleDeserializationSchema.java x: 1 contributors (30d) y: 18 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/MetricUtils.java x: 1 contributors (30d) y: 72 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtil.java x: 1 contributors (30d) y: 48 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RocketMQUtils.java x: 1 contributors (30d) y: 52 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/BoundedOutOfOrdernessGenerator.java x: 1 contributors (30d) y: 31 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/TimeLagWatermarkGenerator.java x: 1 contributors (30d) y: 23 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkPerQueue.java x: 1 contributors (30d) y: 35 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java x: 1 contributors (30d) y: 258 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSink.java x: 1 contributors (30d) y: 42 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/committer/RocketMQCommitter.java x: 1 contributors (30d) y: 76 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittable.java x: 1 contributors (30d) y: 106 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java x: 1 contributors (30d) y: 255 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java x: 1 contributors (30d) y: 100 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataConverter.java x: 1 contributors (30d) y: 178 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java x: 1 contributors (30d) y: 102 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java x: 1 contributors (30d) y: 135 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceBuilder.java x: 1 contributors (30d) y: 98 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java x: 1 contributors (30d) y: 133 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/config/OffsetVerification.java x: 1 contributors (30d) y: 21 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java x: 1 contributors (30d) y: 66 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java x: 1 contributors (30d) y: 310 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java x: 1 contributors (30d) y: 29 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorBySpecified.java x: 1 contributors (30d) y: 56 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java x: 1 contributors (30d) y: 123 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java x: 1 contributors (30d) y: 57 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java x: 1 contributors (30d) y: 108 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java x: 1 contributors (30d) y: 214 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/DirtyDataStrategy.java x: 1 contributors (30d) y: 9 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQRowDeserializationSchema.java x: 1 contributors (30d) y: 70 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java x: 1 contributors (30d) y: 526 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java x: 1 contributors (30d) y: 78 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactory.java x: 1 contributors (30d) y: 156 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQScanTableSource.java x: 1 contributors (30d) y: 196 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java x: 1 contributors (30d) y: 128 lines of code
531.0
lines of code
  min: 2.0
  average: 74.37
  25th percentile: 14.25
  median: 36.0
  75th percentile: 93.75
  max: 531.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): 104 points

src/main/java/org/apache/flink/connector/rocketmq/MetricUtil.java x: 1 commits (90d) y: 2 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalog.java x: 1 commits (90d) y: 416 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactory.java x: 1 commits (90d) y: 41 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactoryOptions.java x: 1 commits (90d) y: 26 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigBuilder.java x: 1 commits (90d) y: 84 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigValidator.java x: 1 commits (90d) y: 59 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfiguration.java x: 1 commits (90d) y: 54 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQOptions.java x: 1 commits (90d) y: 109 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/constant/RocketMqCatalogConstant.java x: 1 commits (90d) y: 7 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/constant/SchemaRegistryConstant.java x: 1 commits (90d) y: 5 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQConfig.java x: 1 commits (90d) y: 115 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java x: 1 commits (90d) y: 185 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java x: 1 commits (90d) y: 531 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RunningChecker.java x: 1 commits (90d) y: 11 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/DefaultTopicSelector.java x: 1 commits (90d) y: 20 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/HashMessageQueueSelector.java x: 1 commits (90d) y: 14 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/MessageQueueSelector.java x: 1 commits (90d) y: 4 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/SimpleTopicSelector.java x: 1 commits (90d) y: 44 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java x: 1 commits (90d) y: 351 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueDeserializationSchema.java x: 1 commits (90d) y: 37 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueSerializationSchema.java x: 1 commits (90d) y: 32 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleStringDeserializationSchema.java x: 1 commits (90d) y: 15 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleTupleDeserializationSchema.java x: 1 commits (90d) y: 18 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/MetricUtils.java x: 1 commits (90d) y: 72 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtil.java x: 1 commits (90d) y: 48 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RocketMQUtils.java x: 1 commits (90d) y: 52 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/BoundedOutOfOrdernessGenerator.java x: 1 commits (90d) y: 31 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/TimeLagWatermarkGenerator.java x: 1 commits (90d) y: 23 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkPerQueue.java x: 1 commits (90d) y: 35 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java x: 1 commits (90d) y: 258 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSink.java x: 1 commits (90d) y: 42 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/committer/RocketMQCommitter.java x: 1 commits (90d) y: 76 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittable.java x: 1 commits (90d) y: 106 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java x: 1 commits (90d) y: 255 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java x: 1 commits (90d) y: 100 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataConverter.java x: 1 commits (90d) y: 178 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java x: 1 commits (90d) y: 102 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java x: 1 commits (90d) y: 135 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceBuilder.java x: 1 commits (90d) y: 98 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java x: 1 commits (90d) y: 133 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/config/OffsetVerification.java x: 1 commits (90d) y: 21 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: 310 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java x: 1 commits (90d) y: 29 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorBySpecified.java x: 1 commits (90d) y: 56 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java x: 1 commits (90d) y: 123 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java x: 1 commits (90d) y: 57 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java x: 1 commits (90d) y: 108 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java x: 1 commits (90d) y: 214 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/DirtyDataStrategy.java x: 1 commits (90d) y: 9 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQRowDeserializationSchema.java x: 1 commits (90d) y: 70 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java x: 1 commits (90d) y: 526 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java x: 1 commits (90d) y: 78 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactory.java x: 1 commits (90d) y: 156 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQScanTableSource.java x: 1 commits (90d) y: 196 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java x: 1 commits (90d) y: 128 lines of code
531.0
lines of code
  min: 2.0
  average: 74.37
  25th percentile: 14.25
  median: 36.0
  75th percentile: 93.75
  max: 531.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): 104 points

src/main/java/org/apache/flink/connector/rocketmq/MetricUtil.java x: 1 contributors (90d) y: 2 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalog.java x: 1 contributors (90d) y: 416 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactory.java x: 1 contributors (90d) y: 41 lines of code src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactoryOptions.java x: 1 contributors (90d) y: 26 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigBuilder.java x: 1 contributors (90d) y: 84 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigValidator.java x: 1 contributors (90d) y: 59 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfiguration.java x: 1 contributors (90d) y: 54 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQOptions.java x: 1 contributors (90d) y: 109 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/constant/RocketMqCatalogConstant.java x: 1 contributors (90d) y: 7 lines of code src/main/java/org/apache/flink/connector/rocketmq/common/constant/SchemaRegistryConstant.java x: 1 contributors (90d) y: 5 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQConfig.java x: 1 contributors (90d) y: 115 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java x: 1 contributors (90d) y: 185 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java x: 1 contributors (90d) y: 531 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/RunningChecker.java x: 1 contributors (90d) y: 11 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/DefaultTopicSelector.java x: 1 contributors (90d) y: 20 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/HashMessageQueueSelector.java x: 1 contributors (90d) y: 14 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/MessageQueueSelector.java x: 1 contributors (90d) y: 4 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/SimpleTopicSelector.java x: 1 contributors (90d) y: 44 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java x: 1 contributors (90d) y: 351 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueDeserializationSchema.java x: 1 contributors (90d) y: 37 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueSerializationSchema.java x: 1 contributors (90d) y: 32 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleStringDeserializationSchema.java x: 1 contributors (90d) y: 15 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleTupleDeserializationSchema.java x: 1 contributors (90d) y: 18 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/MetricUtils.java x: 1 contributors (90d) y: 72 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtil.java x: 1 contributors (90d) y: 48 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RocketMQUtils.java x: 1 contributors (90d) y: 52 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/BoundedOutOfOrdernessGenerator.java x: 1 contributors (90d) y: 31 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/TimeLagWatermarkGenerator.java x: 1 contributors (90d) y: 23 lines of code src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkPerQueue.java x: 1 contributors (90d) y: 35 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java x: 1 contributors (90d) y: 258 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSink.java x: 1 contributors (90d) y: 42 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/committer/RocketMQCommitter.java x: 1 contributors (90d) y: 76 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittable.java x: 1 contributors (90d) y: 106 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java x: 1 contributors (90d) y: 255 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java x: 1 contributors (90d) y: 100 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataConverter.java x: 1 contributors (90d) y: 178 lines of code src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java x: 1 contributors (90d) y: 102 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java x: 1 contributors (90d) y: 135 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceBuilder.java x: 1 contributors (90d) y: 98 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java x: 1 contributors (90d) y: 133 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/config/OffsetVerification.java x: 1 contributors (90d) y: 21 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: 310 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java x: 1 contributors (90d) y: 29 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorBySpecified.java x: 1 contributors (90d) y: 56 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java x: 1 contributors (90d) y: 123 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java x: 1 contributors (90d) y: 57 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java x: 1 contributors (90d) y: 108 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java x: 1 contributors (90d) y: 214 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/DirtyDataStrategy.java x: 1 contributors (90d) y: 9 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQRowDeserializationSchema.java x: 1 contributors (90d) y: 70 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java x: 1 contributors (90d) y: 526 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java x: 1 contributors (90d) y: 78 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactory.java x: 1 contributors (90d) y: 156 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQScanTableSource.java x: 1 contributors (90d) y: 196 lines of code src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java x: 1 contributors (90d) y: 128 lines of code
531.0
lines of code
  min: 2.0
  average: 74.37
  25th percentile: 14.25
  median: 36.0
  75th percentile: 93.75
  max: 531.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