org.apache.hadoop.hive.ql.exec.vector

Class VectorExtractRow

java.lang.Object

org.apache.hadoop.hive.ql.exec.vector.VectorExtractRow

Direct Known Subclasses:

VectorExtractRowDynBatch, VectorExtractRowSameBatch

public abstract class VectorExtractRow
extends Object

This class extracts specified VectorizedRowBatch row columns into a Writable row Object[]. The caller provides the hive type names and target column numbers in the order desired to extract from the Writable row Object[]. This class is abstract to allow the subclasses to control batch reuse.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	VectorExtractRow.BooleanExtractor
protected class	VectorExtractRow.ByteExtractor
protected class	VectorExtractRow.Extractor

Constructor Summary

Constructors

Constructor and Description
VectorExtractRow()

Method Summary

Methods

Modifier and Type	Method and Description
void	extractRow(int batchIndex, Object[] objects)
Object	extractRowColumn(int batchIndex, int logicalColumnIndex)
protected void	forgetBatch()
int	getCount()
void	init(List<String> typeNames)
void	init(StructObjectInspector structObjectInspector, List<Integer> projectedColumns)
protected void	setBatch(VectorizedRowBatch batch)

Methods inherited from class java.lang.Object

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

Constructor Detail

VectorExtractRow

public VectorExtractRow()

Method Detail

init

public void init(StructObjectInspector structObjectInspector,
        List<Integer> projectedColumns)
          throws HiveException

Throws:

HiveException

init

public void init(List<String> typeNames)
          throws HiveException

Throws:

HiveException

getCount

public int getCount()

setBatch

protected void setBatch(VectorizedRowBatch batch)
                 throws HiveException

Throws:

HiveException

forgetBatch

protected void forgetBatch()

extractRowColumn

public Object extractRowColumn(int batchIndex,
                      int logicalColumnIndex)

extractRow

public void extractRow(int batchIndex,
              Object[] objects)