fix

apache · Aug 21, 2024 · 15fe3ea · 15fe3ea
1 parent 033d245
commit 15fe3ea
Show file tree

Hide file tree

Showing 15 changed files with 16 additions and 53 deletions.
diff --git a/computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/bsp/Bsp4Master.java b/computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/bsp/Bsp4Master.java
@@ -54,7 +54,7 @@ public List<ContainerInfo> waitWorkersInitDone() {
         LOG.info("Master is waiting for workers init-done");
         String path = this.constructPath(BspEvent.BSP_WORKER_INIT_DONE);
         List<byte[]> serializedContainers = this.waitOnWorkersEvent(
-                                            path, this.registerTimeout());
+                path, this.registerTimeout());
         List<ContainerInfo> containers = new ArrayList<>(this.workerCount());
         for (byte[] serializedContainer : serializedContainers) {
             ContainerInfo container = new ContainerInfo();
@@ -110,7 +110,7 @@ public List<WorkerStat> waitWorkersStepDone(int superstep) {
         String path = this.constructPath(BspEvent.BSP_WORKER_STEP_DONE,
                                          superstep);
         List<byte[]> list = this.waitOnWorkersEvent(path,
-                            this.barrierOnWorkersTimeout());
+                                                    this.barrierOnWorkersTimeout());
         List<WorkerStat> result = new ArrayList<>(this.workerCount());
         for (byte[] bytes : list) {
             WorkerStat workerStat = new WorkerStat();

diff --git a/...re/src/main/java/org/apache/hugegraph/computer/core/combiner/AbstractPointerCombiner.java b/...re/src/main/java/org/apache/hugegraph/computer/core/combiner/AbstractPointerCombiner.java
@@ -24,6 +24,7 @@
 import org.apache.hugegraph.computer.core.io.BytesOutput;
 import org.apache.hugegraph.computer.core.io.IOFactory;
 import org.apache.hugegraph.computer.core.io.RandomAccessInput;
+import org.apache.hugegraph.computer.core.io.Readable;
 import org.apache.hugegraph.computer.core.io.Writable;
 import org.apache.hugegraph.computer.core.store.entry.InlinePointer;
 import org.apache.hugegraph.computer.core.store.entry.Pointer;

diff --git a/.../computer-core/src/main/java/org/apache/hugegraph/computer/core/common/ContainerInfo.java b/.../computer-core/src/main/java/org/apache/hugegraph/computer/core/common/ContainerInfo.java
@@ -22,6 +22,7 @@
 
 import org.apache.hugegraph.computer.core.io.RandomAccessInput;
 import org.apache.hugegraph.computer.core.io.RandomAccessOutput;
+import org.apache.hugegraph.computer.core.io.Readable;
 import org.apache.hugegraph.computer.core.io.Writable;
 import org.apache.hugegraph.computer.core.network.TransportUtil;
 import org.apache.hugegraph.computer.core.util.JsonUtil;

diff --git a/...-core/src/main/java/org/apache/hugegraph/computer/core/compute/input/ReusablePointer.java b/...-core/src/main/java/org/apache/hugegraph/computer/core/compute/input/ReusablePointer.java
@@ -24,6 +24,7 @@
 import org.apache.hugegraph.computer.core.io.IOFactory;
 import org.apache.hugegraph.computer.core.io.RandomAccessInput;
 import org.apache.hugegraph.computer.core.io.RandomAccessOutput;
+import org.apache.hugegraph.computer.core.io.Readable;
 import org.apache.hugegraph.computer.core.store.entry.Pointer;
 import org.apache.hugegraph.computer.core.util.BytesUtil;
 

diff --git a/...r/computer-core/src/main/java/org/apache/hugegraph/computer/core/graph/SuperstepStat.java b/...r/computer-core/src/main/java/org/apache/hugegraph/computer/core/graph/SuperstepStat.java
@@ -24,6 +24,7 @@
 import org.apache.hugegraph.computer.core.graph.partition.PartitionStat;
 import org.apache.hugegraph.computer.core.io.RandomAccessInput;
 import org.apache.hugegraph.computer.core.io.RandomAccessOutput;
+import org.apache.hugegraph.computer.core.io.Readable;
 import org.apache.hugegraph.computer.core.io.Writable;
 import org.apache.hugegraph.computer.core.util.JsonUtil;
 import org.apache.hugegraph.computer.core.worker.WorkerStat;

diff --git a/...-core/src/main/java/org/apache/hugegraph/computer/core/graph/partition/PartitionStat.java b/...-core/src/main/java/org/apache/hugegraph/computer/core/graph/partition/PartitionStat.java
@@ -21,6 +21,7 @@
 
 import org.apache.hugegraph.computer.core.io.RandomAccessInput;
 import org.apache.hugegraph.computer.core.io.RandomAccessOutput;
+import org.apache.hugegraph.computer.core.io.Readable;
 import org.apache.hugegraph.computer.core.io.Writable;
 import org.apache.hugegraph.computer.core.receiver.MessageStat;
 import org.apache.hugegraph.computer.core.util.JsonUtil;

diff --git a/...omputer-core/src/main/java/org/apache/hugegraph/computer/core/store/entry/EntryInput.java b/...omputer-core/src/main/java/org/apache/hugegraph/computer/core/store/entry/EntryInput.java
@@ -18,6 +18,7 @@
 package org.apache.hugegraph.computer.core.store.entry;
 
 import java.io.IOException;
+import org.apache.hugegraph.computer.core.io.Readable;
 
 public interface EntryInput {
 

diff --git a/...ter-core/src/main/java/org/apache/hugegraph/computer/core/store/entry/EntryInputImpl.java b/...ter-core/src/main/java/org/apache/hugegraph/computer/core/store/entry/EntryInputImpl.java
@@ -20,6 +20,7 @@
 import java.io.IOException;
 
 import org.apache.hugegraph.computer.core.io.RandomAccessInput;
+import org.apache.hugegraph.computer.core.io.Readable;
 
 public class EntryInputImpl implements EntryInput {
 

diff --git a/...uter-core/src/main/java/org/apache/hugegraph/computer/core/store/entry/KvEntryReader.java b/...uter-core/src/main/java/org/apache/hugegraph/computer/core/store/entry/KvEntryReader.java
@@ -19,6 +19,8 @@
 
 import java.io.IOException;
 
+import org.apache.hugegraph.computer.core.io.Readable;
+
 public interface KvEntryReader {
 
     void readSubKv(Readable subKey, Readable subValue) throws IOException;

diff --git a/...-core/src/main/java/org/apache/hugegraph/computer/core/store/entry/KvEntryReaderImpl.java b/...-core/src/main/java/org/apache/hugegraph/computer/core/store/entry/KvEntryReaderImpl.java
@@ -21,6 +21,7 @@
 
 import org.apache.hugegraph.computer.core.common.exception.ComputerException;
 import org.apache.hugegraph.computer.core.io.RandomAccessInput;
+import org.apache.hugegraph.computer.core.io.Readable;
 
 public class KvEntryReaderImpl implements KvEntryReader {
 

diff --git a/...er/computer-core/src/main/java/org/apache/hugegraph/computer/core/util/SerializeUtil.java b/...er/computer-core/src/main/java/org/apache/hugegraph/computer/core/util/SerializeUtil.java
@@ -27,6 +27,7 @@
 import org.apache.hugegraph.computer.core.io.BytesInput;
 import org.apache.hugegraph.computer.core.io.BytesOutput;
 import org.apache.hugegraph.computer.core.io.IOFactory;
+import org.apache.hugegraph.computer.core.io.Readable;
 import org.apache.hugegraph.computer.core.io.Writable;
 
 public final class SerializeUtil {

diff --git a/...ter/computer-core/src/main/java/org/apache/hugegraph/computer/core/worker/WorkerStat.java b/...ter/computer-core/src/main/java/org/apache/hugegraph/computer/core/worker/WorkerStat.java
@@ -25,6 +25,7 @@
 import org.apache.hugegraph.computer.core.graph.partition.PartitionStat;
 import org.apache.hugegraph.computer.core.io.RandomAccessInput;
 import org.apache.hugegraph.computer.core.io.RandomAccessOutput;
+import org.apache.hugegraph.computer.core.io.Readable;
 import org.apache.hugegraph.computer.core.io.Writable;
 import org.apache.hugegraph.computer.core.util.JsonUtil;
 import org.apache.hugegraph.util.E;

diff --git a/computer/computer-test/src/main/java/org/apache/hugegraph/computer/GenOption.java b/computer/computer-test/src/main/java/org/apache/hugegraph/computer/GenOption.java
diff --git a/...computer-test/src/main/java/org/apache/hugegraph/computer/core/receiver/ReceiverUtil.java b/...computer-test/src/main/java/org/apache/hugegraph/computer/core/receiver/ReceiverUtil.java
@@ -25,6 +25,7 @@
 import org.apache.hugegraph.computer.core.io.BytesOutput;
 import org.apache.hugegraph.computer.core.io.IOFactory;
 import org.apache.hugegraph.computer.core.io.RandomAccessInput;
+import org.apache.hugegraph.computer.core.io.Readable;
 import org.apache.hugegraph.computer.core.io.StreamGraphInput;
 import org.apache.hugegraph.computer.core.io.Writable;
 import org.apache.hugegraph.computer.core.network.buffer.NettyBuffer;

diff --git a/...er/computer-test/src/main/java/org/apache/hugegraph/computer/suite/unit/UnitTestBase.java b/...er/computer-test/src/main/java/org/apache/hugegraph/computer/suite/unit/UnitTestBase.java
@@ -41,6 +41,7 @@
 import org.apache.hugegraph.computer.core.io.RandomAccessInput;
 import org.apache.hugegraph.computer.core.io.RandomAccessOutput;
 import org.apache.hugegraph.computer.core.io.StreamGraphInput;
+import org.apache.hugegraph.computer.core.io.Readable;
 import org.apache.hugegraph.computer.core.io.StreamGraphOutput;
 import org.apache.hugegraph.computer.core.io.Writable;
 import org.apache.hugegraph.computer.core.store.entry.EntryInput;