This is an automated email from the ASF dual-hosted git repository.
jenniferdai pushed a commit to branch orc
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
The following commit(s) were added to refs/heads/orc by this push:
new de8e3e8 Using local path to read segment
de8e3e8 is described below
commit de8e3e8ea8e5c390d5668372341232d866dab361
Author: Jennifer Dai <[email protected]>
AuthorDate: Tue Mar 19 13:59:49 2019 -0700
Using local path to read segment
---
.../main/java/org/apache/pinot/orc/data/readers/ORCRecordReader.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/pinot-orc/src/main/java/org/apache/pinot/orc/data/readers/ORCRecordReader.java
b/pinot-orc/src/main/java/org/apache/pinot/orc/data/readers/ORCRecordReader.java
index 68660fd..754be0f 100644
---
a/pinot-orc/src/main/java/org/apache/pinot/orc/data/readers/ORCRecordReader.java
+++
b/pinot-orc/src/main/java/org/apache/pinot/orc/data/readers/ORCRecordReader.java
@@ -49,7 +49,9 @@ public class ORCRecordReader implements RecordReader {
Configuration conf = new Configuration();
LOGGER.info("Creating segment for {}",
segmentGeneratorConfig.getInputFilePath());
try {
- _reader = OrcFile.createReader(new
Path(segmentGeneratorConfig.getInputFilePath()), OrcFile.readerOptions(conf));
+ Path orcReaderPath = new Path("file://" +
segmentGeneratorConfig.getInputFilePath());
+ LOGGER.info("orc reader path is {}", orcReaderPath);
+ _reader = OrcFile.createReader(orcReaderPath,
OrcFile.readerOptions(conf));
_orcSchema = _reader.getSchema();
LOGGER.info("ORC schema is {}", _orcSchema.toJson());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
