Add computation interface (#17)
authorhouzhizhen <houzhizhen_101@163.com>
Fri, 26 Mar 2021 02:41:24 +0000 (10:41 +0800)
committerGitHub <noreply@github.com>
Fri, 26 Mar 2021 02:41:24 +0000 (10:41 +0800)
commit32390d3898b6c656044d19060dfe71b8c3aeba77
tree7a9698d43ca46d71e9de3694a2a92e4b1f59b2aa
parentc8e21001429b60488407f66117a7992fa8cece8e
Add computation interface (#17)

* Add computation interface

* add FilterMapComputation and ReduceComputation

* add MasterComputation
12 files changed:
computer-core/src/main/java/com/baidu/hugegraph/computer/core/aggregator/Aggregator.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/aggregator/Aggregator4Master.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/aggregator/Aggregator4Worker.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/master/DefaultMasterComputation.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/master/MasterComputation.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/master/MasterContext.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/Computation.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/ComputationContext.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/FilterMapComputation.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/ReduceComputation.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerContext.java [new file with mode: 0644]