apache / rocketmq-flink
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 114 files with 8,651 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 0 files changed 21-50 times (0 lines of code)
    • 0 files changed 6-20 times (0 lines of code)
    • 114 files changed 1-5 times (8,651 lines of code)
0% | 0% | 0% | 0% | 100%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 114 files with 8,651 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 0 files changed by 6-10 contributors (0 lines of code)
    • 21 files changed by 2-5 contributors (3,371 lines of code)
    • 93 files changed by 1 contributor (5,280 lines of code)
0% | 0% | 0% | 38% | 61%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, xml, yaml, txt, gitignore, md
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 0% | 100%
xml0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
src0% | 0% | 0% | 0% | 100%
style0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
79 - 2018-03-23 2021-08-25 4 3 best.wangxin@163.com vongosling@apache.org
RocketMQSourceEnumStateSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator
 66 3 2023-07-31 2025-03-06 3 3 707364882@qq.com 125714719+3424672656@users....
RocketMQSplitReader.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 261 16 2023-07-31 2025-03-06 3 3 707364882@qq.com 125714719+3424672656@users....
InnerConsumerImpl.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 421 23 2023-07-31 2025-03-06 3 3 707364882@qq.com 125714719+3424672656@users....
RocketMQSourceFunction.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
 543 19 2023-07-31 2025-03-06 3 3 707364882@qq.com 125714719+3424672656@users....
RocketMQSourceEnumerator.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator
 587 27 2023-07-31 2025-03-06 3 3 707364882@qq.com 125714719+3424672656@users....
AllocateStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 16 - 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
RocketMQSourceReaderMetrics.java
in src/main/java/org/apache/flink/connector/rocketmq/source/metrics
 24 3 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
BroadcastAllocateStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 27 1 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
RocketMQSourceSplitState.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
 28 4 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
AllocateStrategyFactory.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 32 2 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
ConsistentHashAllocateStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 33 2 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
RocketMQPartitionSplitSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
 48 2 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
RocketMQSourceFetcherManager.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 60 4 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
RocketMQDynamicTableSinkFactory.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
 108 2 2023-07-31 2024-01-10 2 2 707364882@qq.com 1109939087@qq.com
RocketMQSourceSplit.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
 127 17 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
RocketMQSourceOptions.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 133 - 2023-07-31 2023-11-15 2 2 707364882@qq.com liurongtong001@qq.com
RocketMQSource.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 136 9 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
RocketMQSink.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
 187 12 2023-07-31 2024-05-17 2 2 707364882@qq.com 1109939087@qq.com
RocketMQSourceReader.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 199 10 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
RocketMQDynamicTableSink.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
 256 13 2023-07-31 2024-01-10 2 2 707364882@qq.com 1109939087@qq.com
MetricUtil.java
in src/main/java/org/apache/flink/connector/rocketmq
 2 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSerializerWrapper.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer
 4 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
MessageQueueSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector
 4 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
SchemaRegistryConstant.java
in src/main/java/org/apache/flink/connector/rocketmq/common/constant
 5 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
OffsetResetStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/config
 5 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
TransactionResult.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
 6 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
KeyValueDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 6 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
KeyValueSerializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 6 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
TopicSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector
 6 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
OffsetsValidator.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset
 7 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMqCatalogConstant.java
in src/main/java/org/apache/flink/connector/rocketmq/common/constant
 7 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
MessageExtDeserializationScheme.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 7 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
Apache.xml
in style/copyright
 7 - 2018-03-23 2018-03-23 1 1 best.wangxin@163.com best.wangxin@163.com
StartupMode.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/config
 8 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
DirtyDataStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
 9 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
SourceDetectEvent.java
in src/main/java/org/apache/flink/connector/rocketmq/common/event
 11 2 2025-03-06 2025-03-06 1 1 125714719+3424672656@users.... 125714719+3424672656@users....
RunningChecker.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
 11 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
QueryableSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
 13 1 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSchemaWrapper.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
 13 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSinkContext.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/writer/context
 13 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
InnerProducer.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
 13 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
SourceInitAssignEvent.java
in src/main/java/org/apache/flink/connector/rocketmq/common/event
 13 2 2025-03-06 2025-03-06 1 1 125714719+3424672656@users.... 125714719+3424672656@users....
