reconstruct StreamGraph{Input/Output} to associate with UnsafeByteArray{Input/Output...
authorhouzhizhen <houzhizhen_101@163.com>
Mon, 8 Feb 2021 13:04:36 +0000 (21:04 +0800)
committerGitHub <noreply@github.com>
Mon, 8 Feb 2021 13:04:36 +0000 (21:04 +0800)
commit7c7178acd45cc2720803c31cefd25b8d78c237f4
treedfbf6249df0347ab20b7de8d4191937ce23638e3
parent3773c5f4c8f6fb94912025aa9bb0971913bc7a6d
reconstruct StreamGraph{Input/Output} to associate with UnsafeByteArray{Input/Output} (#14)
19 files changed:
computer-core/src/main/java/com/baidu/hugegraph/computer/core/common/Constants.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/graph/id/LongId.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/graph/id/Utf8Id.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/graph/id/UuidId.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/graph/value/IdValue.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/CsvStructGraphOutput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/GraphOutputFactory.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/JsonStructGraphOutput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/OptimizedStreamGraphInput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/OptimizedStreamGraphOutput.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/io/StructGraphOutput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/UnsafeByteArrayInput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/UnsafeByteArrayOutput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/util/ReadWriteUtil.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/UnitTestBase.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/StreamGraphOutputInputTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/UnsafeByteArrayTest.java