Change in asterixdb[master]: [COMP] Maintain schemas for delegate operators

[Steven Jacobs (Code Review)]

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 <sjaco...@ucr.edu>