fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SnapshotSplit.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SnapshotSplit.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SnapshotSplit.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SourceSplitBase.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SourceSplitBase.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/reader/RecordAndPos.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/reader/RecordAndPos.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/event/PartitionBucketsUnsubscribedEvent.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/state/SourceEnumeratorState.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/event/PartitionBucketsUnsubscribedEvent.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/state/SourceEnumeratorState.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/state/SourceEnumeratorState.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ProduceLogResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SourceSplitBase.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SnapshotSplit.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/event/PartitionBucketsUnsubscribedEvent.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/reader/RecordAndPos.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/reader/RecordAndPos.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/state/SourceEnumeratorState.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/event/PartitionBucketsUnsubscribedEvent.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/WriteResultForBucket.java

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/split/SourceSplitBase.java
fluss-rpc/src/main/java/com/alibaba/fluss/rpc/entity/ListOffsetsResultForBucket.java