From 07b0750ae940c1708f3de6f806c9403dffd8db25 Mon Sep 17 00:00:00 2001
From: CooooolFrog <zuliangwanghust@gmail.com>
Date: Fri, 29 Mar 2024 15:23:31 +0800
Subject: [PATCH] rename package

---
 .../src/test/java/org/apache/horaedb/QueryClientTest.java | 6 ++++--
 .../src/test/java/org/apache/horaedb/WriteClientTest.java | 8 ++++----
 2 files changed, 8 insertions(+), 6 deletions(-)

diff --git a/horaedb-protocol/src/test/java/org/apache/horaedb/QueryClientTest.java b/horaedb-protocol/src/test/java/org/apache/horaedb/QueryClientTest.java
index cb2e741..fa76658 100644
--- a/horaedb-protocol/src/test/java/org/apache/horaedb/QueryClientTest.java
+++ b/horaedb-protocol/src/test/java/org/apache/horaedb/QueryClientTest.java
@@ -41,6 +41,8 @@
 import org.apache.arrow.vector.VectorSchemaRoot;
 import org.apache.arrow.vector.ipc.ArrowStreamWriter;
 import org.apache.arrow.vector.types.pojo.Field;
+import org.apache.horaedb.proto.internal.Common;
+import org.apache.horaedb.proto.internal.Storage;
 import org.junit.After;
 import org.junit.Assert;
 import org.junit.Before;
@@ -89,7 +91,7 @@ public void after() {
 
     @Test
     public void queryOkNoRouteTest() throws ExecutionException, InterruptedException, IOException {
-        final SqlQueryResponse resp = mockSimpleQueryResponse(1, false);
+        final Storage.SqlQueryResponse resp = mockSimpleQueryResponse(1, false);
         final Endpoint ep = Endpoint.of("127.0.0.1", 8081);
 
         Mockito.when(this.routerClient.invoke(Mockito.eq(ep), Mockito.any(), Mockito.any())) //
@@ -385,7 +387,7 @@ private Storage.SqlQueryResponse mockAllTypeQueryResponse(int rowCount) throws I
         writer.writeBatch();
         writer.close();
 
-        ArrowPayload arrowPayload = Storage.ArrowPayload.newBuilder()
+        Storage.ArrowPayload arrowPayload = Storage.ArrowPayload.newBuilder()
                 .setCompression(Storage.ArrowPayload.Compression.NONE)
                 .addRecordBatches(ByteStringHelper.wrap(out.toByteArray())).build();
 
diff --git a/horaedb-protocol/src/test/java/org/apache/horaedb/WriteClientTest.java b/horaedb-protocol/src/test/java/org/apache/horaedb/WriteClientTest.java
index 441643f..c0a9302 100644
--- a/horaedb-protocol/src/test/java/org/apache/horaedb/WriteClientTest.java
+++ b/horaedb-protocol/src/test/java/org/apache/horaedb/WriteClientTest.java
@@ -18,12 +18,14 @@
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
+import org.apache.horaedb.common.Endpoint;
+import org.apache.horaedb.common.util.Clock;
 import org.apache.horaedb.models.Point;
 import org.apache.horaedb.models.RequestContext;
 import org.apache.horaedb.models.Value;
 import org.apache.horaedb.models.WriteRequest;
-import io.ceresdb.proto.internal.Common;
-import io.ceresdb.proto.internal.Storage;
+import org.apache.horaedb.proto.internal.Common;
+import org.apache.horaedb.proto.internal.Storage;
 import org.junit.After;
 import org.junit.Assert;
 import org.junit.Before;
@@ -33,8 +35,6 @@
 import org.mockito.Mockito;
 import org.mockito.runners.MockitoJUnitRunner;
 
-import io.ceresdb.common.Endpoint;
-import io.ceresdb.common.util.Clock;
 import org.apache.horaedb.models.Err;
 import org.apache.horaedb.models.Result;
 import org.apache.horaedb.models.WriteOk;