diff options
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/store/pcapng/PcapngRecordReader.java')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/store/pcapng/PcapngRecordReader.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/pcapng/PcapngRecordReader.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/pcapng/PcapngRecordReader.java index b1c5f2427..0ad234de7 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/pcapng/PcapngRecordReader.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/pcapng/PcapngRecordReader.java @@ -65,11 +65,11 @@ public class PcapngRecordReader extends AbstractRecordReader { private Iterator<IPcapngType> it; - public PcapngRecordReader(final String pathToFile, + public PcapngRecordReader(final Path pathToFile, final FileSystem fileSystem, final List<SchemaPath> columns) { this.fs = fileSystem; - this.pathToFile = fs.makeQualified(new Path(pathToFile)); + this.pathToFile = fs.makeQualified(pathToFile); this.columns = columns; setColumns(columns); } |