org.apache.hawq.pxf.plugins.hdfs

Class WritableResolver

java.lang.Object

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

org.apache.hawq.pxf.plugins.hdfs.WritableResolver

All Implemented Interfaces:

ReadResolver, WriteResolver

public class WritableResolver
extends Plugin
implements ReadResolver, WriteResolver

WritableResolver handles serialization and deserialization of records that were serialized using Hadoop's Writable serialization framework. A field named 'recordkey' is treated as a key of the given row, and not as part of the data schema. See RecordkeyAdapter.

Field Summary

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

inputData

Constructor Summary

Constructors

Constructor and Description
WritableResolver(InputData input) Constructs a WritableResolver.

Method Summary

Modifier and Type	Method and Description
java.util.List<OneField>	getFields(OneRow onerow) Gets the OneField list of one row.
OneRow	setFields(java.util.List<OneField> record) Sets customWritable fields and creates a OneRow object.

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

WritableResolver

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

Constructs a WritableResolver.

Parameters:

input - all input parameters coming from the client

Throws:

java.lang.Exception - if schema file is missing, cannot be found in classpath or fails to instantiate

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

setFields

public OneRow setFields(java.util.List<OneField> record)
                 throws java.lang.Exception

Sets customWritable fields and creates a OneRow object.

Specified by:

setFields in interface WriteResolver

Parameters:

record - list of OneField

Returns:

the constructed OneRow

Throws:

java.lang.Exception - if constructing a row from the fields failed