SourceMapFunction.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/function
 13 1 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RandomMessageQueueSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector
 13 1 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSourceEnumState.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator
 14 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSerializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer
 14 1 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
SpinLock.java
in src/main/java/org/apache/flink/connector/rocketmq/common/lock
 14 2 2025-03-06 2025-03-06 1 1 125714719+3424672656@users.... 125714719+3424672656@users....
SourceCheckEvent.java
in src/main/java/org/apache/flink/connector/rocketmq/common/event
 14 1 2025-03-06 2025-03-06 1 1 125714719+3424672656@users.... 125714719+3424672656@users....
ForwardMessageExtDeserialization.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 14 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
79 - 2018-03-23 2021-08-25 4 3 best.wangxin@163.com vongosling@apache.org
RocketMQSourceFunction.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
 543 19 2023-07-31 2025-03-06 3 3 707364882@qq.com 125714719+3424672656@users....
InnerConsumerImpl.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 421 23 2023-07-31 2025-03-06 3 3 707364882@qq.com 125714719+3424672656@users....
RocketMQSourceEnumStateSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator
 66 3 2023-07-31 2025-03-06 3 3 707364882@qq.com 125714719+3424672656@users....
RocketMQSourceEnumerator.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator
 587 27 2023-07-31 2025-03-06 3 3 707364882@qq.com 125714719+3424672656@users....
RocketMQSplitReader.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 261 16 2023-07-31 2025-03-06 3 3 707364882@qq.com 125714719+3424672656@users....
RocketMQSink.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
 187 12 2023-07-31 2024-05-17 2 2 707364882@qq.com 1109939087@qq.com
RocketMQDynamicTableSink.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
 256 13 2023-07-31 2024-01-10 2 2 707364882@qq.com 1109939087@qq.com
RocketMQDynamicTableSinkFactory.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
 108 2 2023-07-31 2024-01-10 2 2 707364882@qq.com 1109939087@qq.com
RocketMQSourceReaderMetrics.java
in src/main/java/org/apache/flink/connector/rocketmq/source/metrics
 24 3 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
RocketMQSourceOptions.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 133 - 2023-07-31 2023-11-15 2 2 707364882@qq.com liurongtong001@qq.com
RocketMQSource.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 136 9 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
BroadcastAllocateStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 27 1 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
AllocateStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 16 - 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
AllocateStrategyFactory.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 32 2 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
ConsistentHashAllocateStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 33 2 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
RocketMQSourceSplitState.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
 28 4 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
RocketMQPartitionSplitSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
 48 2 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
RocketMQSourceSplit.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
 127 17 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
RocketMQSourceReader.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 199 10 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
RocketMQSourceFetcherManager.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 60 4 2023-07-31 2025-03-06 2 2 707364882@qq.com 125714719+3424672656@users....
140 - 2018-03-23 2018-03-23 1 1 best.wangxin@163.com best.wangxin@163.com
profiles_settings.xml
in style/copyright
 47 - 2018-03-23 2018-03-23 1 1 best.wangxin@163.com best.wangxin@163.com
Apache.xml
in style/copyright
 7 - 2018-03-23 2018-03-23 1 1 best.wangxin@163.com best.wangxin@163.com
RunningChecker.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
 11 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
StartupMode.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/config
 8 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
OffsetResetStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/config
 5 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
TestUtils.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util
 19 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RetryUtil.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util
 48 4 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
MetricUtils.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util
 72 8 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQUtils.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util
 52 6 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RandomMessageQueueSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector
 13 1 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
TopicSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector
 6 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
MessageQueueSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector
 4 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
DefaultTopicSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector
 20 4 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
HashMessageQueueSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector
 14 1 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
SimpleTopicSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector
 44 3 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
SimpleKeyValueDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 37 3 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
SimpleKeyValueSerializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 32 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
KeyValueSerializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 6 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
KeyValueDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 6 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
ForwardMessageExtDeserialization.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 14 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RowKeyValueDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 351 18 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
SimpleStringDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 15 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
SimpleTupleDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 18 1 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
MessageExtDeserializationScheme.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 7 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
WaterMarkForAll.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark
 16 4 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
BoundedOutOfOrdernessGenerator.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark
 31 5 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
