apache / fluss

Code / Commits / bb84256
[client] move OffsetsInitializer to fluss-client (#2424)
Yann Byron Yann Byron committed on Jan 21, 2026, 07:55 AM
Showing 19 changed files +38 additions -39 deletions
R fluss-client/src/main/java/org/apache/fluss/client/initializer/BucketOffsetsRetrieverImpl.java +6 -8
R fluss-client/src/main/java/org/apache/fluss/client/initializer/EarliestOffsetsInitializer.java +2 -7
R fluss-client/src/main/java/org/apache/fluss/client/initializer/LatestOffsetsInitializer.java +1 -1
R fluss-client/src/main/java/org/apache/fluss/client/initializer/NoStoppingOffsetsInitializer.java +2 -2
R fluss-client/src/main/java/org/apache/fluss/client/initializer/OffsetsInitializer.java +2 -3
R fluss-client/src/main/java/org/apache/fluss/client/initializer/SnapshotOffsetsInitializer.java +1 -1
R fluss-client/src/main/java/org/apache/fluss/client/initializer/TimestampOffsetsInitializer.java +1 -1
M fluss-client/src/main/java/org/apache/fluss/client/table/scanner/log/LogScanner.java +6
M fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/lake/LakeSplitGenerator.java +1 -1
M fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/source/FlinkSource.java +1 -1
M fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/source/FlinkTableSource.java +1 -1
M fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/source/FlussSource.java +1 -1
M fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/source/FlussSourceBuilder.java +1 -1
M fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/source/enumerator/FlinkSourceEnumerator.java +5 -5
M fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/source/split/LogSplit.java +2 -1
M fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/source/split/TieringSplitGenerator.java +2 -2
M fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/FlussSourceBuilderTest.java +1 -1
M fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/FlussSourceITCase.java +1 -1
M fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/enumerator/FlinkSourceEnumeratorTest.java +1 -1
Browse files at this commit →