rename package

apache · Mar 29, 2024 · 07b0750 · 07b0750
1 parent 13468ca
commit 07b0750
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 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
@@ -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
@@ -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;