org.apache.hawq.pxf.plugins.hive

Class HiveRCFileAccessor

java.lang.Object

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

org.apache.hawq.pxf.plugins.hdfs.HdfsSplittableDataAccessor

org.apache.hawq.pxf.plugins.hive.HiveAccessor

org.apache.hawq.pxf.plugins.hive.HiveRCFileAccessor

All Implemented Interfaces:

ReadAccessor

public class HiveRCFileAccessor
extends HiveAccessor

Specialization of HiveAccessor for a Hive table that stores only RC files. This class replaces the generic HiveAccessor for a case where a table is stored entirely as RC files. Use together with HiveInputFormatFragmenter/HiveColumnarSerdeResolver

Field Summary

Fields inherited from class org.apache.hawq.pxf.plugins.hive.HiveAccessor

filterInFragmenter

Fields inherited from class org.apache.hawq.pxf.plugins.hdfs.HdfsSplittableDataAccessor

conf, data, inputFormat, iter, jobConf, key, reader

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

inputData

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected java.lang.Object	getReader(org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.mapred.InputSplit split) Creates the RecordReader suitable for this given split.

Methods inherited from class org.apache.hawq.pxf.plugins.hive.HiveAccessor

openForRead

Methods inherited from class org.apache.hawq.pxf.plugins.hdfs.HdfsSplittableDataAccessor

closeForRead, getNextSplit, isThreadSafe, readNextObject

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveRCFileAccessor

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

Constructs a HiveRCFileAccessor.

Parameters:

input - input containing user data

Throws:

java.lang.Exception - if user data was wrong

Method Detail

getReader

protected java.lang.Object getReader(org.apache.hadoop.mapred.JobConf jobConf,
                                     org.apache.hadoop.mapred.InputSplit split)
                              throws java.io.IOException

Description copied from class: HiveAccessor

Creates the RecordReader suitable for this given split.

Overrides:

getReader in class HiveAccessor

Parameters:

jobConf - configuration data for the Hadoop framework

split - the split that was allocated for reading to this accessor

Returns:

record reader

Throws:

java.io.IOException - if failed to create record reader