add ComputeManager (#66)
authorhouzhizhen <houzhizhen_101@163.com>
Wed, 7 Jul 2021 07:08:46 +0000 (15:08 +0800)
committerGitHub <noreply@github.com>
Wed, 7 Jul 2021 07:08:46 +0000 (15:08 +0800)
commit644f725b9d3f81073b6c6ea7903654e9290d06a2
tree39875c1153437df61cd06c5682c8e159fd87a2c2
parent25b9a337850f77d20889ecfcaa0d3f68d9e19407
add ComputeManager (#66)

add class ComputeManager, FileGraphPartition, EdgesInput, MessageInput, ReusablePointer, VertexInput, LogOutput, MessageRecvStat
add class ComputeTestSuite, ComputeManagerTest, MockComputation, MockMessageSender, EdgesInputTest, EmptyEdgesTest, MessageInputTest
add method copy in IdValueList.
remove mergeGraph from MessageRecvManager;
add method recvStat in MessageRecvPartition
add method recvStats in MessageRecvPartitions
add methods merge(recvStat)recvStat in Partition
WorkerService links compute and output to corresponding methods in ComputeManager
move method writeMessage from ComputeMessageRecvPartitionTest to ReceiverUtil
38 files changed:
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/IdValueList.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/output/ComputerOutput.java [moved from computer-core/src/main/java/com/baidu/hugegraph/computer/core/output/ComputerOutput.java with 100% similarity]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/ComputeManager.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/FileGraphPartition.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/input/EdgesInput.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/input/MessageInput.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/input/ReusablePointer.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/input/VertexInput.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/config/ComputerOptions.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/output/LogOutput.java [new file with mode: 0644]
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/receiver/RecvMessageStat.java [new file with mode: 0644]
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/hgkvfile/entry/InlinePointer.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 [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/ComputeTestSuite.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/MockComputation.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/MockMessageSender.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/input/EdgesInputTest.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/input/MessageInputTest.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/input/ResuablePointerTest.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/partition/PartitionStatTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/BufferedFileTest.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/message/ComputeMessageRecvPartitionTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/MockComputation.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/MockComputation2.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/MockMasterComputation.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/MockMasterComputation2.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/MockComputation.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/UnitTestSuite.java