>From <[email protected]>:
[email protected] has uploaded this change for review. (
https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/19028 )
Change subject: fix without projection unnest
......................................................................
fix without projection unnest
Change-Id: I7602fb59ae79eb31aae6d177bab912ecc8301d9d
---
M
hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/AbstractUnnestPOperator.java
1 file changed, 10 insertions(+), 8 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/28/19028/1
diff --git
a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/AbstractUnnestPOperator.java
b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/AbstractUnnestPOperator.java
index a985b2c..03acebf 100644
---
a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/AbstractUnnestPOperator.java
+++
b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/AbstractUnnestPOperator.java
@@ -18,16 +18,12 @@
*/
package org.apache.hyracks.algebricks.core.algebra.operators.physical;
-import java.util.ArrayList;
-import java.util.List;
-
import org.apache.hyracks.algebricks.common.exceptions.AlgebricksException;
import org.apache.hyracks.algebricks.core.algebra.base.IHyracksJobBuilder;
import org.apache.hyracks.algebricks.core.algebra.base.ILogicalExpression;
import org.apache.hyracks.algebricks.core.algebra.base.ILogicalOperator;
import org.apache.hyracks.algebricks.core.algebra.base.IOptimizationContext;
import org.apache.hyracks.algebricks.core.algebra.base.LogicalExpressionTag;
-import org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable;
import
org.apache.hyracks.algebricks.core.algebra.expressions.AbstractFunctionCallExpression;
import
org.apache.hyracks.algebricks.core.algebra.expressions.AbstractFunctionCallExpression.FunctionKind;
import
org.apache.hyracks.algebricks.core.algebra.expressions.IExpressionRuntimeProvider;
@@ -91,10 +87,7 @@
if (unnest.isProjectPushed()) {
projectionList = JobGenHelper.projectVariables(inputSchemas[0],
unnest.getProjectVariables());
} else {
- List<LogicalVariable> outputVariables = new
ArrayList<>(unnest.getVariables());
- if (unnest.hasPositionalVariable())
- outputVariables.add(unnest.getPositionalVariable());
- projectionList = JobGenHelper.projectVariables(inputSchemas[0],
outputVariables);
+ projectionList = JobGenHelper.projectAllVariables(opSchema);
}
IUnnestingPositionWriterFactory positionWriterFactory =
unnest.hasPositionalVariable() ?
context.getUnnestingPositionWriterFactory() : null;
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/19028
To unsubscribe, or for help writing mail filters, visit
https://asterix-gerrit.ics.uci.edu/settings
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Change-Id: I7602fb59ae79eb31aae6d177bab912ecc8301d9d
Gerrit-Change-Number: 19028
Gerrit-PatchSet: 1
Gerrit-Owner: [email protected]
Gerrit-MessageType: newchange
