ASF Git Repos - incubator-hugegraph-computer.git/commit

projects / incubator-hugegraph-computer.git / commit

author	Cong Zhao <zhaocong@apache.org>
	Thu, 19 May 2022 09:04:35 +0000 (17:04 +0800)
committer	GitHub <noreply@github.com>
	Thu, 19 May 2022 09:04:35 +0000 (17:04 +0800)
commit	180051786606fe7c93fcee66f66c50a6864072bf
tree	5439f2bd2be7b4a5eb0d79f1c9602348ba686db8	tree \| snapshot
parent	bcaef8563f15730b37b4d445cdf97a1f25c1e39f	commit \| diff

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		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/combiner/PointerCombiner.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/combiner/VertexValueCombiner.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/common/exception/TransportException.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/ComputeManager.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/FileGraphPartition.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/input/MessageInput.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/input/ReusablePointer.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/config/ComputerOptions.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/IOFactory.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/StreamGraphInput.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/StreamGraphOutput.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/DataClientManager.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/MessageHandler.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/TransportConf.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/TransportUtil.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/buffer/FileRegionBuffer.java	[new file with mode: 0644]	blob
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/message/AbstractMessage.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/message/DataMessage.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/message/FailMessage.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/message/Message.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/AbstractNettyHandler.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyClientHandler.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyProtocol.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyServerHandler.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyTransportClient.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyTransportServer.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/codec/MessageDecoder.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/codec/MessageEncoder.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/netty/codec/PreciseFrameDecoder.java	[new file with mode: 0644]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/session/ClientSession.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvBuffers.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvManager.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvPartition.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvPartitions.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sender/WriteBuffer.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/BufferFileSorter.java	[new file with mode: 0644]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/DefaultSorter.java	[new file with mode: 0644]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/HgkvFileSorter.java	[new file with mode: 0644]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/Sorter.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/SorterImpl.java	[deleted file]	blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/CombinableSorterFlusher.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/CombineKvInnerSortFlusher.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/CombineKvOuterSortFlusher.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/CombineSubKvInnerSortFlusher.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/CombineSubKvOuterSortFlusher.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/InnerSortFlusher.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/KvInnerSortFlusher.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/KvOuterSortFlusher.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/OuterSortFlusher.java		diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/InputSorter.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/InputsSorter.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/InputsSorterImpl.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/JavaInputSorter.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/SubKvSorter.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorting/RecvSortManager.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorting/SortManager.java		diff \| blob \| history
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]	diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/KvEntryFileReader.java	[new file with mode: 0644]	blob
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/bufferfile/BufferFileEntryBuilder.java	[new file with mode: 0644]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/bufferfile/BufferFileEntryReader.java	[new file with mode: 0644]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/bufferfile/BufferFileSubEntryReader.java	[new file with mode: 0644]	blob
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/file/select/InputFilesSelector.java	[new file with mode: 0644]	blob
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
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]	diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/InputToEntries.java	[deleted file]	blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/reader/HgkvDirReader.java	[deleted file]	blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/reader/HgkvFileReader.java	[deleted file]	blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/file/select/InputFilesSelector.java	[deleted file]	blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/combiner/PointerCombinerTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/ComputeManagerTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/input/EdgesInputTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/input/MessageInputTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/BufferedFileTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/network/MockClientHandler.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/network/MockMessageHandler.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/network/NetworkTestSuite.java		diff \| blob \| history
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]	diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyEncodeDecodeHandlerTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyTransportClientTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvBuffersTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvManagerTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/receiver/ReceiverUtil.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/receiver/edge/EdgeMessageRecvPartitionTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/receiver/message/ComputeMessageRecvPartitionTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/receiver/vertex/VertexMessageRecvPartitionTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sender/WriteBuffersTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sort/SorterTestUtil.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/FlusherTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/SortLargeDataTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/SorterTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/BitFileTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/EntriesUtilTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/EntryOutputTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/HgkvDirTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/HgkvFileTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/PointerTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/StoreTestUtil.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/ValueFileTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/suite/integrate/SenderIntegrateTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/suite/unit/UnitTestBase.java		diff \| blob \| history
pom.xml		diff \| blob \| history

Apache HugeGraph (incubating)

RSS Atom