This is an automated email from the ASF dual-hosted git repository.
alsuliman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb.git
The following commit(s) were added to refs/heads/master by this push:
new fe301a1 [ASTERIXDB-2551][*DB] Use Ordered Property in range merge
POperator
fe301a1 is described below
commit fe301a1a344ab8ac856386f3da082a52b7377d73
Author: Stephen Ermshar <[email protected]>
AuthorDate: Mon Mar 11 09:41:43 2019 -0700
[ASTERIXDB-2551][*DB] Use Ordered Property in range merge POperator
- user model changes: no
- storage format changes: no
- interface changes: no
details:
- Create the IPartitioningProperty using the orderedPartitionedProperty
instead of creating the list to be used in an unorderedPartitionProperty.
Change-Id: I044e2219fff7564864f68fa0df849d1102b4bb20
Reviewed-on: https://asterix-gerrit.ics.uci.edu/3261
Sonar-Qube: Jenkins <[email protected]>
Tested-by: Jenkins <[email protected]>
Integration-Tests: Jenkins <[email protected]>
Reviewed-by: Ali Alsuliman <[email protected]>
---
.../operators/physical/RangePartitionMergeExchangePOperator.java | 9 ++-------
1 file changed, 2 insertions(+), 7 deletions(-)
diff --git
a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/RangePartitionMergeExchangePOperator.java
b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/RangePartitionMergeExchangePOperator.java
index b015193..ee43f3f 100644
---
a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/RangePartitionMergeExchangePOperator.java
+++
b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/RangePartitionMergeExchangePOperator.java
@@ -23,7 +23,6 @@ import java.util.LinkedList;
import java.util.List;
import org.apache.hyracks.algebricks.common.exceptions.AlgebricksException;
-import org.apache.hyracks.algebricks.common.utils.ListSet;
import org.apache.hyracks.algebricks.common.utils.Pair;
import
org.apache.hyracks.algebricks.core.algebra.base.IHyracksJobBuilder.TargetConstraint;
import org.apache.hyracks.algebricks.core.algebra.base.ILogicalOperator;
@@ -44,7 +43,7 @@ import
org.apache.hyracks.algebricks.core.algebra.properties.LocalOrderProperty;
import org.apache.hyracks.algebricks.core.algebra.properties.OrderColumn;
import
org.apache.hyracks.algebricks.core.algebra.properties.PhysicalRequirements;
import
org.apache.hyracks.algebricks.core.algebra.properties.StructuralPropertiesVector;
-import
org.apache.hyracks.algebricks.core.algebra.properties.UnorderedPartitionedProperty;
+import
org.apache.hyracks.algebricks.core.algebra.properties.OrderedPartitionedProperty;
import org.apache.hyracks.algebricks.core.jobgen.impl.JobGenContext;
import org.apache.hyracks.algebricks.data.IBinaryComparatorFactoryProvider;
import
org.apache.hyracks.algebricks.data.INormalizedKeyComputerFactoryProvider;
@@ -85,11 +84,7 @@ public class RangePartitionMergeExchangePOperator extends
AbstractExchangePOpera
@Override
public void computeDeliveredProperties(ILogicalOperator op,
IOptimizationContext context) {
- List<LogicalVariable> varList = new ArrayList<LogicalVariable>();
- for (OrderColumn oc : partitioningFields) {
- varList.add(oc.getColumn());
- }
- IPartitioningProperty p = new UnorderedPartitionedProperty(new
ListSet<LogicalVariable>(varList), domain);
+ IPartitioningProperty p = new
OrderedPartitionedProperty(partitioningFields, domain);
AbstractLogicalOperator op2 = (AbstractLogicalOperator)
op.getInputs().get(0).getValue();
List<ILocalStructuralProperty> op2Locals =
op2.getDeliveredPhysicalProperties().getLocalProperties();
List<ILocalStructuralProperty> locals = new
ArrayList<ILocalStructuralProperty>();
