feat(s3stream): make AbstractOrderedCollection could be extented by o…

…thers (#863) Signed-off-by: Robin Han <[email protected]>
AutoMQ · Dec 28, 2023 · 18ff310 · 18ff310
1 parent 0f5121a
commit 18ff310
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 7 deletions.
diff --git a/pom.xml b/pom.xml
@@ -53,7 +53,7 @@
         <guava.version>32.1.3-jre</guava.version>
         <slf4j.version>2.0.9</slf4j.version>
         <snakeyaml.version>2.2</snakeyaml.version>
-        <s3stream.version>0.8.0-SNAPSHOT</s3stream.version>
+        <s3stream.version>0.9.0-SNAPSHOT</s3stream.version>
 
         <!-- Flat buffers related -->
         <flatbuffers.version>23.5.26</flatbuffers.version>

diff --git a/s3stream/pom.xml b/s3stream/pom.xml
@@ -22,7 +22,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.automq.elasticstream</groupId>
     <artifactId>s3stream</artifactId>
-    <version>0.8.0-SNAPSHOT</version>
+    <version>0.9.0-SNAPSHOT</version>
     <properties>
         <mockito-core.version>5.5.0</mockito-core.version>
         <junit-jupiter.version>5.10.0</junit-jupiter.version>

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
@@ -19,9 +19,9 @@
 
 public abstract class AbstractOrderedCollection<T> {
 
-    abstract int size();
+    protected abstract int size();
 
-    abstract ComparableItem<T> get(int index);
+    protected abstract ComparableItem<T> 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
@@ -27,12 +27,12 @@ public IndexBlockOrderedBytes(ByteBuf byteBuf) {
     }
 
     @Override
-    int size() {
+    protected int size() {
         return this.byteBuf.readableBytes() / ComparableStreamRange.SIZE;
     }
 
     @Override
-    ComparableItem<TargetStreamOffset> get(int index) {
+    protected ComparableItem<TargetStreamOffset> 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
@@ -37,7 +37,7 @@ public int size() {
     }
 
     @Override
-    ComparableItem<Long> get(int index) {
+    protected ComparableItem<Long> get(int index) {
         return records.get(index);
     }