aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/planner/ParquetPartitionLocation.java
diff options
context:
space:
mode:
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.java8
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;
}
}