fix FileGraphPartition and some warnings (#90)
authorJermy Li <lizhangmei@baidu.com>
Tue, 17 Aug 2021 03:21:43 +0000 (11:21 +0800)
committerGitHub <noreply@github.com>
Tue, 17 Aug 2021 03:21:43 +0000 (11:21 +0800)
commitb6341ca82f35f16160b5df7c5fa0fe110d788086
treee72a490a8606f089420d9aa2dea5d4850a0d7cb5
parent3a3483e605af4ad1aec904811121c85774ab6b9f
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
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/IntValue.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/LongValue.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/allocator/DefaultAllocator.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/bsp/Bsp4Master.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/bsp/Bsp4Worker.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/bsp/BspBase.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/io/AbstractBufferedFileOutput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/BufferedFileOutput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/master/MasterService.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/codec/MessageEncoder.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/message/ComputeMessageRecvPartition.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/PeekableIterator.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/FileManager.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/hgkvfile/entry/KvEntryReaderImpl.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/store/seqfile/ValueFileOutput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/util/ShutdownHook.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerService.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/MockComputation.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/graph/value/IntValueTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/network/netty/NettyTransportServerTest.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/SorterTest.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/StoreTestUtil.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/store/ValueFileTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/WorkerServiceTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/suite/integrate/SenderIntegrateTest.java