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 108 files with 8,007 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)
    • 108 files changed 1-5 times (8,007 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 108 files with 8,007 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)
    • 1 file changed by 2-5 contributors (79 lines of code)
    • 107 files changed by 1 contributor (7,928 lines of code)
0% | 0% | 0% | <1% | 99%
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, txt, gitignore, md, json, yml, yaml
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
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
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
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
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
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
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
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
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
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
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
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
AllocateStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 12 - 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
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
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
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
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
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
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
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
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
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
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
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
UtilAll.java
in src/main/java/org/apache/flink/connector/rocketmq/source/util
 17 3 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
MessageView.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 18 - 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
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
OffsetsSelectorNoStopping.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset
 21 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
OffsetVerification.java
in src/main/java/org/apache/flink/connector/rocketmq/source/config
 21 1 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
BroadcastAllocateStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 22 1 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
TimeLagWatermarkGenerator.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark
 23 3 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
SinkMapFunction.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy/function
 23 3 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSourceReaderMetrics.java
in src/main/java/org/apache/flink/connector/rocketmq/source/metrics
 23 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSourceSplitState.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
 23 4 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
BytesMessage.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
 25 5 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
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
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
ConsistentHashAllocateStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 28 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
AllocateStrategyFactory.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 29 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
140 - 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
profiles_settings.xml
in style/copyright
 47 - 2018-03-23 2018-03-23 1 1 best.wangxin@163.com best.wangxin@163.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
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
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
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
RocketMQSourceReader.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 108 7 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
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
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
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
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
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
BytesMessage.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer
 25 5 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
MessageView.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 18 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSourceFetcherManager.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 57 3 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSplitReader.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 214 14 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
RocketMQPartitionSplitSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
 42 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSourceSplitState.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
 23 4 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSourceSplit.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
 78 12 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSourceReaderMetrics.java
in src/main/java/org/apache/flink/connector/rocketmq/source/metrics
 23 2 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
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
UtilAll.java
in src/main/java/org/apache/flink/connector/rocketmq/source/util
 17 3 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
OffsetVerification.java
in src/main/java/org/apache/flink/connector/rocketmq/source/config
 21 1 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
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
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
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
RocketMQSourceOptions.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 133 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
InnerConsumerImpl.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 414 23 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
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
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
OffsetsSelectorNoStopping.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset
 21 2 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
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
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
RocketMQSourceEnumerator.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator
 310 23 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
AllocateStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 12 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
ConsistentHashAllocateStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 28 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
AllocateStrategyFactory.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 29 2 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
BroadcastAllocateStrategy.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate
 22 1 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSourceEnumStateSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator
 66 3 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSource.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 135 9 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
RocketMQSourceFunction.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
 531 19 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
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
InnerConsumerImpl.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 414 23 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
RocketMQSourceEnumerator.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator
 310 23 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
RocketMQDynamicTableSink.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
 255 13 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSplitReader.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 214 14 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
RocketMQSink.java
in src/main/java/org/apache/flink/connector/rocketmq/legacy
 185 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
RocketMQSource.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 135 9 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.com
RocketMQSourceOptions.java
in src/main/java/org/apache/flink/connector/rocketmq/source
 133 - 2023-07-31 2023-07-31 1 1 707364882@qq.com 707364882@qq.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
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
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
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
RocketMQSourceReader.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 108 7 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
RocketMQDynamicTableSinkFactory.java
in src/main/java/org/apache/flink/connector/rocketmq/sink/table
 100 2 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
RocketMQSourceSplit.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
 78 12 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
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
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
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
RocketMQSourceEnumStateSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator
 66 3 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
RocketMQSourceFetcherManager.java
in src/main/java/org/apache/flink/connector/rocketmq/source/reader
 57 3 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
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
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
profiles_settings.xml
in style/copyright
 47 - 2018-03-23 2018-03-23 1 1 best.wangxin@163.com best.wangxin@163.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
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
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
RocketMQPartitionSplitSerializer.java
in src/main/java/org/apache/flink/connector/rocketmq/source/split
 42 2 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
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
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
Correlations

File Size vs. Number of Changes: 108 points

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/RocketMQSink.java x: 185 lines of code y: 1 # changes src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java x: 531 lines of code y: 1 # changes src/main/java/org/apache/flink/connector/rocketmq/legacy/RunningChecker.java x: 11 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/HashMessageQueueSelector.java x: 14 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/RandomMessageQueueSelector.java x: 13 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/SimpleKeyValueSerializationSchema.java x: 32 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/RocketMQDynamicTableSink.java x: 255 lines of code y: 1 # changes src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java x: 100 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/table/RocketMQRowDataSink.java x: 36 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/InnerConsumerImpl.java x: 414 lines of code y: 1 # changes src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java x: 135 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/RocketMQSourceOptions.java x: 133 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/RocketMQSourceEnumStateSerializer.java x: 66 lines of code y: 1 # changes src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java x: 310 lines of code y: 1 # changes src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategy.java x: 12 lines of code y: 1 # changes src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java x: 29 lines of code y: 1 # changes src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java x: 22 lines of code y: 1 # changes src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java x: 28 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/RocketMQSourceFetcherManager.java x: 57 lines of code y: 1 # changes src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java x: 108 lines of code y: 1 # changes src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java x: 214 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/split/RocketMQSourceSplit.java x: 78 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 src/main/java/org/apache/flink/connector/rocketmq/source/util/UtilAll.java x: 17 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.03
  25th percentile: 1.0
  median: 1.0
  75th percentile: 1.0
  max: 4.0
0 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

Number of Contributors vs. Number of Changes: 108 points

src/main/java/org/apache/flink/connector/rocketmq/MetricUtil.java x: 1 # contributors y: 1 # changes style/rmq_checkstyle.xml x: 3 # contributors y: 4 # changes
4.0
# changes
  min: 1.0
  average: 1.03
  25th percentile: 1.0
  median: 1.0
  75th percentile: 1.0
  max: 4.0
0 3.0
# contributors
min: 1.0 | average: 1.02 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 3.0

Number of Contributors vs. File Size: 108 points

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