BoundedOutOfOrdernessGeneratorPerQueue.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark
 41 5 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
PunctuatedAssigner.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark
 16 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
RowDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
 526 30 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQCatalog.java
in src/main/java/org/apache/flink/connector/rocketmq/catalog
 416 41 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RowKeyValueDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 351 18 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
InnerProducerImpl.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
 258 10 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQScanTableSource.java
in src/main/java/org/apache/flink/connector/rocketmq/source/table
 196 12 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQRowDataConverter.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
 178 4 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQDynamicTableSourceFactory.java
in src/main/java/org/apache/flink/connector/rocketmq/source/table
 156 3 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
140 - 2018-03-23 2018-03-23 1 1 best.wangxin@163.com best.wangxin@163.com
ByteSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/util
 128 4 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
StringSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/util
 123 4 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
MessageViewExt.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 123 14 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQConfig.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
 115 4 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQOptions.java
in src/main/java/org/apache/flink/connector/rocketmq/common/config
 109 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
SendCommittable.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/committer
 106 19 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQWriter.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/writer
 102 6 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSourceBuilder.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 98 16 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
ByteUtils.java
in src/main/java/org/apache/flink/connector/rocketmq/source/util
 97 15 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQConfigBuilder.java
in src/main/java/org/apache/flink/connector/rocketmq/common/config
 84 8 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQCommitter.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/committer
 76 5 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSinkBuilder.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
 73 12 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
MetricUtils.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util
 72 8 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSinkOptions.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
 72 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQRowDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
 70 6 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQConfigValidator.java
in src/main/java/org/apache/flink/connector/rocketmq/common/config
 59 6 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
OffsetsSelectorBySpecified.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset
 56 3 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQConfiguration.java
in src/main/java/org/apache/flink/connector/rocketmq/common/config
 54 5 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQUtils.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util
 52 6 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RetryUtil.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util
 48 4 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
OffsetsSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset
 48 8 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
profiles_settings.xml
in style/copyright
 47 - 2018-03-23 2018-03-23 1 1 best.wangxin@163.com best.wangxin@163.com
SimpleTopicSelector.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector
 44 3 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
SendCommittableSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/committer
 44 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQRecordEmitter.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 44 6 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSink.java
in src/main/java/org/apache/flink/connector/rocketmq/sink
 42 4 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
BoundedOutOfOrdernessGeneratorPerQueue.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark
 41 5 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSinkContextImpl.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/writer/context
 41 6 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQCatalogFactory.java
in src/main/java/org/apache/flink/connector/rocketmq/catalog
 41 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
SimpleKeyValueDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 37 3 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQRowDataSink.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
 36 5 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
OffsetsSelectorByStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset
 36 3 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
OffsetsSelectorByTimestamp.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset
 36 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
WaterMarkPerQueue.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark
 35 5 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
AverageAllocateStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 33 2 2025-03-06 2025-03-06 1 1 125714719+3424672656@users.... 125714719+3424672656@users....
SimpleKeyValueSerializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization
 32 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
SourceReportOffsetEvent.java
in src/main/java/org/apache/flink/connector/rocketmq/common/event
 32 8 2025-03-06 2025-03-06 1 1 125714719+3424672656@users.... 125714719+3424672656@users....
BoundedOutOfOrdernessGenerator.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark
 31 5 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQDeserializationSchema.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
 27 4 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
InnerConsumer.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 26 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQCatalogFactoryOptions.java
in src/main/java/org/apache/flink/connector/rocketmq/catalog
 26 1 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQDeserializationSchemaWrapper.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
 25 3 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
Correlations

File Size vs. Number of Changes: 114 points

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

Number of Contributors vs. Number of Changes: 114 points

src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java x: 1 # contributors y: 1 # changes src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java x: 3 # contributors y: 3 # changes src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java x: 2 # contributors y: 2 # changes style/rmq_checkstyle.xml x: 3 # contributors y: 4 # changes
4.0
# changes
  min: 1.0
  average: 1.25
  25th percentile: 1.0
  median: 1.0
  75th percentile: 1.0
  max: 4.0
0 3.0
# contributors
min: 1.0 | average: 1.24 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 3.0

Number of Contributors vs. File Size: 114 points

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