Wenhai Li has uploaded a new change for review. https://asterix-gerrit.ics.uci.edu/729
Change subject: Initial step of parallel sort related operators The following commits from your working branch will be included: ...................................................................... Initial step of parallel sort related operators The following commits from your working branch will be included: commit ba4868a8acc5ac783512be3c959cb3e81f44ce09 Merge: 10bc6ac 8f81363 Author: Michael <[email protected]> Date: Thu Mar 17 20:40:02 2016 -0700 Merged master onto PSort commit 10bc6ac737ad7812e1aa62c94482b271d76e1bc7 Author: Michael <[email protected]> Date: Thu Mar 17 17:45:10 2016 -0700 Local file test commit 33b214712917133f369b3bd32427b89401a7731d Author: Michael <[email protected]> Date: Thu Mar 17 16:57:50 2016 -0700 First version of sample sort commit 47b957528b76a7546d585586cfd3da3d6d95db4c Author: Michael <[email protected]> Date: Thu Dec 3 02:58:45 2015 -0800 Parallel sort commit 7487152f591b2df6a559c87c98e5eabd066dbc22 Author: Michael <[email protected]> Date: Sun Sep 20 14:49:08 2015 -0700 Review the file header commit bf46ee5a435e87dbb689869aa3f8e8605c56e741 Author: Michael <[email protected]> Date: Sat Sep 19 17:57:03 2015 -0700 Commit for one-to-one partition Change-Id: I4ad9a4728c768839781bf01d754ba5c88c832365 --- M algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/base/PhysicalOperatorTag.java A algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/expressions/SortMergeJoinExpressionAnnotation.java M hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/context/IHyracksTaskContext.java M hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/dataflow/value/ITuplePartitionComputerFactory.java M hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/Task.java M hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/data/partition/FieldHashPartitionComputerFactory.java M hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/data/partition/RandomPartitionComputerFactory.java M hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/data/partition/RepartitionComputerFactory.java M hyracks/hyracks-dataflow-common/src/main/java/org/apache/hyracks/dataflow/common/data/partition/range/FieldRangePartitionComputerFactory.java M hyracks/hyracks-dataflow-hadoop/src/main/java/org/apache/hyracks/dataflow/hadoop/data/HadoopHashTuplePartitionComputerFactory.java M hyracks/hyracks-dataflow-hadoop/src/main/java/org/apache/hyracks/dataflow/hadoop/data/HadoopNewPartitionerTuplePartitionComputerFactory.java M hyracks/hyracks-dataflow-hadoop/src/main/java/org/apache/hyracks/dataflow/hadoop/data/HadoopPartitionerTuplePartitionComputerFactory.java M hyracks/hyracks-dataflow-hadoop/src/main/java/org/apache/hyracks/dataflow/hadoop/mapreduce/HashPartitioningShuffleConnectorDescriptor.java M hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/LocalityAwareMToNPartitioningConnectorDescriptor.java M hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/MToNPartitioningConnectorDescriptor.java M hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/MToNPartitioningMergingConnectorDescriptor.java M hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/connectors/MToNPartitioningWithMessageConnectorDescriptor.java M hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/join/GraceHashJoinOperatorNodePushable.java M hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/join/GraceHashJoinPartitionBuildOperatorNodePushable.java M hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/join/HybridHashJoinOperatorDescriptor.java M hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/join/InMemoryHashJoinOperatorDescriptor.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/AbstractSampleOperatorDescriptor.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/AbstractSamplingWriter.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/AbstractStreamingHistogram.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/BlockingForwardOperatorDescriptor.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/DTStreamingHistogram.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/DefaultSamplingWriter.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/DualSerialEntry.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/FieldRangePartitionDelayComputerFactory.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/ForwardOperatorNodePushable.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/IDTHistogram.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/IHistogram.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/IIterativeHistogram.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/ISequentialAccessor.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/ISequentialTrie.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/IStatisticEntity.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/IStatisticNode.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/IStatisticTernaryNode.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/MaterializingForwardOperatorDescriptor.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/MaterializingSampleOperatorDescriptor.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/MaterializingSampleOperatorNodePushable.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/MaterializingSampleTaskState.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/MemoryTernaryNode.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/MergeOrderedSampleWriter.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/MergeSampleOperatorDescriptor.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/MergeSampleOperatorNodePushable.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/OrderedSamplingWriter.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/QuantileSamplingWriter.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/SampleAlgorithm.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/SampleConnectorPolicyAssignmentPolicy.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/SampleReaderOperatorNodePushable.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/SampleUtils.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/SampledRangeMapTaskState.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/SequentialAccessor.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/TernaryIterativeHistogram.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/TernaryMemoryTrie.java A hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/sample/ValueSerialEntry.java A hyracks/hyracks-dataflow-std/src/test/java/org/apache/hyracks/dataflow/std/sample/TrieTests.java A hyracks/hyracks-dataflow-std/src/test/java/org/apache/hyracks/dataflow/std/sample/TypeTranslateTest.java A hyracks/hyracks-examples/hyracks-integration-tests/src/test/java/org/apache/hyracks/tests/integration/ConnectorPolicyAssignmentPolicy.java A hyracks/hyracks-examples/hyracks-integration-tests/src/test/java/org/apache/hyracks/tests/integration/SampleBandJoinTest.java A hyracks/hyracks-examples/hyracks-integration-tests/src/test/java/org/apache/hyracks/tests/integration/SampleForwardTest.java A hyracks/hyracks-examples/hyracks-integration-tests/src/test/java/org/apache/hyracks/tests/util/SampleAlgorithmTests.java M hyracks/hyracks-test-support/src/main/java/org/apache/hyracks/test/support/TestTaskContext.java 64 files changed, 7,353 insertions(+), 35 deletions(-) git pull ssh://asterix-gerrit.ics.uci.edu:29418/hyracks refs/changes/29/729/1 -- To view, visit https://asterix-gerrit.ics.uci.edu/729 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: newchange Gerrit-Change-Id: I4ad9a4728c768839781bf01d754ba5c88c832365 Gerrit-PatchSet: 1 Gerrit-Project: hyracks Gerrit-Branch: master Gerrit-Owner: Wenhai Li <[email protected]>
