Let Sender and Receiver process compute message with type MESSAGE_CLASS (#63)
authorhouzhizhen <houzhizhen_101@163.com>
Tue, 22 Jun 2021 08:53:10 +0000 (16:53 +0800)
committerGitHub <noreply@github.com>
Tue, 22 Jun 2021 08:53:10 +0000 (16:53 +0800)
commit429e081006545f53d4d5e5ce219e23c24c44be2a
treeb6c7c539062c73af7d9dc7c86d12704957361558
parentea4c7434b5236533a755e2452fb010e65201eb8a
Let Sender and Receiver process compute message with type MESSAGE_CLASS (#63)

* delete ValueFactory
* rename VALUE_CLASS to ALGORITHM_RESULT_CLASS, remove VALUE_TYPE
* add option OUTPUT_VALUE_NAME
* check channel not null in QueuedMessageSender#init
50 files changed:
computer-api/src/main/java/com/baidu/hugegraph/computer/core/common/ComputerContext.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/config/Config.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/GraphFactory.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/ListValue.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/ValueFactory.java [deleted file]
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/value/ValueType.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/io/GraphComputeInput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/aggregator/DefaultAggregator.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/config/ComputerOptions.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/config/DefaultConfig.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/config/HotConfig.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/graph/BuiltinGraphFactory.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/graph/properties/DefaultProperties.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/graph/value/BuiltinValueFactory.java [deleted file]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/JsonStructGraphOutput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/StreamGraphInput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/io/StreamGraphOutput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvBuffers.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/message/ComputeMessageRecvPartition.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sender/QueuedMessageSender.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/util/ComputerContextUtil.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/allocator/DefaultAllocatorTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/config/DefaultConfigTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/BuiltinGraphFactoryTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/DefaultEdgeTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/DefaultPropertiesTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/GraphTestSuite.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/value/BuiltinValueFactoryTest.java [deleted file]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/graph/value/MockCustomValue.java [deleted file]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/CsvStructGraphOutputTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/JsonStructGraphOutputTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/MockRankComputation.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/io/StreamGraphOutputInputTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/receiver/MessageRecvManagerTest.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/edge/EdgeMessageRecvPartitionTest.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/receiver/vertex/VertexMessageRecvPartitionTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sender/MessageSendBuffersTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sender/MockTransportClient.java [new file with mode: 0644]
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sender/MultiQueueTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sender/QueuedMessageSenderTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sender/WriteBufferTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sender/WriteBuffersTest.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/IntegrateTestSuite.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/UnitTestBase.java
computer-test/src/main/java/com/baidu/hugegraph/computer/suite/unit/UnitTestSuite.java