diff options
| author | Mehant Baid <mehantr@gmail.com> | 2014-08-11 18:04:30 -0700 |
|---|---|---|
| committer | Aditya Kishore <aditya@maprtech.com> | 2014-08-18 14:56:52 +0530 |
| commit | 81bd7527846318610a3367e4bd756d269fedfb9c (patch) | |
| tree | 6b901a76e51e5b278ff904f0fb76ce5fa14e8fd4 /exec/java-exec/src | |
| parent | d4a07dbc6e492f5c9a071772c470b6f4b54c10d1 (diff) | |
DRILL-1278: Fix selecting scalar field from a map with join clause.
Diffstat (limited to 'exec/java-exec/src')
| -rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/project/ProjectRecordBatch.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/project/ProjectRecordBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/project/ProjectRecordBatch.java index 1ba010347..fcc216f9b 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/project/ProjectRecordBatch.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/project/ProjectRecordBatch.java @@ -309,6 +309,7 @@ public class ProjectRecordBatch extends AbstractSingleRecordBatch<Project>{ String outputName = getRef(namedExpression).getRootSegment().getPath(); if (result != null && result.outputNames != null && result.outputNames.size() > 0) { + // TODO: Revisit this logic. It is possible that the output names array does not contain the expression of interest in index 0 if (result.outputNames.get(0) == EMPTY_STRING) continue; outputName = result.outputNames.get(0); } @@ -406,11 +407,10 @@ public class ProjectRecordBatch extends AbstractSingleRecordBatch<Project>{ if (!(ex.getExpr() instanceof SchemaPath)) continue; NameSegment expr = ((SchemaPath) ex.getExpr()).getRootSegment(); NameSegment ref = ex.getRef().getRootSegment(); - boolean exprHasPrefix = expr.getPath().contains(StarColumnHelper.PREFIX_DELIMITER); boolean refHasPrefix = ref.getPath().contains(StarColumnHelper.PREFIX_DELIMITER); boolean exprContainsStar = expr.getPath().contains(StarColumnHelper.STAR_COLUMN); - if (exprHasPrefix || refHasPrefix || exprContainsStar) { + if (refHasPrefix || exprContainsStar) { needed = true; break; } |