Package org.apache.orc.impl

Class TreeReaderFactory.TimestampTreeReader

java.lang.Object

org.apache.orc.impl.TreeReaderFactory.TreeReader

org.apache.orc.impl.TreeReaderFactory.TimestampTreeReader

All Implemented Interfaces:

TypeReader

Enclosing class:

TreeReaderFactory

public static class TreeReaderFactory.TimestampTreeReader
extends TreeReaderFactory.TreeReader

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.orc.impl.reader.tree.TypeReader

TypeReader.ReaderCategory, TypeReader.ReadPhase

Field Summary

Fields

Modifier and Type	Field	Description
protected long	base_timestamp
protected IntegerReader	data
protected IntegerReader	nanos

Fields inherited from class org.apache.orc.impl.TreeReaderFactory.TreeReader

columnId, context, present, readerCategory

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TimestampTreeReader(int columnId, InStream presentStream, InStream dataStream, InStream nanosStream, OrcProto.ColumnEncoding encoding, TreeReaderFactory.Context context, boolean instantType)

Method Summary

Modifier and Type	Method	Description
void	checkEncoding(OrcProto.ColumnEncoding encoding)
protected long	getBaseTimestamp(String timeZoneId)
void	nextVector(org.apache.hadoop.hive.ql.exec.vector.ColumnVector previousVector, 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	nextVector(org.apache.hadoop.hive.ql.exec.vector.TimestampColumnVector result, boolean[] isNull, int batchSize)
void	nextVector(org.apache.hadoop.hive.ql.exec.vector.TimestampColumnVector result, boolean[] isNull, org.apache.hadoop.hive.ql.io.filter.FilterContext filterContext, int batchSize)
void	readTimestamp(org.apache.hadoop.hive.ql.exec.vector.TimestampColumnVector result, int idx)
void	seek(PositionProvider[] index, TypeReader.ReadPhase readPhase)	Seek to the given position.
void	seek(PositionProvider index, TypeReader.ReadPhase readPhase)
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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

data

protected IntegerReader data

nanos

protected IntegerReader nanos

base_timestamp

protected long base_timestamp

Constructor Details

TimestampTreeReader

protected TimestampTreeReader(int columnId,
 InStream presentStream,
 InStream dataStream,
 InStream nanosStream,
 OrcProto.ColumnEncoding encoding,
 TreeReaderFactory.Context context,
 boolean instantType)
                       throws IOException

Throws:

IOException

Method Details

checkEncoding

public void checkEncoding(OrcProto.ColumnEncoding encoding)
                   throws IOException

Specified by:

checkEncoding in interface TypeReader

Overrides:

checkEncoding in class TreeReaderFactory.TreeReader

Throws:

IOException

startStripe

public void startStripe(StripePlanner planner,
 TypeReader.ReadPhase readPhase)
                 throws IOException

Specified by:

startStripe in interface TypeReader

Overrides:

startStripe in class TreeReaderFactory.TreeReader

Throws:

IOException

getBaseTimestamp

protected long getBaseTimestamp(String timeZoneId)
                         throws IOException

Throws:

IOException

seek

public void seek(PositionProvider[] index,
 TypeReader.ReadPhase readPhase)
          throws IOException

Description copied from class: TreeReaderFactory.TreeReader

Seek to the given position.

Specified by:

seek in interface TypeReader

Overrides:

seek in class TreeReaderFactory.TreeReader

Parameters:

index - the indexes loaded from the file

readPhase - the current readPhase

Throws:

IOException

seek

public void seek(PositionProvider index,
 TypeReader.ReadPhase readPhase)
          throws IOException

Specified by:

seek in interface TypeReader

Overrides:

seek in class TreeReaderFactory.TreeReader

Throws:

IOException

readTimestamp

public void readTimestamp(org.apache.hadoop.hive.ql.exec.vector.TimestampColumnVector result,
 int idx)
                   throws IOException

Throws:

IOException

nextVector

public void nextVector(org.apache.hadoop.hive.ql.exec.vector.TimestampColumnVector result,
 boolean[] isNull,
 int batchSize)
                throws IOException

Throws:

IOException

nextVector

public void nextVector(org.apache.hadoop.hive.ql.exec.vector.TimestampColumnVector result,
 boolean[] isNull,
 org.apache.hadoop.hive.ql.io.filter.FilterContext filterContext,
 int batchSize)
                throws IOException

Throws:

IOException

nextVector

public void nextVector(org.apache.hadoop.hive.ql.exec.vector.ColumnVector previousVector,
 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 interface TypeReader

Overrides:

nextVector in class TreeReaderFactory.TreeReader

Parameters:

previousVector - The columnVector object whose isNull value is populated

isNull - Whether the each value was null at a higher level. If isNull is null, all values are non-null.

batchSize - Size of the column vector

filterContext - the information about the rows that were selected by the filter.

readPhase - The read level

Throws:

IOException

skipRows

public void skipRows(long items,
 TypeReader.ReadPhase readPhase)
              throws IOException

Throws:

IOException