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

Class VectorSerializeRow<T extends SerializeWrite>

java.lang.Object

org.apache.hadoop.hive.ql.exec.vector.VectorSerializeRow<T>

public final class VectorSerializeRow<T extends SerializeWrite>
extends Object

This class serializes columns from a row in a VectorizedRowBatch into a serialization format. The caller provides the hive type names and column numbers in the order desired to serialize. This class uses an provided SerializeWrite object to directly serialize by writing field-by-field into a serialization format from the primitive values of the VectorizedRowBatch. Note that when serializing a row, the logical mapping using selected in use has already been performed.

Constructor Summary

Constructors

Constructor and Description
VectorSerializeRow(T serializeWrite)

Method Summary

Modifier and Type	Method and Description
int	getCount()
boolean	getHasAnyNulls()
boolean	getIsAllNulls()
void	init(List<String> typeNames)
void	init(List<String> typeNames, int[] columnMap)
void	init(TypeInfo[] typeInfos)
void	init(TypeInfo[] typeInfos, int[] columnMap)
void	serializeWrite(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch, int batchIndex)
void	setOutput(ByteStream.Output output)
void	setOutputAppend(ByteStream.Output output)

Methods inherited from class java.lang.Object

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

Constructor Detail

VectorSerializeRow

public VectorSerializeRow(T serializeWrite)

Method Detail

init

public void init(List<String> typeNames,
                 int[] columnMap)
          throws HiveException

Throws:

HiveException

init

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

Throws:

HiveException

init

public void init(TypeInfo[] typeInfos)
          throws HiveException

Throws:

HiveException

init

public void init(TypeInfo[] typeInfos,
                 int[] columnMap)
          throws HiveException

Throws:

HiveException

getCount

public int getCount()

setOutput

public void setOutput(ByteStream.Output output)

setOutputAppend

public void setOutputAppend(ByteStream.Output output)

serializeWrite

public void serializeWrite(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
                           int batchIndex)
                    throws IOException

Throws:

IOException

getHasAnyNulls

public boolean getHasAnyNulls()

getIsAllNulls

public boolean getIsAllNulls()