From a3d1472037892a3ce2cf86a282cb67c43b488d62 Mon Sep 17 00:00:00 2001 From: Jinfeng Ni Date: Tue, 29 Apr 2014 15:04:43 -0700 Subject: 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. --- .../org/apache/drill/exec/store/parquet/ParquetFormatPlugin.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetFormatPlugin.java') 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 columns) throws IOException { + return new ParquetGroupScan(selection.getFileStatusList(fs), this, selection.selectionRoot, columns); } @Override -- cgit v1.2.3