protected static class EncodedTreeReaderFactory.ListStreamReader extends TreeReaderFactory.ListTreeReader implements EncodedTreeReaderFactory.SettableTreeReader
Modifier and Type | Class and Description |
---|---|
static class |
EncodedTreeReaderFactory.ListStreamReader.StreamReaderBuilder |
elementReader, lengths
columnId, present, valuePresent, vectorColumnCount
Constructor and Description |
---|
ListStreamReader(int columnIndex,
SettableUncompressedStream present,
SettableUncompressedStream lengthStream,
OrcProto.ColumnEncoding columnEncoding,
boolean isFileCompressed,
TreeReaderFactory.TreeReader elementReader) |
Modifier and Type | Method and Description |
---|---|
static EncodedTreeReaderFactory.ListStreamReader.StreamReaderBuilder |
builder() |
void |
seek(PositionProvider index) |
void |
seek(PositionProvider[] index)
Seek to the given position.
|
void |
setBuffers(org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch<OrcBatchKey> batch,
boolean sameStripe) |
nextVector
countNonNulls, createIntegerReader, getColumnId, getPresent, nextBatch
public ListStreamReader(int columnIndex, SettableUncompressedStream present, SettableUncompressedStream lengthStream, OrcProto.ColumnEncoding columnEncoding, boolean isFileCompressed, TreeReaderFactory.TreeReader elementReader) throws IOException
IOException
public void seek(PositionProvider[] index) throws IOException
TreeReaderFactory.TreeReader
seek
in class TreeReaderFactory.ListTreeReader
index
- the indexes loaded from the fileIOException
public void seek(PositionProvider index) throws IOException
seek
in class TreeReaderFactory.TreeReader
IOException
public void setBuffers(org.apache.hadoop.hive.common.io.encoded.EncodedColumnBatch<OrcBatchKey> batch, boolean sameStripe) throws IOException
setBuffers
in interface EncodedTreeReaderFactory.SettableTreeReader
IOException
public static EncodedTreeReaderFactory.ListStreamReader.StreamReaderBuilder builder()
Copyright © 2017 The Apache Software Foundation. All rights reserved.