add WorkerService and MasterService (#27)
authorhouzhizhen <houzhizhen_101@163.com>
Fri, 9 Apr 2021 06:44:13 +0000 (14:44 +0800)
committerGitHub <noreply@github.com>
Fri, 9 Apr 2021 06:44:13 +0000 (14:44 +0800)
commit3bfed77bcd41292d08aeaeff2295bfc53b010d27
tree163b309735e40c02a9f05a3f80cae3cf95f8a3be
parentacd3434d7b0e6078e8fd09c54448a6578992f1eb
add WorkerService and MasterService (#27)

* rename input to inputStep
* MasterService does not implement MasterContext
* add name in Combiner and Computation
* add category in Computation
23 files changed:
computer-core/src/main/java/com/baidu/hugegraph/computer/core/aggregator/MasterAggrManager.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/aggregator/WorkerAggrManager.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/combiner/Combiner.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
computer-core/src/main/java/com/baidu/hugegraph/computer/core/config/ComputerOptions.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/config/Config.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/config/Null.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/graph/SuperstepStat.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/master/DefaultMasterComputation.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/master/MasterComputation.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/master/MasterService.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/StoreManager.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/Computation.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/Manager.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerService.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/common/ConfigTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/common/FakeMasterComputation.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/MockComputation.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/MockMasterComputation.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/MockWorkerService.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerServiceTest.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerTestSuite.java