ASF Git Repos - incubator-hugegraph-computer.git/commit

projects / incubator-hugegraph-computer.git / commit

author	houzhizhen <houzhizhen_101@163.com>
	Fri, 9 Apr 2021 06:44:13 +0000 (14:44 +0800)
committer	GitHub <noreply@github.com>
	Fri, 9 Apr 2021 06:44:13 +0000 (14:44 +0800)
commit	3bfed77bcd41292d08aeaeff2295bfc53b010d27
tree	163b309735e40c02a9f05a3f80cae3cf95f8a3be	tree \| snapshot
parent	acd3434d7b0e6078e8fd09c54448a6578992f1eb	commit \| diff

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]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/aggregator/WorkerAggrManager.java	[new file with mode: 0644]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/combiner/Combiner.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/common/Constants.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/common/ContainerInfo.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/config/Config.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/config/Null.java	[new file with mode: 0644]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/graph/SuperstepStat.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/master/DefaultMasterComputation.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/master/MasterComputation.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/master/MasterService.java	[new file with mode: 0644]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/StoreManager.java	[new file with mode: 0644]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/Computation.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/Manager.java	[new file with mode: 0644]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerService.java	[new file with mode: 0644]	blob
computer-test/src/main/java/com/baidu/hugegraph/computer/core/common/ConfigTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/common/FakeMasterComputation.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/MockComputation.java	[new file with mode: 0644]	blob
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/MockMasterComputation.java	[new file with mode: 0644]	blob
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/MockWorkerService.java	[new file with mode: 0644]	blob
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerServiceTest.java	[new file with mode: 0644]	blob
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerTestSuite.java		diff \| blob \| history

Apache HugeGraph (incubating)

RSS Atom