Package org.apache.orc.impl
Class TreeReaderFactory.ListTreeReader
java.lang.Object
org.apache.orc.impl.TreeReaderFactory.TreeReader
org.apache.orc.impl.TreeReaderFactory.ListTreeReader
- All Implemented Interfaces:
TypeReader
- Enclosing class:
- TreeReaderFactory
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.orc.impl.reader.tree.TypeReader
TypeReader.ReaderCategory, TypeReader.ReadPhase
-
Field Summary
Fields inherited from class org.apache.orc.impl.TreeReaderFactory.TreeReader
columnId, context, present, readerCategory
-
Constructor Summary
ModifierConstructorDescriptionprotected
ListTreeReader
(int columnId, InStream present, TreeReaderFactory.Context context, InStream data, OrcProto.ColumnEncoding encoding, TypeReader elementReader) protected
ListTreeReader
(int fileColumn, TypeDescription readerSchema, TreeReaderFactory.Context context) -
Method Summary
Modifier and TypeMethodDescriptionvoid
checkEncoding
(OrcProto.ColumnEncoding encoding) void
nextVector
(org.apache.hadoop.hive.ql.exec.vector.ColumnVector previous, boolean[] isNull, int batchSize, org.apache.hadoop.hive.ql.io.filter.FilterContext filterContext, TypeReader.ReadPhase readPhase) Populates the isNull vector array in the previousVector object based on the present stream values.void
seek
(PositionProvider[] index, TypeReader.ReadPhase readPhase) Seek to the given position.void
skipRows
(long items, TypeReader.ReadPhase readPhase) void
startStripe
(StripePlanner planner, TypeReader.ReadPhase readPhase) Methods inherited from class org.apache.orc.impl.TreeReaderFactory.TreeReader
countNonNullRowsInRange, countNonNulls, createIntegerReader, getColumnId, getPresent, getReaderCategory, seek
-
Field Details
-
elementReader
-
lengths
-
-
Constructor Details
-
ListTreeReader
protected ListTreeReader(int fileColumn, TypeDescription readerSchema, TreeReaderFactory.Context context) throws IOException - Throws:
IOException
-
ListTreeReader
protected ListTreeReader(int columnId, InStream present, TreeReaderFactory.Context context, InStream data, OrcProto.ColumnEncoding encoding, TypeReader elementReader) throws IOException - Throws:
IOException
-
-
Method Details
-
seek
Description copied from class:TreeReaderFactory.TreeReader
Seek to the given position.- Specified by:
seek
in interfaceTypeReader
- Overrides:
seek
in classTreeReaderFactory.TreeReader
- Parameters:
index
- the indexes loaded from the filereadPhase
- the current readPhase- Throws:
IOException
-
nextVector
public void nextVector(org.apache.hadoop.hive.ql.exec.vector.ColumnVector previous, boolean[] isNull, int batchSize, org.apache.hadoop.hive.ql.io.filter.FilterContext filterContext, TypeReader.ReadPhase readPhase) throws IOException Description copied from class:TreeReaderFactory.TreeReader
Populates the isNull vector array in the previousVector object based on the present stream values. This function is called from all the child readers, and they all set the values based on isNull field value.- Specified by:
nextVector
in interfaceTypeReader
- Overrides:
nextVector
in classTreeReaderFactory.TreeReader
- Parameters:
previous
- The columnVector object whose isNull value is populatedisNull
- Whether the each value was null at a higher level. If isNull is null, all values are non-null.batchSize
- Size of the column vectorfilterContext
- the information about the rows that were selected by the filter.readPhase
- The read level- Throws:
IOException
-
checkEncoding
- Specified by:
checkEncoding
in interfaceTypeReader
- Overrides:
checkEncoding
in classTreeReaderFactory.TreeReader
- Throws:
IOException
-
startStripe
- Specified by:
startStripe
in interfaceTypeReader
- Overrides:
startStripe
in classTreeReaderFactory.TreeReader
- Throws:
IOException
-
skipRows
- Throws:
IOException
-