diff options
author | Jinfeng Ni <jni@maprtech.com> | 2014-04-29 15:04:43 -0700 |
---|---|---|
committer | Jacques Nadeau <jacques@apache.org> | 2014-05-03 17:58:47 -0700 |
commit | a3d1472037892a3ce2cf86a282cb67c43b488d62 (patch) | |
tree | 0b35b8593c8f75d83101977eec96b84f4e3fab9a /exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetFormatPlugin.java | |
parent | 69d90bbcd7e274d68bb41c4922e48dd51f44ef2b (diff) |
DRILL-491: project pushdown into scan. Add base test class for testing plan.
Project pushdown. Add a plan base test class. Add a clone method for GroupScan.
Minor change to DrillScanRel.getGroupScan().
Project push down : skip trivial project.
Enable the rule to remove trivial project in logical planning phase.
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetFormatPlugin.java')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetFormatPlugin.java | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetFormatPlugin.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetFormatPlugin.java index 4fd05871d..ec6456bb0 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetFormatPlugin.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetFormatPlugin.java @@ -18,9 +18,11 @@ package org.apache.drill.exec.store.parquet; import java.io.IOException; +import java.util.List; import java.util.Set; import java.util.regex.Pattern; +import org.apache.drill.common.expression.SchemaPath; import org.apache.drill.common.logical.StoragePluginConfig; import org.apache.drill.exec.server.DrillbitContext; import org.apache.drill.exec.store.StoragePluginOptimizerRule; @@ -100,7 +102,12 @@ public class ParquetFormatPlugin implements FormatPlugin{ @Override public ParquetGroupScan getGroupScan(FileSelection selection) throws IOException { - return new ParquetGroupScan(selection.getFileStatusList(fs), this, selection.selectionRoot); + return new ParquetGroupScan(selection.getFileStatusList(fs), this, selection.selectionRoot, null); + } + + @Override + public ParquetGroupScan getGroupScan(FileSelection selection, List<SchemaPath> columns) throws IOException { + return new ParquetGroupScan(selection.getFileStatusList(fs), this, selection.selectionRoot, columns); } @Override |