path	# lines of code	# active days	days since first update	days since last update	# commits	# contributors	first updated	last updated	first contributor	last contributor
style/rmq_checkstyle.xml	79	4	2603	1352	4	3	2018-03-23	2021-08-25	best.wangxin@163.com	vongosling@apache.org
style/rmq_codeStyle.xml	140	1	2603	2603	1	1	2018-03-23	2018-03-23	best.wangxin@163.com	best.wangxin@163.com
style/copyright/profiles_settings.xml	47	1	2603	2603	1	1	2018-03-23	2018-03-23	best.wangxin@163.com	best.wangxin@163.com
style/copyright/Apache.xml	7	1	2603	2603	1	1	2018-03-23	2018-03-23	best.wangxin@163.com	best.wangxin@163.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/RunningChecker.java	11	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/config/StartupMode.java	8	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/config/OffsetResetStrategy.java	5	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/TestUtils.java	19	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtil.java	48	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/MetricUtils.java	72	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RocketMQUtils.java	52	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/RandomMessageQueueSelector.java	13	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/TopicSelector.java	6	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/MessageQueueSelector.java	4	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/DefaultTopicSelector.java	20	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/HashMessageQueueSelector.java	14	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/SimpleTopicSelector.java	44	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueDeserializationSchema.java	37	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueSerializationSchema.java	32	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/KeyValueSerializationSchema.java	6	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/KeyValueDeserializationSchema.java	6	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/ForwardMessageExtDeserialization.java	14	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java	351	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleStringDeserializationSchema.java	15	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleTupleDeserializationSchema.java	18	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/MessageExtDeserializationScheme.java	7	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkForAll.java	16	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/BoundedOutOfOrdernessGenerator.java	31	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/BoundedOutOfOrdernessGeneratorPerQueue.java	41	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/PunctuatedAssigner.java	16	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/TimeLagWatermarkGenerator.java	23	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkPerQueue.java	35	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java	187	2	647	356	2	2	2023-07-31	2024-05-17	707364882@qq.com	1109939087@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/function/SinkMapFunction.java	23	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/function/SourceMapFunction.java	13	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQConfig.java	115	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java	543	3	647	63	3	3	2023-07-31	2025-03-06	707364882@qq.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfiguration.java	54	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigBuilder.java	84	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQOptions.java	109	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigValidator.java	59	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java	14	1	63	63	1	1	2025-03-06	2025-03-06	125714719+3424672656@users.noreply.github.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java	13	1	63	63	1	1	2025-03-06	2025-03-06	125714719+3424672656@users.noreply.github.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java	32	1	63	63	1	1	2025-03-06	2025-03-06	125714719+3424672656@users.noreply.github.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java	11	1	63	63	1	1	2025-03-06	2025-03-06	125714719+3424672656@users.noreply.github.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/common/constant/RocketMqCatalogConstant.java	7	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/common/constant/SchemaRegistryConstant.java	5	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/common/lock/SpinLock.java	14	1	63	63	1	1	2025-03-06	2025-03-06	125714719+3424672656@users.noreply.github.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/MetricUtil.java	2	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSink.java	42	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/TransactionResult.java	6	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/committer/RocketMQCommitter.java	76	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittable.java	106	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittableSerializer.java	44	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataSink.java	36	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java	256	2	647	484	2	2	2023-07-31	2024-01-10	707364882@qq.com	1109939087@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataConverter.java	178	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java	108	2	647	484	2	2	2023-07-31	2024-01-10	707364882@qq.com	1109939087@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java	258	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducer.java	13	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkOptions.java	72	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer/RocketMQSerializerWrapper.java	4	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer/RocketMQSerializationSchema.java	14	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/writer/context/RocketMQSinkContext.java	13	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/writer/context/RocketMQSinkContextImpl.java	41	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java	102	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkBuilder.java	73	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java	24	2	647	63	2	2	2023-07-31	2025-03-06	707364882@qq.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java	133	2	647	540	2	2	2023-07-31	2023-11-15	707364882@qq.com	liurongtong001@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java	421	3	647	63	3	3	2023-07-31	2025-03-06	707364882@qq.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java	136	2	647	63	2	2	2023-07-31	2025-03-06	707364882@qq.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactory.java	156	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQScanTableSource.java	196	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/config/OffsetVerification.java	21	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java	128	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteUtils.java	97	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/util/StringSerializer.java	123	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/util/UtilAll.java	17	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceBuilder.java	98	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumer.java	26	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java	66	3	647	63	3	3	2023-07-31	2025-03-06	707364882@qq.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java	587	3	647	63	3	3	2023-07-31	2025-03-06	707364882@qq.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelector.java	48	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorByStrategy.java	36	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorByTimestamp.java	36	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorBySpecified.java	56	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsValidator.java	7	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorNoStopping.java	21	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java	27	2	647	63	2	2	2023-07-31	2025-03-06	707364882@qq.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategy.java	16	2	647	63	2	2	2023-07-31	2025-03-06	707364882@qq.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java	32	2	647	63	2	2	2023-07-31	2025-03-06	707364882@qq.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java	33	2	647	63	2	2	2023-07-31	2025-03-06	707364882@qq.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategy.java	33	1	63	63	1	1	2025-03-06	2025-03-06	125714719+3424672656@users.noreply.github.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumState.java	14	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplitState.java	28	2	647	63	2	2	2023-07-31	2025-03-06	707364882@qq.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java	48	2	647	63	2	2	2023-07-31	2025-03-06	707364882@qq.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java	127	2	647	63	2	2	2023-07-31	2025-03-06	707364882@qq.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQRecordEmitter.java	44	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/DirtyDataStrategy.java	9	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQDeserializationSchemaWrapper.java	25	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQSchemaWrapper.java	13	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQDeserializationSchema.java	27	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/QueryableSchema.java	13	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/BytesMessage.java	25	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java	526	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQRowDeserializationSchema.java	70	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageView.java	18	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java	261	3	647	63	3	3	2023-07-31	2025-03-06	707364882@qq.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java	199	2	647	63	2	2	2023-07-31	2025-03-06	707364882@qq.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java	60	2	647	63	2	2	2023-07-31	2025-03-06	707364882@qq.com	125714719+3424672656@users.noreply.github.com
src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java	123	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalog.java	416	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactoryOptions.java	26	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com
src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalogFactory.java	41	1	647	647	1	1	2023-07-31	2023-07-31	707364882@qq.com	707364882@qq.com