apache / rocketmq-flink
Temporal Dependencies

A temporal dependency occurs when developers change two or more files at the same time (i.e. they are a part of the same commit).


Files Most Frequently Changed Together (Top 50)

data...

Pairs # same commits # commits 1 # commits 2 latest commit
src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java
src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer/RocketMQSerializationSchema.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtil.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer/RocketMQSerializerWrapper.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/MetricUtils.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java
src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/MessageExtDeserializationScheme.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/KeyValueDeserializationSchema.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer/RocketMQSerializerWrapper.java
src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittable.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java
src/main/java/org/apache/flink/connector/rocketmq/sink/committer/RocketMQCommitter.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQDeserializationSchemaWrapper.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueDeserializationSchema.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactory.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/TopicSelector.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkPerQueue.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/TestUtils.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java
src/main/java/org/apache/flink/connector/rocketmq/sink/committer/RocketMQCommitter.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsValidator.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/TestUtils.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsValidator.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/BoundedOutOfOrdernessGenerator.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/util/UtilAll.java
src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQRecordEmitter.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/config/OffsetResetStrategy.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/HashMessageQueueSelector.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/config/StartupMode.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/util/UtilAll.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/MessageExtDeserializationScheme.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsValidator.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsValidator.java
src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQOptions.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQRowDeserializationSchema.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/KeyValueDeserializationSchema.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataSink.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/TimeLagWatermarkGenerator.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java
src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataConverter.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java
src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/KeyValueDeserializationSchema.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/PunctuatedAssigner.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java
src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/TestUtils.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/TopicSelector.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/util/StringSerializer.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkForAll.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/MessageQueueSelector.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueSerializationSchema.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteUtils.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtil.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java
src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java
src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/BytesMessage.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/SimpleTopicSelector.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java
src/main/java/org/apache/flink/connector/rocketmq/common/constant/RocketMqCatalogConstant.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java
src/main/java/org/apache/flink/connector/rocketmq/common/constant/SchemaRegistryConstant.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/util/StringSerializer.java
src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtil.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java
src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkBuilder.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkPerQueue.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java
src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumer.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorByStrategy.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/KeyValueSerializationSchema.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorNoStopping.java
src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigBuilder.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/QueryableSchema.java
src/main/java/org/apache/flink/connector/rocketmq/sink/TransactionResult.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageView.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/TestUtils.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java
src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQOptions.java		 1 1 (100%) 1 (100%) 2023-07-31
src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java
src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/TestUtils.java		 1 1 (100%) 1 (100%) 2023-07-31
Dependencies between files in same commits
The number on the lines shows the number of shared commits.
G [src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java]--[src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/common/constant/SchemaRegistryConstant.java] [src/main/java/org/apache/flink/connector/rocketmq/common/constant/SchemaRegistryConstant.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java]--[src/main/java/org/apache/flink/connector/rocketmq/common/constant/SchemaRegistryConstant.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkPerQueue.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkPerQueue.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkPerQueue.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer/RocketMQSerializationSchema.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer/RocketMQSerializationSchema.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtil.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtil.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer/RocketMQSerializationSchema.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtil.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer/RocketMQSerializerWrapper.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer/RocketMQSerializerWrapper.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/MetricUtils.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/MetricUtils.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer/RocketMQSerializerWrapper.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/MetricUtils.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittable.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittable.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/writer/serializer/RocketMQSerializerWrapper.java]--[src/main/java/org/apache/flink/connector/rocketmq/sink/committer/SendCommittable.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java] [src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java] [src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java]--[src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/BytesMessage.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/BytesMessage.java] [src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java]--[src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/BytesMessage.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/MessageExtDeserializationScheme.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/MessageExtDeserializationScheme.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/KeyValueDeserializationSchema.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/KeyValueDeserializationSchema.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/MessageExtDeserializationScheme.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/KeyValueDeserializationSchema.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/committer/RocketMQCommitter.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/committer/RocketMQCommitter.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java]--[src/main/java/org/apache/flink/connector/rocketmq/sink/committer/RocketMQCommitter.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueSerializationSchema.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueSerializationSchema.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueSerializationSchema.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQDeserializationSchemaWrapper.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQDeserializationSchemaWrapper.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueDeserializationSchema.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueDeserializationSchema.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQDeserializationSchemaWrapper.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueDeserializationSchema.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactory.java] [src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactory.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/TopicSelector.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/TopicSelector.java] [src/main/java/org/apache/flink/connector/rocketmq/source/table/RocketMQDynamicTableSourceFactory.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/TopicSelector.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/TestUtils.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/TestUtils.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkPerQueue.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/TestUtils.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/MessageExtDeserializationScheme.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java]--[src/main/java/org/apache/flink/connector/rocketmq/sink/committer/RocketMQCommitter.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsValidator.java] [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsValidator.java] [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsValidator.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/TestUtils.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/BoundedOutOfOrdernessGenerator.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/BoundedOutOfOrdernessGenerator.java] [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsValidator.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/BoundedOutOfOrdernessGenerator.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java] [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsValidator.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQOptions.java] [src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQOptions.java] [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsValidator.java]--[src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQOptions.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/util/UtilAll.java] [src/main/java/org/apache/flink/connector/rocketmq/source/util/UtilAll.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java] [src/main/java/org/apache/flink/connector/rocketmq/source/util/UtilAll.java]--[src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/util/UtilAll.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQRecordEmitter.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQRecordEmitter.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/config/OffsetResetStrategy.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/config/OffsetResetStrategy.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQRecordEmitter.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/config/OffsetResetStrategy.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/HashMessageQueueSelector.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/HashMessageQueueSelector.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/config/StartupMode.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/config/StartupMode.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/HashMessageQueueSelector.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/config/StartupMode.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQRowDeserializationSchema.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQRowDeserializationSchema.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RocketMQRowDeserializationSchema.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/KeyValueDeserializationSchema.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataSink.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataSink.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/TimeLagWatermarkGenerator.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/TimeLagWatermarkGenerator.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataSink.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/TimeLagWatermarkGenerator.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java] [src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java] [src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/KeyValueDeserializationSchema.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataConverter.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataConverter.java] [src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java]--[src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataConverter.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java] [src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java] [src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java]--[src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageViewExt.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/TestUtils.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/PunctuatedAssigner.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/PunctuatedAssigner.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/PunctuatedAssigner.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSink.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java] [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java] [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java]--[src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSinkFactory.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java] [src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java] [src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/TestUtils.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/SimpleTopicSelector.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/SimpleTopicSelector.java] [src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/SimpleTopicSelector.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/common/constant/RocketMqCatalogConstant.java] [src/main/java/org/apache/flink/connector/rocketmq/common/constant/RocketMqCatalogConstant.java] [src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java]--[src/main/java/org/apache/flink/connector/rocketmq/common/constant/RocketMqCatalogConstant.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/TopicSelector.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/util/StringSerializer.java] [src/main/java/org/apache/flink/connector/rocketmq/source/util/StringSerializer.java] [src/main/java/org/apache/flink/connector/rocketmq/source/util/StringSerializer.java]--[src/main/java/org/apache/flink/connector/rocketmq/sink/writer/RocketMQWriter.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkForAll.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkForAll.java] [src/main/java/org/apache/flink/connector/rocketmq/source/util/StringSerializer.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkForAll.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/MessageQueueSelector.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/MessageQueueSelector.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/InnerProducerImpl.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/selector/MessageQueueSelector.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java]--[src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQOptions.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java] [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java]--[src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkBuilder.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkBuilder.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/RowDeserializationSchema.java]--[src/main/java/org/apache/flink/connector/rocketmq/sink/RocketMQSinkBuilder.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteUtils.java] [src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteUtils.java] [src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteUtils.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtil.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java] [src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java] [src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java]--[src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java] [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java] [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/RetryUtil.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java] [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java] [src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumer.java] [src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumer.java] [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java]--[src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumer.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorByStrategy.java] [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorByStrategy.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/KeyValueSerializationSchema.java] [src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/KeyValueSerializationSchema.java] [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorByStrategy.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/KeyValueSerializationSchema.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorNoStopping.java] [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorNoStopping.java] [src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigBuilder.java] [src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigBuilder.java] [src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorNoStopping.java]--[src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfigBuilder.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/QueryableSchema.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/QueryableSchema.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/TransactionResult.java] [src/main/java/org/apache/flink/connector/rocketmq/sink/TransactionResult.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/deserializer/QueryableSchema.java]--[src/main/java/org/apache/flink/connector/rocketmq/sink/TransactionResult.java] 1 [src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageView.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageView.java] [src/main/java/org/apache/flink/connector/rocketmq/source/reader/MessageView.java]--[src/main/java/org/apache/flink/connector/rocketmq/legacy/common/util/TestUtils.java] 1
Download: SVG DOT (open online Graphviz editor)

Open 3D force graph (file dependencies)...
Open 3D force graph (file dependencies with commits)...
Dependencies between components in same commits (primary)
The number on the lines shows the number of shared commits.
G src src src--src 1
Download: SVG DOT (open online Graphviz editor)

Open 3D force graph (file dependencies)...