add hdfs output (#114)
authorcoderzc <zc1217zc@126.com>
Mon, 18 Oct 2021 02:05:31 +0000 (10:05 +0800)
committerGitHub <noreply@github.com>
Mon, 18 Oct 2021 02:05:31 +0000 (10:05 +0800)
commit847abed47562e466d13c1969dd7e2b1a4b2f7d3e
tree8b39d79734605a65e7e00b48aba11441fb89254d
parentdec7e2993df09610a43e0dfa034c66530707ce2c
add hdfs output (#114)

* add hsfd output
* statistics execute cost
* fix problems with using the same Config object for SenderIntegrateTest
15 files changed:
.github/workflows/ci.yml
computer-algorithm/src/main/java/com/baidu/hugegraph/computer/algorithm/centrality/pagerank/PageRankOutput.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/output/hg/PageRankOutput.java with 92% similarity]
computer-algorithm/src/main/java/com/baidu/hugegraph/computer/algorithm/centrality/pagerank/PageRankParams.java
computer-algorithm/src/main/java/com/baidu/hugegraph/computer/algorithm/community/trianglecount/TriangleCountValue.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/output/ComputerOutput.java
computer-core/pom.xml
computer-core/src/main/java/com/baidu/hugegraph/computer/core/config/ComputerOptions.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/master/MasterService.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/output/hdfs/HdfsOutput.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/output/hdfs/HdfsOutputMerger.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/util/ComputerContextUtil.java
computer-test/pom.xml
computer-test/src/main/java/com/baidu/hugegraph/computer/algorithm/centrality/degree/DegreeCentralityTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/suite/integrate/SenderIntegrateTest.java
pom.xml