org.apache.hawq.pxf.plugins.hdfs.utilities

Class RecordkeyAdapter

java.lang.Object

org.apache.hawq.pxf.plugins.hdfs.utilities.RecordkeyAdapter

public class RecordkeyAdapter
extends java.lang.Object

Adapter used for adding a recordkey field to the records output List<OneField>.

Constructor Summary

Constructors

Constructor and Description
RecordkeyAdapter() Constructs a RecordkeyAdapter.

Method Summary

Modifier and Type	Method and Description
int	appendRecordkeyField(java.util.List<OneField> recFields, InputData input, OneRow onerow) Adds the recordkey to the end of the passed in recFields list.
org.apache.hadoop.io.Writable	convertKeyValue(java.lang.Object key) Converts given key object to its matching Writable.

Methods inherited from class java.lang.Object

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

Constructor Detail

RecordkeyAdapter

public RecordkeyAdapter()

Constructs a RecordkeyAdapter.

Method Detail

appendRecordkeyField

public int appendRecordkeyField(java.util.List<OneField> recFields,
                                InputData input,
                                OneRow onerow)
                         throws java.lang.NoSuchFieldException

Adds the recordkey to the end of the passed in recFields list.

This method also verifies cases in which record keys are not supported by the underlying source type, and therefore "illegally" requested.

Parameters:

recFields - existing list of record (non-key) fields and their values.

input - all input parameters coming from the client request

onerow - a row object which is used here in order to find out if the given type supports recordkeys or not.

Returns:

0 if record key not needed, or 1 if record key was appended

Throws:

java.lang.NoSuchFieldException - when the given record type does not support recordkeys

convertKeyValue

public org.apache.hadoop.io.Writable convertKeyValue(java.lang.Object key)

Converts given key object to its matching Writable. Supported types: Integer, Byte, Boolean, Double, Float, Long, String. The type is only checked once based on the key, all consequent calls must be of the same type.

Parameters:

key - object to convert

Returns:

Writable object matching given key