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 d620318 Editing reusable vectorized row batch to really be reusable
d620318 is described below
commit d620318cc0be146e1c4bc8792b72369f84b521e6
Author: Jennifer Dai <[email protected]>
AuthorDate: Wed Mar 20 13:58:04 2019 -0700
Editing reusable vectorized row batch to really be reusable
---
.../main/java/org/apache/pinot/orc/data/readers/ORCRecordReader.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
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 f09de55..cec3529 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
@@ -54,7 +54,7 @@ public class ORCRecordReader implements RecordReader {
private TypeDescription _orcSchema;
Reader _reader;
org.apache.orc.RecordReader _recordReader;
- VectorizedRowBatch _reusableVectorizedRowBatch = new VectorizedRowBatch(1);
+ VectorizedRowBatch _reusableVectorizedRowBatch;
private static final Logger LOGGER =
LoggerFactory.getLogger(ORCRecordReader.class);
@@ -78,6 +78,8 @@ public class ORCRecordReader implements RecordReader {
LOGGER.error("Caught exception initializing record reader at path {}",
segmentGeneratorConfig.getInputFilePath());
throw new RuntimeException(e);
}
+
+ _reusableVectorizedRowBatch = _orcSchema.createRowBatch(1);
}
@Override
@@ -99,7 +101,6 @@ public class ORCRecordReader implements RecordReader {
@Override
public GenericRow next(GenericRow reuse)
throws IOException {
- _reusableVectorizedRowBatch = _orcSchema.createRowBatch(1);
_recordReader.nextBatch(_reusableVectorizedRowBatch);
fillGenericRow(reuse, _reusableVectorizedRowBatch);
return reuse;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
