org.apache.hawq.pxf.plugins.hive

Class HiveResolver

java.lang.Object

org.apache.hawq.pxf.api.utilities.Plugin

org.apache.hawq.pxf.plugins.hive.HiveResolver

All Implemented Interfaces:

ReadResolver

Direct Known Subclasses:

HiveColumnarSerdeResolver, HiveStringPassResolver

public class HiveResolver
extends Plugin
implements ReadResolver

Class HiveResolver handles deserialization of records that were serialized using Hadoop's Hive serialization framework.

Field Summary

Fields inherited from class org.apache.hawq.pxf.api.utilities.Plugin

inputData

Constructor Summary

Constructors

Constructor and Description
HiveResolver(InputData input) Constructs the HiveResolver by parsing the userdata in the input and obtaining the serde class name, the serde properties string and the partition keys.

Method Summary

Modifier and Type	Method and Description
java.util.List<OneField>	getFields(OneRow onerow) Gets the OneField list of one row.

Methods inherited from class org.apache.hawq.pxf.api.utilities.Plugin

isThreadSafe

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveResolver

public HiveResolver(InputData input)
             throws java.lang.Exception

Constructs the HiveResolver by parsing the userdata in the input and obtaining the serde class name, the serde properties string and the partition keys.

Parameters:

input - contains the Serde class name, the serde properties string and the partition keys

Throws:

java.lang.Exception - if user data was wrong or serde failed to be instantiated

Method Detail

getFields

public java.util.List<OneField> getFields(OneRow onerow)
                                   throws java.lang.Exception

Description copied from interface: ReadResolver

Gets the OneField list of one row.

Specified by:

getFields in interface ReadResolver

Parameters:

onerow - the row to get the fields from

Returns:

the OneField list of one row.

Throws:

java.lang.Exception - if decomposing the row into fields failed