apache / rocketmq-flink
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 114 files with 8,651 lines of code in files.
    • 108 files that are 366+ days old (8,534 lines of code)
    • 0 files that are 181-365 days old (0 lines of code)
    • 0 files that are 91-180 days old (0 lines of code)
    • 6 files that are 31-90 days old (117 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
98% | 0% | 0% | 1% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 114 files with 8,651 lines of code in files.
    • 91 files have been last changed 366+ days ago (5,739 lines of code)
    • 1 files have been last changed 181-365 days ago (187 lines of code)
    • 0 files have been last changed 91-180 days ago (0 lines of code)
    • 22 files have been last changed 31-90 days ago (2,725 lines of code)
    • 0 files have been last changed 1-30 days ago (0 lines of code)
66% | 2% | 0% | 31% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, xml, yaml, txt, gitignore, md
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java98% | 0% | 0% | 1% | 0%
xml100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java65% | 2% | 0% | 32% | 0%
xml100% | 0% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
src98% | 0% | 0% | 1% | 0%
style100% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
src65% | 2% | 0% | 32% | 0%
style100% | 0% | 0% | 0% | 0%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
140 - 2018-03-23 2018-03-23 1 1 best.wangxin@163.com best.wangxin@163.com
79 - 2018-03-23 2021-08-25 4 3 best.wangxin@163.com vongosling@apache.org
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
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....
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....
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
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....
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
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....
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
 256 13 2023-07-31 2024-01-10 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....
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
 187 12 2023-07-31 2024-05-17 2 2 707364882@qq.com 1109939087@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
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....
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
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
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....
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
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
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
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....
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....
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
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....
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
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
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
140 - 2018-03-23 2018-03-23 1 1 best.wangxin@163.com best.wangxin@163.com
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
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....
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....
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....
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....
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....
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....
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....
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....
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
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....
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
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....
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
 256 13 2023-07-31 2024-01-10 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....
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
 187 12 2023-07-31 2024-05-17 2 2 707364882@qq.com 1109939087@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
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....
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
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
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....
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
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
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
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....
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....
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
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....
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
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
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....
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....
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....
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....
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....
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....
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....
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....
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....
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....
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....
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....
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....
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....
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....
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....
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....
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....
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....
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....
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....
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
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
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
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