Implement vertex/edge fetcher to load data from hugegraph server (#18)
authorLinary <liningrui@baidu.com>
Mon, 15 Mar 2021 13:00:43 +0000 (21:00 +0800)
committerGitHub <noreply@github.com>
Mon, 15 Mar 2021 13:00:43 +0000 (21:00 +0800)
commit2b76996b0593c7a5e53f9e91816f196fa5e4c5f7
tree2b2b424d529df6776cd829bc73ffdd9ca86438b8
parent128ce85d0b02dec779792449ce923eb8a7e19df5
Implement vertex/edge fetcher to load data from hugegraph server (#18)

* Add install-hugegraph-from-source.sh

* Add HugeConverter
30 files changed:
.travis.yml
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/graph/id/IdFactory.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/input/EdgeFetcher.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/input/ElementFetcher.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/input/HugeConverter.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/input/InputSplit.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/input/InputSplitFetcher.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/input/MasterInputHandler.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/input/VertexFetcher.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/input/hg/HugeEdgeFetcher.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/input/hg/HugeElementFetcher.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/input/hg/HugeInputSplitFetcher.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/input/hg/HugeVertexFetcher.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/StreamGraphInput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/UnsafeByteArrayInput.java
computer-dist/src/assembly/travis/install-hugegraph-from-source.sh [new file with mode: 0755]
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
computer-test/src/main/java/com/baidu/hugegraph/computer/core/combiner/ValueMaxCombinerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/combiner/ValueMinCombinerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/id/IdFactoryTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/input/HugeConverterTest.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/input/InputSplitDataTest.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/input/InputTestSuite.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/input/MockRpcClient.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/input/MockWorkerInputHandler.java [new file with mode: 0644]
pom.xml