aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/store/pcapng/PcapngRecordReader.java
diff options
context:
space:
mode:
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.java4
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);
}