Package org.apache.orc.impl.reader.tree

Interface TypeReader

All Known Implementing Classes:

ConvertTreeReaderFactory.AnyIntegerFromAnyIntegerTreeReader, ConvertTreeReaderFactory.AnyIntegerFromDecimalTreeReader, ConvertTreeReaderFactory.AnyIntegerFromDoubleTreeReader, ConvertTreeReaderFactory.AnyIntegerFromStringGroupTreeReader, ConvertTreeReaderFactory.AnyIntegerFromTimestampTreeReader, ConvertTreeReaderFactory.ConvertTreeReader, ConvertTreeReaderFactory.DateFromStringGroupTreeReader, ConvertTreeReaderFactory.DateFromTimestampTreeReader, ConvertTreeReaderFactory.DecimalFromAnyIntegerTreeReader, ConvertTreeReaderFactory.DecimalFromDecimalTreeReader, ConvertTreeReaderFactory.DecimalFromDoubleTreeReader, ConvertTreeReaderFactory.DecimalFromStringGroupTreeReader, ConvertTreeReaderFactory.DecimalFromTimestampTreeReader, ConvertTreeReaderFactory.DoubleFromAnyIntegerTreeReader, ConvertTreeReaderFactory.DoubleFromDecimalTreeReader, ConvertTreeReaderFactory.DoubleFromStringGroupTreeReader, ConvertTreeReaderFactory.DoubleFromTimestampTreeReader, ConvertTreeReaderFactory.FloatFromDoubleTreeReader, ConvertTreeReaderFactory.StringGroupFromAnyIntegerTreeReader, ConvertTreeReaderFactory.StringGroupFromBinaryTreeReader, ConvertTreeReaderFactory.StringGroupFromBooleanTreeReader, ConvertTreeReaderFactory.StringGroupFromDateTreeReader, ConvertTreeReaderFactory.StringGroupFromDecimalTreeReader, ConvertTreeReaderFactory.StringGroupFromDoubleTreeReader, ConvertTreeReaderFactory.StringGroupFromStringGroupTreeReader, ConvertTreeReaderFactory.StringGroupFromTimestampTreeReader, ConvertTreeReaderFactory.TimestampFromAnyIntegerTreeReader, ConvertTreeReaderFactory.TimestampFromDateTreeReader, ConvertTreeReaderFactory.TimestampFromDecimalTreeReader, ConvertTreeReaderFactory.TimestampFromDoubleTreeReader, ConvertTreeReaderFactory.TimestampFromStringGroupTreeReader, TreeReaderFactory.BinaryTreeReader, TreeReaderFactory.BooleanTreeReader, TreeReaderFactory.ByteTreeReader, TreeReaderFactory.CharTreeReader, TreeReaderFactory.DateTreeReader, TreeReaderFactory.Decimal64TreeReader, TreeReaderFactory.DecimalTreeReader, TreeReaderFactory.DoubleTreeReader, TreeReaderFactory.FloatTreeReader, TreeReaderFactory.IntTreeReader, TreeReaderFactory.ListTreeReader, TreeReaderFactory.LongTreeReader, TreeReaderFactory.MapTreeReader, TreeReaderFactory.NullTreeReader, TreeReaderFactory.ShortTreeReader, TreeReaderFactory.StringDictionaryTreeReader, TreeReaderFactory.StringDirectTreeReader, TreeReaderFactory.StringTreeReader, TreeReaderFactory.StructTreeReader, TreeReaderFactory.TimestampTreeReader, TreeReaderFactory.TreeReader, TreeReaderFactory.UnionTreeReader, TreeReaderFactory.VarcharTreeReader

public interface TypeReader

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	TypeReader.ReaderCategory
static enum	TypeReader.ReadPhase

Method Summary

Modifier and Type	Method	Description
void	checkEncoding(OrcProto.ColumnEncoding encoding)
int	getColumnId()
TypeReader.ReaderCategory	getReaderCategory()
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)
void	seek(PositionProvider[] index, TypeReader.ReadPhase readPhase)
void	seek(PositionProvider index, TypeReader.ReadPhase readPhase)
static boolean	shouldProcessChild(TypeReader child, TypeReader.ReadPhase readPhase)	Determines if the child of the parent should be allowed based on the read level.
void	skipRows(long rows, TypeReader.ReadPhase readPhase)
void	startStripe(StripePlanner planner, TypeReader.ReadPhase readPhase)

Method Details

checkEncoding

void checkEncoding(OrcProto.ColumnEncoding encoding)
            throws IOException

Throws:

IOException

startStripe

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

Throws:

IOException

seek

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

Throws:

IOException

seek

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

Throws:

IOException

skipRows

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

Throws:

IOException

nextVector

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

Throws:

IOException

getColumnId

int getColumnId()

getReaderCategory

TypeReader.ReaderCategory getReaderCategory()

shouldProcessChild

static boolean shouldProcessChild(TypeReader child,
 TypeReader.ReadPhase readPhase)

Determines if the child of the parent should be allowed based on the read level. The child is allowed based on the read level or if the child is a FILTER_PARENT, this allows the handling of NON_FILTER children on the FILTER_PARENT child

Parameters:

child - the child reader that is being evaluated

readPhase - the requested read level

Returns:

true if allowed by read level or if it is a FILTER_PARENT otherwise false