org.apache.hive.hcatalog.data

Class LazyHCatRecord

java.lang.Object

org.apache.hive.hcatalog.data.HCatRecord

org.apache.hive.hcatalog.data.LazyHCatRecord

All Implemented Interfaces:

org.apache.hadoop.io.Writable, HCatRecordable

public class LazyHCatRecord
extends HCatRecord

An implementation of HCatRecord that wraps an Object returned by a SerDe and an ObjectInspector. This delays deserialization of unused columns.

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
LazyHCatRecord(Object wrappedObject, ObjectInspector oi)

Method Summary

Methods

Modifier and Type	Method and Description
void	copy(HCatRecord r)
Object	get(int fieldNum) Gets the field at the specified index.
Object	get(String fieldName, HCatSchema recordSchema)
List<Object>	getAll() Gets all the fields of the hcat record.
HCatRecord	getWritable() Convert this LazyHCatRecord to a DefaultHCatRecord.
void	readFields(DataInput in)
void	remove(int idx)
void	set(int fieldNum, Object value) Sets the field at the specified index.
void	set(String fieldName, HCatSchema recordSchema, Object value)
int	size() Gets the size of the hcat record.
String	toString()
void	write(DataOutput out)

Methods inherited from class org.apache.hive.hcatalog.data.HCatRecord

get, getBoolean, getByte, getByteArray, getChar, getDate, getDecimal, getDouble, getFloat, getInteger, getList, getLong, getMap, getShort, getString, getStruct, getTimestamp, getVarchar, setBoolean, setByte, setByteArray, setChar, setDate, setDecimal, setDouble, setFloat, setInteger, setList, setLong, setMap, setShort, setString, setStruct, setTimestamp, setVarchar

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

LazyHCatRecord

public LazyHCatRecord(Object wrappedObject,
              ObjectInspector oi)
               throws Exception

Throws:

Exception

Method Detail

get

public Object get(int fieldNum)

Description copied from interface: HCatRecordable

Gets the field at the specified index.

Parameters:

fieldNum - the field number

Returns:

the object at the specified index

getAll

public List<Object> getAll()

Description copied from interface: HCatRecordable

Gets all the fields of the hcat record.

Returns:

the list of fields

set

public void set(int fieldNum,
       Object value)

Description copied from interface: HCatRecordable

Sets the field at the specified index.

Parameters:

fieldNum - the field number

value - the value to set

size

public int size()

Description copied from interface: HCatRecordable

Gets the size of the hcat record.

Returns:

the size

readFields

public void readFields(DataInput in)
                throws IOException

Throws:

IOException

write

public void write(DataOutput out)
           throws IOException

Throws:

IOException

get

public Object get(String fieldName,
         HCatSchema recordSchema)
           throws HCatException

Specified by:

get in class HCatRecord

Throws:

HCatException

set

public void set(String fieldName,
       HCatSchema recordSchema,
       Object value)
         throws HCatException

Specified by:

set in class HCatRecord

Throws:

HCatException

remove

public void remove(int idx)
            throws HCatException

Specified by:

remove in class HCatRecord

Throws:

HCatException

copy

public void copy(HCatRecord r)
          throws HCatException

Specified by:

copy in class HCatRecord

Throws:

HCatException

toString

public String toString()

Overrides:

toString in class Object

getWritable

public HCatRecord getWritable()
                       throws HCatException

Convert this LazyHCatRecord to a DefaultHCatRecord. This is required before you can write out a record via write.

Returns:

an HCatRecord that can be serialized

Throws:

HCatException