org.apache.hadoop.hive.serde2.lazy

Class LazyStruct

java.lang.Object

org.apache.hadoop.hive.serde2.lazy.LazyObject<OI>

org.apache.hadoop.hive.serde2.lazy.LazyNonPrimitive<LazySimpleStructObjectInspector>

org.apache.hadoop.hive.serde2.lazy.LazyStruct

All Implemented Interfaces:

LazyObjectBase, SerDeStatsStruct, StructObject

Direct Known Subclasses:

AccumuloCompositeRowId, HBaseCompositeKey, HBaseStructValue, LazyAccumuloRow, LazyHBaseRow

public class LazyStruct
extends LazyNonPrimitive<LazySimpleStructObjectInspector>
implements StructObject, SerDeStatsStruct

LazyObject for storing a struct. The field of a struct can be primitive or non-primitive. LazyStruct does not deal with the case of a NULL struct. That is handled by the parent LazyObject.

Field Summary

Fields inherited from class org.apache.hadoop.hive.serde2.lazy.LazyNonPrimitive

bytes, length, start

Fields inherited from class org.apache.hadoop.hive.serde2.lazy.LazyObject

isNull, oi

Constructor Summary

Constructors

Constructor and Description
LazyStruct(LazySimpleStructObjectInspector oi) Construct a LazyStruct object with the ObjectInspector.

Method Summary

Methods

Modifier and Type	Method and Description
protected LazyObjectBase	createLazyField(int fieldID, StructField fieldRef)
byte[]	getBytes() Return the data in bytes corresponding to this given struct.
Object	getField(int fieldID) Get one field out of the struct.
protected boolean[]	getFieldInited()
protected LazyObjectBase[]	getFields()
List<Object>	getFieldsAsList() Get the values of the fields as an ArrayList.
protected boolean	getParsed()
long	getRawDataSerializedSize() Rerurns the serialized size of the object.
void	init(ByteArrayRef bytes, int start, int length) Set the row data for this LazyStruct.
protected void	initLazyFields(List<? extends StructField> fieldRefs)
void	parseMultiDelimit(byte[] rawRow, byte[] fieldDelimit)
protected void	setFieldInited(boolean[] fieldInited)
protected void	setFields(LazyObject[] fields)
protected void	setParsed(boolean parsed)

Methods inherited from class org.apache.hadoop.hive.serde2.lazy.LazyNonPrimitive

hashCode, isNull, isNull

Methods inherited from class org.apache.hadoop.hive.serde2.lazy.LazyObject

getInspector, getObject, setInspector, setNull

Methods inherited from class java.lang.Object

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

Constructor Detail

LazyStruct

public LazyStruct(LazySimpleStructObjectInspector oi)

Construct a LazyStruct object with the ObjectInspector.

Method Detail

init

public void init(ByteArrayRef bytes,
        int start,
        int length)

Set the row data for this LazyStruct.

Specified by:

init in interface LazyObjectBase

Overrides:

init in class LazyNonPrimitive<LazySimpleStructObjectInspector>

Parameters:

bytes - The wrapper of the byte[].

start - The start position inside the bytes.

length - The length of the data, starting from "start"

See Also:

LazyObject.init(ByteArrayRef, int, int)

initLazyFields

protected final void initLazyFields(List<? extends StructField> fieldRefs)

createLazyField

protected LazyObjectBase createLazyField(int fieldID,
                             StructField fieldRef)
                                  throws SerDeException

Throws:

SerDeException

getField

public Object getField(int fieldID)

Get one field out of the struct. If the field is a primitive field, return the actual object. Otherwise return the LazyObject. This is because PrimitiveObjectInspector does not have control over the object used by the user - the user simply directly use the Object instead of going through Object PrimitiveObjectInspector.get(Object).

Specified by:

getField in interface StructObject

Parameters:

fieldID - The field ID

Returns:

The field as a LazyObject

getFieldsAsList

public List<Object> getFieldsAsList()

Get the values of the fields as an ArrayList.

Specified by:

getFieldsAsList in interface StructObject

Returns:

The values of the fields as an ArrayList.

getParsed

protected boolean getParsed()

setParsed

protected void setParsed(boolean parsed)

getFields

protected LazyObjectBase[] getFields()

setFields

protected void setFields(LazyObject[] fields)

getFieldInited

protected boolean[] getFieldInited()

setFieldInited

protected void setFieldInited(boolean[] fieldInited)

getRawDataSerializedSize

public long getRawDataSerializedSize()

Description copied from interface: SerDeStatsStruct

Rerurns the serialized size of the object.

Specified by:

getRawDataSerializedSize in interface SerDeStatsStruct

parseMultiDelimit

public void parseMultiDelimit(byte[] rawRow,
                     byte[] fieldDelimit)

getBytes

public byte[] getBytes()

Return the data in bytes corresponding to this given struct. This is useful specifically in cases where the data is stored in serialized formats like protobufs or thrift and would need custom deserializers to be deserialized.