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

projects / incubator-hugegraph-computer.git / commit

author	houzhizhen <houzhizhen_101@163.com>
	Wed, 7 Jul 2021 07:08:46 +0000 (15:08 +0800)
committer	GitHub <noreply@github.com>
	Wed, 7 Jul 2021 07:08:46 +0000 (15:08 +0800)
commit	644f725b9d3f81073b6c6ea7903654e9290d06a2
tree	39875c1153437df61cd06c5682c8e159fd87a2c2	tree \| snapshot
parent	25b9a337850f77d20889ecfcaa0d3f68d9e19407	commit \| diff

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		diff \| blob \| history
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]	blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/ComputeManager.java	[new file with mode: 0644]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/FileGraphPartition.java	[new file with mode: 0644]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/input/EdgesInput.java	[new file with mode: 0644]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/input/MessageInput.java	[new file with mode: 0644]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/input/ReusablePointer.java	[new file with mode: 0644]	blob
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/input/VertexInput.java	[new file with mode: 0644]	blob
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/graph/partition/PartitionStat.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/BufferedFileInput.java		diff \| blob \| history
computer-core/src/main/java/com/baidu/hugegraph/computer/core/output/LogOutput.java	[new file with mode: 0644]	blob
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/receiver/RecvMessageStat.java	[new file with mode: 0644]	blob
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/hgkvfile/entry/InlinePointer.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	[new file with mode: 0644]	blob
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/ComputeTestSuite.java	[new file with mode: 0644]	blob
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/MockComputation.java	[new file with mode: 0644]	blob
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/MockMessageSender.java	[new file with mode: 0644]	blob
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/input/EdgesInputTest.java	[new file with mode: 0644]	blob
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/input/MessageInputTest.java	[new file with mode: 0644]	blob
computer-test/src/main/java/com/baidu/hugegraph/computer/core/compute/input/ResuablePointerTest.java	[new file with mode: 0644]	blob
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/partition/PartitionStatTest.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/receiver/ReceiverUtil.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/worker/MockComputation.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/MockComputation2.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/MockMasterComputation.java		diff \| blob \| history
computer-test/src/main/java/com/baidu/hugegraph/computer/core/worker/MockMasterComputation2.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/MockComputation.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/UnitTestSuite.java		diff \| blob \| history

Apache HugeGraph (incubating)

RSS Atom