org.apache.hawq.pxf.plugins.hdfs

Class AvroResolver

java.lang.Object

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

org.apache.hawq.pxf.plugins.hdfs.AvroResolver

All Implemented Interfaces:

ReadResolver

public class AvroResolver
extends Plugin
implements ReadResolver

Class AvroResolver handles deserialization of records that were serialized using the AVRO serialization framework.

Field Summary

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

inputData

Constructor Summary

Constructors

Constructor and Description
AvroResolver(InputData input) Constructs an AvroResolver.

Method Summary

Modifier and Type	Method and Description
java.util.List<OneField>	getFields(OneRow row) Returns a list of the fields of one record.

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

AvroResolver

public AvroResolver(InputData input)
             throws java.io.IOException

Constructs an AvroResolver. Initializes Avro data structure: the Avro record - fields information and the Avro record reader. All Avro data is build from the Avro schema, which is based on the *.avsc file that was passed by the user

Parameters:

input - all input parameters coming from the client

Throws:

java.io.IOException - if Avro schema could not be retrieved or parsed

Method Detail

getFields

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

Returns a list of the fields of one record. Each record field is represented by a OneField item. OneField item contains two fields: an integer representing the field type and a Java Object representing the field value.

Specified by:

getFields in interface ReadResolver

Parameters:

row - 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