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

java.lang.Object
  org.apache.hadoop.hive.serde2.AbstractSerDe
      org.apache.hadoop.hive.serde2.columnar.ColumnarSerDeBase
          org.apache.hadoop.hive.serde2.columnar.ColumnarSerDe
              org.apache.hadoop.hive.ql.exec.vector.VectorizedColumnarSerDe

All Implemented Interfaces:

VectorizedSerde, Deserializer, SerDe, Serializer

public class VectorizedColumnarSerDe
extends ColumnarSerDe
implements VectorizedSerde

VectorizedColumnarSerDe is used by Vectorized query execution engine for columnar based storage supported by RCFile.

Field Summary

Fields inherited from class org.apache.hadoop.hive.serde2.columnar.ColumnarSerDe

LOG

Constructor Summary

VectorizedColumnarSerDe()

Method Summary

Object	deserialize(org.apache.hadoop.io.Writable blob)
void	deserializeVector(Object rowBlob, int rowsInBlob, VectorizedRowBatch reuseBatch) Deserializes the rowBlob into Vectorized row batch
ObjectInspector	getObjectInspector()
SerDeStats	getSerDeStats()
Class<? extends org.apache.hadoop.io.Writable>	getSerializedClass()
org.apache.hadoop.io.Writable	serialize(Object obj, ObjectInspector objInspector)
org.apache.hadoop.io.Writable	serializeVector(VectorizedRowBatch vrg, ObjectInspector objInspector) Serialize a vectorized row batch

Methods inherited from class org.apache.hadoop.hive.serde2.columnar.ColumnarSerDe

initialize, toString

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

VectorizedColumnarSerDe

public VectorizedColumnarSerDe()
                        throws SerDeException

Throws:

SerDeException

Method Detail

serializeVector

public org.apache.hadoop.io.Writable serializeVector(VectorizedRowBatch vrg,
                                                     ObjectInspector objInspector)
                                              throws SerDeException

Serialize a vectorized row batch

Specified by:

serializeVector in interface VectorizedSerde

Parameters:

vrg - Vectorized row batch to serialize

objInspector - The ObjectInspector for the row object

Returns:

The serialized Writable object

Throws:

SerDeException

See Also:

Serializer.serialize(Object, ObjectInspector)

getSerDeStats

public SerDeStats getSerDeStats()

Specified by:

getSerDeStats in interface Deserializer

Specified by:

getSerDeStats in interface Serializer

Overrides:

getSerDeStats in class ColumnarSerDeBase

getSerializedClass

public Class<? extends org.apache.hadoop.io.Writable> getSerializedClass()

Specified by:

getSerializedClass in interface Serializer

Overrides:

getSerializedClass in class ColumnarSerDeBase

deserialize

public Object deserialize(org.apache.hadoop.io.Writable blob)
                   throws SerDeException

Specified by:

deserialize in interface Deserializer

Overrides:

deserialize in class ColumnarSerDeBase

Throws:

SerDeException

getObjectInspector

public ObjectInspector getObjectInspector()
                                   throws SerDeException

Specified by:

getObjectInspector in interface Deserializer

Overrides:

getObjectInspector in class ColumnarSerDeBase

Throws:

SerDeException

serialize

public org.apache.hadoop.io.Writable serialize(Object obj,
                                               ObjectInspector objInspector)
                                        throws SerDeException

Specified by:

serialize in interface Serializer

Overrides:

serialize in class ColumnarSerDe

Throws:

SerDeException

deserializeVector

public void deserializeVector(Object rowBlob,
                              int rowsInBlob,
                              VectorizedRowBatch reuseBatch)
                       throws SerDeException

Deserializes the rowBlob into Vectorized row batch

Specified by:

deserializeVector in interface VectorizedSerde

Parameters:

rowBlob - rowBlob row batch to deserialize

rowsInBlob - Total number of rows in rowBlob to deserialize

reuseBatch - VectorizedRowBatch to which the rows should be serialized *

Throws:

SerDeException