diff options
| author | Vitalii Diravka <vitalii.diravka@gmail.com> | 2019-02-18 22:30:36 +0200 |
|---|---|---|
| committer | Vitalii Diravka <vitalii.diravka@gmail.com> | 2019-03-05 16:32:05 +0200 |
| commit | 3d29faf81da593035f6bd38dd56d48e719afe7d4 (patch) | |
| tree | d77b926b0de304677bf81a883e20e9776f986ea0 /contrib/format-syslog/src/main/java/org/apache | |
| parent | 7e3b45967dbb97da18ba49a2fa6a67a48e33b092 (diff) | |
DRILL-5603: Replace String file paths to Hadoop Path
- replaced all String path representation with org.apache.hadoop.fs.Path
- added PathSerDe.Se JSON serializer
- refactoring of DFSPartitionLocation code by leveraging existing listPartitionValues() functionality
closes #1657
Diffstat (limited to 'contrib/format-syslog/src/main/java/org/apache')
| -rw-r--r-- | contrib/format-syslog/src/main/java/org/apache/drill/exec/store/syslog/SyslogRecordReader.java | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/contrib/format-syslog/src/main/java/org/apache/drill/exec/store/syslog/SyslogRecordReader.java b/contrib/format-syslog/src/main/java/org/apache/drill/exec/store/syslog/SyslogRecordReader.java index a198e3444..4b2831c2d 100644 --- a/contrib/format-syslog/src/main/java/org/apache/drill/exec/store/syslog/SyslogRecordReader.java +++ b/contrib/format-syslog/src/main/java/org/apache/drill/exec/store/syslog/SyslogRecordReader.java @@ -32,7 +32,6 @@ import org.apache.drill.exec.store.dfs.DrillFileSystem; import org.apache.drill.exec.store.dfs.easy.FileWork; import org.apache.drill.exec.vector.complex.impl.VectorContainerWriter; import org.apache.drill.exec.vector.complex.writer.BaseWriter; -import org.apache.hadoop.fs.Path; import org.realityforge.jsyslog.message.StructuredDataParameter; import org.realityforge.jsyslog.message.SyslogMessage; @@ -95,7 +94,7 @@ public class SyslogRecordReader extends AbstractRecordReader { private void openFile() { InputStream in; try { - in = fileSystem.open(new Path(fileWork.getPath())); + in = fileSystem.open(fileWork.getPath()); } catch (Exception e) { throw UserException .dataReadError(e) |