add Bsp4Worker, Bsp4Master and Etcd based implementation (#9)
authorhouzhizhen <houzhizhen_101@163.com>
Thu, 4 Feb 2021 09:14:54 +0000 (17:14 +0800)
committerGitHub <noreply@github.com>
Thu, 4 Feb 2021 09:14:54 +0000 (17:14 +0800)
commite7302848ee9a89866f6a4e518242f75348a6a4c6
tree26bef534b888563a1425182d4aff5a0605f89d21
parentdfe7347b1ac8d88c42c5b4585f5f279aa6d75435
add Bsp4Worker, Bsp4Master and Etcd based implementation (#9)
29 files changed:
computer-core/src/main/java/com/baidu/hugegraph/computer/core/bsp/Bsp4Master.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/bsp/Bsp4Worker.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/bsp/BspBase.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/bsp/BspClient.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/bsp/BspEvent.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/bsp/EtcdBspClient.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/bsp/EtcdClient.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/common/Constants.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/common/ContainerInfo.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/config/ComputerOptions.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/graph/SuperstepStat.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/graph/partition/PartitionStat.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/util/JsonUtil.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/util/ReadWriteUtil.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerStat.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/UnitTestBase.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/UnitTestSuite.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/bsp/BspEventTest.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/bsp/BspTestSuite.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/bsp/EtcdBspTest.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/bsp/EtcdClientTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/common/CommonTestSuite.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/common/ContainerInfoTest.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/GraphTestSuite.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/SuperstepStatTest.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/partition/PartitionStatTest.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/util/JsonUtilTest.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerStatTest.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerTestSuite.java [new file with mode: 0644]