feature: support partition concurrent compute (#177)
authorShouJing <1075185785@qq.com>
Thu, 19 May 2022 06:10:26 +0000 (14:10 +0800)
committerGitHub <noreply@github.com>
Thu, 19 May 2022 06:10:26 +0000 (14:10 +0800)
commitbcaef8563f15730b37b4d445cdf97a1f25c1e39f
tree790a82ecbbdbba53e44133c8b35e099176e0f52c
parent0d2e6dfd4d5138760cc9f77e2683ea93af238a56
feature: support partition concurrent compute (#177)
14 files changed:
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/ComputeManager.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/FileGraphPartition.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/config/ComputerOptions.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/input/WorkerInputManager.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/DataClientManager.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sender/MessageSendBuffers.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sender/MessageSendManager.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sender/MessageSendPartition.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/JavaInputSorter.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/util/Consumers.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerService.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/ComputeManagerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/input/EdgesInputTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sender/MessageSendBuffersTest.java