>From Ali Alsuliman <[email protected]>:
Ali Alsuliman has uploaded this change for review. (
https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20515?usp=email )
Change subject: Eliminate shared ops
......................................................................
Eliminate shared ops
Change-Id: Ie07cd81d857fb194f1e4d2fff73eabc2bb401db6
---
M
asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/LangExpressionToPlanTranslator.java
1 file changed, 6 insertions(+), 2 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/15/20515/1
diff --git
a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/LangExpressionToPlanTranslator.java
b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/LangExpressionToPlanTranslator.java
index 98c832a..2c61f8c 100644
---
a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/LangExpressionToPlanTranslator.java
+++
b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/LangExpressionToPlanTranslator.java
@@ -345,7 +345,9 @@
DelegateOperator delegateOperator = new DelegateOperator(new
CommitOperator(true));
delegateOperator.getInputs().add(new MutableObject<>(upsertOp));
delegateOperator.setSourceLocation(sourceLoc);
- return new ALogicalPlanImpl(new MutableObject<>(delegateOperator));
+ ALogicalPlanImpl plan = new ALogicalPlanImpl(new
MutableObject<>(delegateOperator));
+ eliminateSharedOperatorReferenceForPlan(plan);
+ return plan;
} else {
throw new CompilationException(ErrorCode.COMPILATION_ERROR,
sourceLoc, "Unrecognized Statement Type",
stmt.getKind());
@@ -481,7 +483,9 @@
newTop.getInputs().add(new MutableObject<>(writeOperator));
globalPlanRoots.add(new MutableObject<>(newTop));
- return new ALogicalPlanImpl(globalPlanRoots);
+ ALogicalPlanImpl plan = new ALogicalPlanImpl(globalPlanRoots);
+ eliminateSharedOperatorReferenceForPlan(plan);
+ return plan;
}
private String getSeparator(String adapter, boolean isFileStore) {
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20515?usp=email
To unsubscribe, or for help writing mail filters, visit
https://asterix-gerrit.ics.uci.edu/settings?usp=email
Gerrit-MessageType: newchange
Gerrit-Project: asterixdb
Gerrit-Branch: phoenix
Gerrit-Change-Id: Ie07cd81d857fb194f1e4d2fff73eabc2bb401db6
Gerrit-Change-Number: 20515
Gerrit-PatchSet: 1
Gerrit-Owner: Ali Alsuliman <[email protected]>
