aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageRecordReader.java
diff options
context:
space:
mode:
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageRecordReader.java')
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageRecordReader.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageRecordReader.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageRecordReader.java
index 2a4b4fb48..08ed4fd09 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageRecordReader.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageRecordReader.java
@@ -99,10 +99,10 @@ public class ImageRecordReader extends AbstractRecordReader {
private DrillBuf managedBuffer;
private boolean finish;
- public ImageRecordReader(FragmentContext context, DrillFileSystem fs, String inputPath,
+ public ImageRecordReader(FragmentContext context, DrillFileSystem fs, Path inputPath,
boolean fileSystemMetadata, boolean descriptive, String timeZone) {
this.fs = fs;
- hadoopPath = fs.makeQualified(new Path(inputPath));
+ hadoopPath = fs.makeQualified(inputPath);
this.fileSystemMetadata = fileSystemMetadata;
this.descriptive = descriptive;
this.timeZone = (timeZone != null) ? TimeZone.getTimeZone(timeZone) : TimeZone.getDefault();