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

Class VectorDeserializeRow<T extends DeserializeRead>

java.lang.Object

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

public final class VectorDeserializeRow<T extends DeserializeRead>
extends Object

This class deserializes a serialization format into a row of a VectorizedRowBatch. The caller provides the hive type names and output column numbers in the order desired to deserialize. This class uses an provided DeserializeRead object to directly deserialize by reading field-by-field from a serialization format into the primitive values of the VectorizedRowBatch.

Constructor Summary

Constructors

Constructor and Description
VectorDeserializeRow(T deserializeRead)

Method Summary

Modifier and Type	Method and Description
void	deserialize(VectorizedRowBatch batch, int batchIndex) Deserialize a row from the range of bytes specified by setBytes.
String	getDetailedReadPositionString()
void	init()
void	init(boolean[] columnsToIncludeTruncated)
void	init(int startColumn)
void	init(int[] outputColumns)
void	init(List<Integer> outputColumns)
int	initConversion(TypeInfo[] targetTypeInfos, boolean[] columnsToIncludeTruncated) Initialize for converting the source data type that are going to be read with the DeserializedRead interface passed to the constructor to the target data types desired in the VectorizedRowBatch.
void	setBytes(byte[] bytes, int offset, int length) Specify the range of bytes to deserialize in the next call to the deserialize method.

Methods inherited from class java.lang.Object

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

Constructor Detail

VectorDeserializeRow

public VectorDeserializeRow(T deserializeRead)

Method Detail

init

public void init(int[] outputColumns)
          throws HiveException

Throws:

HiveException

init

public void init(List<Integer> outputColumns)
          throws HiveException

Throws:

HiveException

init

public void init(int startColumn)
          throws HiveException

Throws:

HiveException

init

public void init(boolean[] columnsToIncludeTruncated)
          throws HiveException

Throws:

HiveException

initConversion

public int initConversion(TypeInfo[] targetTypeInfos,
                          boolean[] columnsToIncludeTruncated)
                   throws HiveException

Initialize for converting the source data type that are going to be read with the DeserializedRead interface passed to the constructor to the target data types desired in the VectorizedRowBatch. No projection -- the column range 0 .. count-1 where count is the minimum of the target data type array size, included array size, and source data type array size.

Parameters:

targetTypeInfos -

columnsToIncludeTruncated -

Returns:

the minimum count described above is returned. That is, the number of columns that will be processed by deserialize.

Throws:

HiveException

init

public void init()
          throws HiveException

Throws:

HiveException

setBytes

public void setBytes(byte[] bytes,
                     int offset,
                     int length)

Specify the range of bytes to deserialize in the next call to the deserialize method.

Parameters:

bytes -

offset -

length -

deserialize

public void deserialize(VectorizedRowBatch batch,
                        int batchIndex)
                 throws IOException

Deserialize a row from the range of bytes specified by setBytes. Use getDetailedReadPositionString to get detailed read position information to help diagnose exceptions that are thrown...

Parameters:

batch -

batchIndex -

Throws:

IOException

getDetailedReadPositionString

public String getDetailedReadPositionString()