调整开源hbase实现类依赖

jd-opensource · Dec 16, 2020 · 9fbd8c4 · 9fbd8c4
1 parent 2928858
commit 9fbd8c4
Show file tree

Hide file tree

Showing 4 changed files with 35 additions and 413 deletions.
diff --git a/...eue-archive-api/src/main/java/org/joyqueue/server/archive/store/query/QueryCondition.java b/...eue-archive-api/src/main/java/org/joyqueue/server/archive/store/query/QueryCondition.java
@@ -18,6 +18,8 @@
 import org.joyqueue.server.archive.store.model.Query;
 import org.joyqueue.server.archive.store.utils.ArchiveSerializer;
 
+import java.util.Arrays;
+
 /**
  * Created by chengzhiliang on 2018/12/4.
  */
@@ -77,6 +79,17 @@ public void setStartRowKeyByteArr(String startRowKeyByteArr) {
         this.startRowKeyByteArr = bytes;
     }
 
+    @Override
+    public String toString() {
+        return "QueryCondition{" +
+                "startRowKey=" + startRowKey +
+                ", stopRowKey=" + stopRowKey +
+                ", count=" + count +
+                ", rowKey=" + rowKey +
+                ", startRowKeyByteArr=" + Arrays.toString(startRowKeyByteArr) +
+                '}';
+    }
+
     /**
      * 查询RowKey
      */
@@ -118,5 +131,14 @@ public void setMessageId(String messageId) {
             this.messageId = messageId;
         }
 
+        @Override
+        public String toString() {
+            return "RowKey{" +
+                    "topic='" + topic + '\'' +
+                    ", time=" + time +
+                    ", businessId='" + businessId + '\'' +
+                    ", messageId='" + messageId + '\'' +
+                    '}';
+        }
     }
 }
diff --git a/...yqueue-archive-hbase/src/main/java/org/joyqueue/server/archive/store/HBaseSerializer.java b/...yqueue-archive-hbase/src/main/java/org/joyqueue/server/archive/store/HBaseSerializer.java