diff options
| author | Steven Phillips <sphillips@maprtech.com> | 2015-03-25 18:35:20 -0700 |
|---|---|---|
| committer | Steven Phillips <smp@apache.org> | 2015-04-14 16:47:15 -0700 |
| commit | 96943de36128c9ceb2a8e8c5212cb2b3e4101e26 (patch) | |
| tree | e01e094755a784262c802904ef7b622bc2a44cf6 /exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/FooterGatherer.java | |
| parent | 7cee11c2bf24b0dd532f1068526bf7caecc9a935 (diff) | |
DRILL-2577: Use DrillPathFilter in FooterGatherer
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/FooterGatherer.java')
| -rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/FooterGatherer.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/FooterGatherer.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/FooterGatherer.java index 6498fd203..0bb86e168 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/FooterGatherer.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/FooterGatherer.java @@ -24,6 +24,7 @@ import java.util.List; import org.apache.commons.lang3.ArrayUtils; import org.apache.drill.exec.store.TimedRunnable; +import org.apache.drill.exec.store.dfs.DrillPathFilter; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FSDataInputStream; import org.apache.hadoop.fs.FileStatus; @@ -82,7 +83,7 @@ public class FooterGatherer { } // else we handle as normal file. - for(FileStatus inStatus : fs.listStatus(status.getPath())){ + for(FileStatus inStatus : fs.listStatus(status.getPath(), new DrillPathFilter())){ readers.add(new FooterReader(conf, inStatus)); } }else{ |