Steven Jacobs has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/2726
Change subject: [COMP] Maintain schemas for delegate operators
......................................................................
[COMP] Maintain schemas for delegate operators
Change-Id: Icc8723e686d741bf3098ff44d046cde5239e204b
---
M
asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SetupCommitExtensionOpRule.java
M
hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/DelegateOperator.java
2 files changed, 3 insertions(+), 0 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/26/2726/1
diff --git
a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SetupCommitExtensionOpRule.java
b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SetupCommitExtensionOpRule.java
index cc50dce..3981d20 100644
---
a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SetupCommitExtensionOpRule.java
+++
b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SetupCommitExtensionOpRule.java
@@ -101,11 +101,13 @@
CommitOperator commitOperator = new
CommitOperator(primaryKeyLogicalVars, isSink);
CommitPOperator commitPOperator = new CommitPOperator(dataset,
primaryKeyLogicalVars, isSink);
commitOperator.setPhysicalOperator(commitPOperator);
+ commitOperator.setSchema(op.getSchema());
//create ExtensionOperator and put the commitOperator in it.
DelegateOperator extensionOperator = new
DelegateOperator(commitOperator);
extensionOperator.setSourceLocation(eOp.getSourceLocation());
extensionOperator.setPhysicalOperator(commitPOperator);
+ extensionOperator.setSchema(op.getSchema());
//update plan link
extensionOperator.getInputs().add(eOp.getInputs().get(0));
diff --git
a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/DelegateOperator.java
b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/DelegateOperator.java
index 3667e6b..8df57e5 100644
---
a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/DelegateOperator.java
+++
b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/logical/DelegateOperator.java
@@ -51,6 +51,7 @@
public void recomputeSchema() throws AlgebricksException {
schema = new
ArrayList<LogicalVariable>(inputs.get(0).getValue().getSchema());
delegate.setSchema(schema);
+ this.setSchema(schema);
}
@Override
--
To view, visit https://asterix-gerrit.ics.uci.edu/2726
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: Icc8723e686d741bf3098ff44d046cde5239e204b
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <[email protected]>
