Refactor Writable and Readable class (#42)
authorLinary <liningrui@baidu.com>
Wed, 12 May 2021 04:02:47 +0000 (12:02 +0800)
committerGitHub <noreply@github.com>
Wed, 12 May 2021 04:02:47 +0000 (12:02 +0800)
commite8e60b9d9606ec41841f23f04f2a2d49b3ca9317
tree4df99682ef44bbac3d9da70c2352c6475a78280d
parentd85b22aeab3399321f792d4c5c8e009b0335d40f
Refactor Writable and Readable class (#42)

* Refactor Writable and Readable class

* Also simplify GraphOut and GraphInput

* remove ComputeException

* Add test for duplicate method

* fix write/read properties value type incorrect
64 files changed:
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/BooleanValue.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/DoubleValue.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/FloatValue.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/IdValue.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/IdValueList.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/IdValueListList.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/IntValue.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/ListValue.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/LongValue.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/NullValue.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/io/GraphInput.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/io/GraphOutput.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/io/RandomAccessInput.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/RandomAccessInput.java with 86% similarity]
computer-api/src/main/java/com/baidu/hugegraph/computer/core/io/RandomAccessOutput.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/RandomAccessOutput.java with 76% similarity]
computer-api/src/main/java/com/baidu/hugegraph/computer/core/io/Readable.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/io/Writable.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/common/Constants.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/common/ContainerInfo.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/common/exception/ComputeException.java [deleted file]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/common/exception/TransportException.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/graph/SuperstepStat.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/partition/PartitionStat.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/BufferedFileInput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/BufferedFileOutput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/BufferedStreamInput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/BufferedStreamOutput.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 [deleted file]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/OptimizedStreamGraphOutput.java [deleted file]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/OptimizedUnsafeBytesInput.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/OptimizedUnsafeBytesOutput.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/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/StructRandomAccessOutput.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/UnsafeBytesInput.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/UnsafeByteArrayInput.java with 93% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/UnsafeBytesOutput.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/UnsafeByteArrayOutput.java with 97% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/TransportUtil.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyTransportServer.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/session/ClientSession.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/util/ByteArrayUtil.java [deleted file]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/util/IdValueUtil.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/util/SerializeUtil.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerStat.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/UnitTestBase.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/id/LongIdTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/value/IdValueTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/value/MockCustomValue.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/BufferedFileTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/CsvStructGraphOutputTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/IOTestSuite.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/JsonStructGraphOutputTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/OptimizedUnsafeBytesTest.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/io/StructRandomAccessOutputTest.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/UnsafeByteArrayTest.java [deleted file]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/UnsafeBytesTest.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyTransportClientTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyTransportServerTest.java