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

projects / incubator-hugegraph-computer.git / commit

author	Jermy Li <lizhangmei@baidu.com>
	Tue, 17 Aug 2021 03:21:43 +0000 (11:21 +0800)
committer	GitHub <noreply@github.com>
	Tue, 17 Aug 2021 03:21:43 +0000 (11:21 +0800)
commit	b6341ca82f35f16160b5df7c5fa0fe110d788086
tree	e72a490a8606f089420d9aa2dea5d4850a0d7cb5	tree \| snapshot
parent	3a3483e605af4ad1aec904811121c85774ab6b9f	commit \| diff

fix FileGraphPartition and some warnings (#90)

* improve FileGraphPartition
* fix warnings
* fix warnings of test
* fix MessageInputTest
* fix tow workers shared one data_dirs

37 files changed:

computer-api/src/main/java/com/baidu/hugegraph/computer/core/combiner/ValueMinCombiner.java		diff \| blob \| history
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/DoubleValue.java		diff \| blob \| history
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/FloatValue.java		diff \| blob \| history
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/IntValue.java		diff \| blob \| history
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/LongValue.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/allocator/DefaultAllocator.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/bsp/Bsp4Master.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/bsp/Bsp4Worker.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/bsp/BspBase.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/io/AbstractBufferedFileOutput.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/BufferedFileOutput.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/master/MasterService.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/codec/MessageEncoder.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/message/ComputeMessageRecvPartition.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/PeekableIterator.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/FileManager.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/KvEntryReaderImpl.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/seqfile/ValueFileOutput.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/util/ShutdownHook.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerService.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/MockComputation.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/graph/value/IntValueTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyTransportServerTest.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/SorterTest.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/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/core/worker/WorkerServiceTest.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/suite/integrate/SenderIntegrateTest.java		diff \| blob \| history

Apache HugeGraph (incubating)

RSS Atom