commit df9830b802687284afb3225b267e06cac7915e22
author JArod <jarodwen@gmail.com> Fri Nov 01 09:56:13 2013 -0400
committer JArod <jarodwen@gmail.com> Mon Nov 04 17:46:40 2013 -0500
tree 0566a76538e653ffb6bb5cde18d83a2bb32a72c3
parent 26974ae51a50f6e2b9d59b3c4c113fa23de575a2

reverted the change of removing adjacent exchange operators

algebricks/algebricks-rewriter/src/main/java/edu/uci/ics/hyracks/algebricks/rewriter/rules/EnforceStructuralPropertiesRule.java

diff --git a/algebricks/algebricks-rewriter/src/main/java/edu/uci/ics/hyracks/algebricks/rewriter/rules/EnforceStructuralPropertiesRule.java b/algebricks/algebricks-rewriter/src/main/java/edu/uci/ics/hyracks/algebricks/rewriter/rules/EnforceStructuralPropertiesRule.java
index 11122d7..810defc 100644
--- a/algebricks/algebricks-rewriter/src/main/java/edu/uci/ics/hyracks/algebricks/rewriter/rules/EnforceStructuralPropertiesRule.java
+++ b/algebricks/algebricks-rewriter/src/main/java/edu/uci/ics/hyracks/algebricks/rewriter/rules/EnforceStructuralPropertiesRule.java
@@ -540,10 +540,6 @@
                 }
             }
             Mutable<ILogicalOperator> ci = op.getInputs().get(i);
-            if (((AbstractLogicalOperator) ci.getValue()).getOperatorTag() == LogicalOperatorTag.EXCHANGE) {
-                ci = ci.getValue().getInputs().get(0);
-                op.getInputs().set(i, ci);
-            }
             ExchangeOperator exchg = new ExchangeOperator();
             exchg.setPhysicalOperator(pop);
             setNewOp(ci, exchg, context);