diff --git a/pom.xml b/pom.xml index d55aa5fa4..36301aa73 100644 --- a/pom.xml +++ b/pom.xml @@ -53,7 +53,7 @@ 32.1.3-jre 2.0.9 2.2 - 0.8.0-SNAPSHOT + 0.9.0-SNAPSHOT 23.5.26 diff --git a/s3stream/pom.xml b/s3stream/pom.xml index 6f78c80c0..93afce96d 100644 --- a/s3stream/pom.xml +++ b/s3stream/pom.xml @@ -22,7 +22,7 @@ 4.0.0 com.automq.elasticstream s3stream - 0.8.0-SNAPSHOT + 0.9.0-SNAPSHOT 5.5.0 5.10.0 diff --git a/s3stream/src/main/java/com/automq/stream/utils/biniarysearch/AbstractOrderedCollection.java b/s3stream/src/main/java/com/automq/stream/utils/biniarysearch/AbstractOrderedCollection.java index f004abd31..838bf2333 100644 --- a/s3stream/src/main/java/com/automq/stream/utils/biniarysearch/AbstractOrderedCollection.java +++ b/s3stream/src/main/java/com/automq/stream/utils/biniarysearch/AbstractOrderedCollection.java @@ -19,9 +19,9 @@ public abstract class AbstractOrderedCollection { - abstract int size(); + protected abstract int size(); - abstract ComparableItem get(int index); + protected abstract ComparableItem get(int index); public int search(T target) { int low = 0; diff --git a/s3stream/src/main/java/com/automq/stream/utils/biniarysearch/IndexBlockOrderedBytes.java b/s3stream/src/main/java/com/automq/stream/utils/biniarysearch/IndexBlockOrderedBytes.java index 841bf3a00..e86546e77 100644 --- a/s3stream/src/main/java/com/automq/stream/utils/biniarysearch/IndexBlockOrderedBytes.java +++ b/s3stream/src/main/java/com/automq/stream/utils/biniarysearch/IndexBlockOrderedBytes.java @@ -27,12 +27,12 @@ public IndexBlockOrderedBytes(ByteBuf byteBuf) { } @Override - int size() { + protected int size() { return this.byteBuf.readableBytes() / ComparableStreamRange.SIZE; } @Override - ComparableItem get(int index) { + protected ComparableItem get(int index) { int start = index * ComparableStreamRange.SIZE; long streamId = this.byteBuf.getLong(start); long startOffset = this.byteBuf.getLong(start + 8); diff --git a/s3stream/src/main/java/com/automq/stream/utils/biniarysearch/StreamRecordBatchList.java b/s3stream/src/main/java/com/automq/stream/utils/biniarysearch/StreamRecordBatchList.java index b70e7d787..6a5f6143c 100644 --- a/s3stream/src/main/java/com/automq/stream/utils/biniarysearch/StreamRecordBatchList.java +++ b/s3stream/src/main/java/com/automq/stream/utils/biniarysearch/StreamRecordBatchList.java @@ -37,7 +37,7 @@ public int size() { } @Override - ComparableItem get(int index) { + protected ComparableItem get(int index) { return records.get(index); }