aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetFormatPlugin.java
diff options
context:
space:
mode:
authorJinfeng Ni <jni@maprtech.com>2014-04-29 15:04:43 -0700
committerJacques Nadeau <jacques@apache.org>2014-05-03 17:58:47 -0700
commita3d1472037892a3ce2cf86a282cb67c43b488d62 (patch)
tree0b35b8593c8f75d83101977eec96b84f4e3fab9a /exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetFormatPlugin.java
parent69d90bbcd7e274d68bb41c4922e48dd51f44ef2b (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.java9
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