diff options
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/planner/ParquetPartitionLocation.java')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/planner/ParquetPartitionLocation.java | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/ParquetPartitionLocation.java b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/ParquetPartitionLocation.java index 49e51094d..eec0d5ebe 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/ParquetPartitionLocation.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/ParquetPartitionLocation.java @@ -17,6 +17,8 @@ */ package org.apache.drill.exec.planner; +import org.apache.hadoop.fs.Path; + /* * PartitionLocation for the parquet auto partitioning scheme. We just store * the location of each partition within this class. Since the partition value @@ -25,9 +27,9 @@ package org.apache.drill.exec.planner; * invoked. */ public class ParquetPartitionLocation extends SimplePartitionLocation { - private final String file; + private final Path file; - public ParquetPartitionLocation(String file) { + public ParquetPartitionLocation(Path file) { this.file = file; } @@ -48,7 +50,7 @@ public class ParquetPartitionLocation extends SimplePartitionLocation { * @return String location of the partition */ @Override - public String getEntirePartitionLocation() { + public Path getEntirePartitionLocation() { return file; } } |