feature: optimize data receiving (#181) master
authorCong Zhao <zhaocong@apache.org>
Thu, 19 May 2022 09:04:35 +0000 (17:04 +0800)
committerGitHub <noreply@github.com>
Thu, 19 May 2022 09:04:35 +0000 (17:04 +0800)
commit180051786606fe7c93fcee66f66c50a6864072bf
tree5439f2bd2be7b4a5eb0d79f1c9602348ba686db8
parentbcaef8563f15730b37b4d445cdf97a1f25c1e39f
feature: optimize data receiving (#181)

* use zero-copy optimize data recv
* remove fail message
* improve some config
* support buffer file sort
* support sort with buffer file and fix some unit test
* create target file
* rebuild sort module

Co-authored-by: ShouJing <1075185785@qq.com>
151 files changed:
computer-core/src/main/java/com/baidu/hugegraph/computer/core/combiner/AbstractPointerCombiner.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/combiner/PointerCombiner.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/combiner/VertexValueCombiner.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/common/exception/TransportException.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/ComputeManager.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/FileGraphPartition.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/input/MessageInput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/input/ReusablePointer.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/config/ComputerOptions.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/IOFactory.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/network/DataClientManager.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/MessageHandler.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/TransportConf.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/TransportUtil.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/buffer/FileRegionBuffer.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/buffer/NettyBuffer.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/buffer/NettyManagedBuffer.java with 91% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/buffer/NetworkBuffer.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/buffer/ManagedBuffer.java with 88% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/buffer/NioBuffer.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/buffer/NioManagedBuffer.java with 91% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/message/AbstractMessage.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/message/DataMessage.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/message/FailMessage.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/message/Message.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/AbstractNettyHandler.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyClientHandler.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyProtocol.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyServerHandler.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyTransportClient.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/netty/codec/MessageDecoder.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/codec/MessageEncoder.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/codec/PreciseFrameDecoder.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/session/ClientSession.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvBuffers.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvManager.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvPartition.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvPartitions.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sender/WriteBuffer.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/BufferFileSorter.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/DefaultSorter.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/HgkvFileSorter.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/Sorter.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/SorterImpl.java [deleted file]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/CombinableSorterFlusher.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/CombineKvInnerSortFlusher.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/CombineKvOuterSortFlusher.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/CombineSubKvInnerSortFlusher.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/CombineSubKvOuterSortFlusher.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/InnerSortFlusher.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/KvInnerSortFlusher.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/KvOuterSortFlusher.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/OuterSortFlusher.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/merge/FileMerger.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/merge/HgkvDirMerger.java with 69% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/merge/FileMergerImpl.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/merge/HgkvDirMergerImpl.java with 70% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/InputSorter.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/InputsSorter.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/InputsSorterImpl.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/JavaInputSorter.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/SubKvSorter.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorting/RecvSortManager.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorting/SortManager.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/EntryIterator.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/buffer/EntryIterator.java with 89% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/KvEntryFileReader.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/KvEntryFileWriter.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/builder/HgkvDirBuilder.java with 80% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/buffer/KvEntriesInput.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/buffer/KvEntriesInput.java with 89% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/buffer/KvEntriesWithFirstSubKvInput.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/buffer/KvEntriesWithFirstSubKvInput.java with 86% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/buffer/SubKvEntriesInput.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/buffer/SubKvEntriesInput.java with 90% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/AbstractKvEntry.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/AbstractKvEntry.java with 95% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/CachedPointer.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/CachedPointer.java with 97% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/DefaultKvEntry.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/DefaultKvEntry.java with 95% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/EntriesUtil.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/EntriesUtil.java with 96% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/EntryInput.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/EntryInput.java with 96% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/EntryInputImpl.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/EntryInputImpl.java with 96% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/EntryOutput.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/EntryOutput.java with 96% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/EntryOutputImpl.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/EntryOutputImpl.java with 97% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/InlinePointer.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/InlinePointer.java with 97% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/KvEntry.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/KvEntry.java with 93% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/KvEntryReader.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/KvEntryReader.java with 94% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/KvEntryReaderImpl.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/KvEntryReaderImpl.java with 96% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/KvEntryWithFirstSubKv.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/KvEntryWithFirstSubKv.java with 95% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/KvEntryWriter.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/KvEntryWriter.java with 94% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/KvEntryWriterImpl.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/KvEntryWriterImpl.java with 96% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/Pointer.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/Pointer.java with 94% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/entry/Range.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/Range.java with 93% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/bufferfile/BufferFileEntryBuilder.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/bufferfile/BufferFileEntryReader.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/bufferfile/BufferFileSubEntryReader.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/hgkvfile/AbstractHgkvFile.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/AbstractHgkvFile.java with 96% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/hgkvfile/HgkvDir.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/HgkvDir.java with 95% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/hgkvfile/HgkvDirImpl.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/HgkvDirImpl.java with 98% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/hgkvfile/HgkvFile.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/HgkvFile.java with 96% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/hgkvfile/HgkvFileImpl.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/HgkvFileImpl.java with 97% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/hgkvfile/builder/BlockBuilder.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/builder/BlockBuilder.java with 89% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/hgkvfile/builder/DataBlockBuilderImpl.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/builder/DataBlockBuilderImpl.java with 93% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/hgkvfile/builder/HgkvDirBuilderImpl.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/builder/HgkvDirBuilderImpl.java with 91% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/hgkvfile/builder/HgkvFileBuilder.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/builder/HgkvFileBuilder.java with 91% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/hgkvfile/builder/HgkvFileBuilderImpl.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/builder/HgkvFileBuilderImpl.java with 95% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/hgkvfile/builder/IndexBlockBuilder.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/builder/IndexBlockBuilder.java with 94% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/hgkvfile/builder/IndexBlockBuilderImpl.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/builder/IndexBlockBuilderImpl.java with 96% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/hgkvfile/reader/HgkvDir4SubKvReaderImpl.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/reader/HgkvDir4SubKvReaderImpl.java with 79% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/hgkvfile/reader/HgkvDirReaderImpl.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/reader/HgkvDirReaderImpl.java with 85% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/hgkvfile/reader/HgkvFileReaderImpl.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/reader/HgkvFileReaderImpl.java with 77% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/select/DefaultSelectedFiles.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/select/DefaultSelectedFiles.java with 95% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/select/DisperseEvenlySelector.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/select/DisperseEvenlySelector.java with 78% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/select/InputFilesSelector.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/select/SelectedFiles.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/select/SelectedFiles.java with 93% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/seqfile/BitsFileReader.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/seqfile/BitsFileReader.java with 95% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/seqfile/BitsFileReaderImpl.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/seqfile/BitsFileReaderImpl.java with 97% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/seqfile/BitsFileWriter.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/seqfile/BitsFileWriter.java with 96% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/seqfile/BitsFileWriterImpl.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/seqfile/BitsFileWriterImpl.java with 97% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/seqfile/ValueFile.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/seqfile/ValueFile.java with 97% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/seqfile/ValueFileInput.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/seqfile/ValueFileInput.java with 99% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/seqfile/ValueFileOutput.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/seqfile/ValueFileOutput.java with 99% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/InputToEntries.java [deleted file]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/reader/HgkvDirReader.java [deleted file]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/reader/HgkvFileReader.java [deleted file]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/select/InputFilesSelector.java [deleted file]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/combiner/PointerCombinerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/ComputeManagerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/input/EdgesInputTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/input/MessageInputTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/BufferedFileTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/network/MockClientHandler.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/network/MockMessageHandler.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/network/NetworkTestSuite.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/network/buffer/NetworkBufferTest.java [moved from computer-test/src/main/java/com/baidu/hugegraph/computer/core/network/buffer/ManagedBufferTest.java with 66% similarity]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyEncodeDecodeHandlerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyTransportClientTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvBuffersTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvManagerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/receiver/ReceiverUtil.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/receiver/edge/EdgeMessageRecvPartitionTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/receiver/message/ComputeMessageRecvPartitionTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/receiver/vertex/VertexMessageRecvPartitionTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sender/WriteBuffersTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sort/SorterTestUtil.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/FlusherTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/SortLargeDataTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/SorterTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/BitFileTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/EntriesUtilTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/EntryOutputTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/HgkvDirTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/HgkvFileTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/PointerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/StoreTestUtil.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/ValueFileTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/suite/integrate/SenderIntegrateTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/suite/unit/UnitTestBase.java
pom.xml