refactor combiner: add v3 as result param (#169)
authorShouJing <1075185785@qq.com>
Fri, 24 Dec 2021 07:14:40 +0000 (15:14 +0800)
committerGitHub <noreply@github.com>
Fri, 24 Dec 2021 07:14:40 +0000 (15:14 +0800)
commit8308ffdd4872ed16d321336e55cb1305c323c7c2
tree246fd69e05bf4cfb43b77c2219ab4627e675eb02
parentbb0bbd0c09b6cf438c9f5c8cbf214b04065454a3
refactor combiner: add v3 as result param (#169)
49 files changed:
computer-api/src/main/java/com/baidu/hugegraph/computer/core/combiner/Combiner.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/combiner/DoubleValueSumCombiner.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/combiner/FloatValueSumCombiner.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/combiner/IntValueSumCombiner.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/combiner/LongValueSumCombiner.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/combiner/MergeNewPropertiesCombiner.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/combiner/MergeOldPropertiesCombiner.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/combiner/OverwriteCombiner.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/combiner/OverwritePropertiesCombiner.java [new file with mode: 0644]
computer-api/src/main/java/com/baidu/hugegraph/computer/core/combiner/ValueMaxCombiner.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/combiner/ValueMinCombiner.java
computer-api/src/main/java/com/baidu/hugegraph/computer/core/graph/properties/Properties.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/aggregator/DefaultAggregator.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/combiner/AbstractPointerCombiner.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/combiner/EdgeValueCombiner.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/combiner/MessageValueCombiner.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/combiner/PointerCombiner.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/combiner/VertexValueCombiner.java [new file with mode: 0644]
computer-core/src/main/java/com/baidu/hugegraph/computer/core/compute/input/EdgesInput.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/config/ComputerOptions.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/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/edge/EdgeMessageRecvPartition.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/receiver/vertex/VertexMessageRecvPartition.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/CombinableSorterFlusher.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/CombineKvInnerSortFlusher.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/CombineKvOuterSortFlusher.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/CombineSubKvInnerSortFlusher.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/CombineSubKvOuterSortFlusher.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/flusher/InnerSortFlusher.java
computer-core/src/main/java/com/baidu/hugegraph/computer/core/sort/sorting/SortManager.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/combiner/DoubleValueSumCombinerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/combiner/FloatValueSumCombinerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/combiner/IntValueSumCombinerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/combiner/LongValueSumCombinerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/combiner/MergeNewPropertiesCombinerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/combiner/MergeOldPropertiesCombinerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/combiner/OverwriteCombinerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/combiner/PointerCombinerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/combiner/ValueMaxCombinerTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/combiner/ValueMinCombinerTest.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/sort/SorterTestUtil.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sort/combiner/MockIntSumCombiner.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/SortLargeDataTest.java
computer-test/src/main/java/com/baidu/hugegraph/computer/core/sort/sorter/SorterTest.java