diff --git a/parquet-hadoop/src/main/java/parquet/hadoop/ParquetInputFormat.java b/parquet-hadoop/src/main/java/parquet/hadoop/ParquetInputFormat.java index 0231ccd720..c3f7d81cbb 100644 --- a/parquet-hadoop/src/main/java/parquet/hadoop/ParquetInputFormat.java +++ b/parquet-hadoop/src/main/java/parquet/hadoop/ParquetInputFormat.java @@ -89,7 +89,7 @@ public class ParquetInputFormat extends FileInputFormat { * key to configure the filter */ public static final String UNBOUND_RECORD_FILTER = "parquet.read.filter"; - + /** * key to configure type checking for conflicting schemas (default: true) */ @@ -414,23 +414,21 @@ private static void checkSorted(List rowGroupBlocks) { @Override public List getSplits(JobContext jobContext) throws IOException { List splits = new ArrayList(); - splits.addAll(getSplits(ContextUtil.getConfiguration(jobContext), getFooters(jobContext))); + splits.addAll(getSplitsWithCachedFooters(ContextUtil.getConfiguration(jobContext), getCachedFooters(jobContext))); return splits; } - /** - * @param configuration the configuration to connect to the file system - * @param footers the footers of the files to read - * @return the splits for the footers - * @throws IOException - */ - public List getSplits(Configuration configuration, List