Implement StreamGraphInput and EntryInput (#60)
authorLinary <liningrui@baidu.com>
Fri, 18 Jun 2021 08:25:37 +0000 (16:25 +0800)
committerGitHub <noreply@github.com>
Fri, 18 Jun 2021 08:25:37 +0000 (16:25 +0800)
commit435d31af301e0613b54a36a2d1a198adc90325dc
treed3cccc5fe92775ab8a00ada01e186807a4b83307
parent2522a35b5db99f50fdd3b81f1e0bd53d78b7a692
Implement StreamGraphInput and EntryInput (#60)
13 files changed:
computer-api/src/main/java/com/baidu/hugegraph/computer/core/io/GraphComputeInput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/graph/vertex/DefaultVertex.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/StreamGraphInput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/StreamGraphOutput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/EntryInput.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/EntryInputImpl.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/KvEntryReader.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/KvEntryReaderImpl.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/StreamGraphOutputInputTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/receiver/ReceiverUtil.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sender/WriteBuffersTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/suite/unit/UnitTestBase.java
computer-test/src/main/java/com/baidu/hugegraph/computer/suite/unit/UnitTestSuite.java