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 108 files with 8,007 lines of code in files.
    • 4 files that are 366+ days old (273 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)
    • 0 files that are 31-90 days old (0 lines of code)
    • 104 files that are 1-30 days old (7,734 lines of code)
3% | 0% | 0% | 0% | 96%
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 108 files with 8,007 lines of code in files.
    • 4 files have been last changed 366+ days ago (273 lines of code)
    • 0 files have been last changed 181-365 days ago (0 lines of code)
    • 0 files have been last changed 91-180 days ago (0 lines of code)
    • 0 files have been last changed 31-90 days ago (0 lines of code)
    • 104 files have been last changed 1-30 days ago (7,734 lines of code)
3% | 0% | 0% | 0% | 96%
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, txt, gitignore, md, json, yml, yaml
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
xml100% | 0% | 0% | 0% | 0%
java0% | 0% | 0% | 0% | 100%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
xml100% | 0% | 0% | 0% | 0%
java0% | 0% | 0% | 0% | 100%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
style100% | 0% | 0% | 0% | 0%
src0% | 0% | 0% | 0% | 100%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
style100% | 0% | 0% | 0% | 0%
src0% | 0% | 0% | 0% | 100%
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
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
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
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
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
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
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
Most Recently Created Files (Top 50)
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
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
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
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
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
Most Recently Changed Files (Top 50)
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
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
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
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
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