projects / incubator-hugegraph-computer.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 0d2e6df) | patch
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
tree790a82ecbbdbba53e44133c8b35e099176e0f52ctree | snapshot
parent0d2e6dfd4d5138760cc9f77e2683ea93af238a56commit | diff
feature: support partition concurrent compute (#177)
14 files changed:
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/ComputeManager.java diff | blob | history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/FileGraphPartition.java diff | blob | history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/config/ComputerOptions.java diff | blob | history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/input/WorkerInputManager.java diff | blob | history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/DataClientManager.java diff | blob | history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sender/MessageSendBuffers.java diff | blob | history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sender/MessageSendManager.java diff | blob | history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sender/MessageSendPartition.java [new file with mode: 0644] blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/JavaInputSorter.java diff | blob | history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/util/Consumers.java [new file with mode: 0644] blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerService.java diff | blob | history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/ComputeManagerTest.java diff | blob | history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/input/EdgesInputTest.java diff | blob | history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sender/MessageSendBuffersTest.java diff | blob | history
Apache HugeGraph (incubating)