org.apache.hawq.pxf.plugins.hive

Class HiveLineBreakAccessor

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.HiveLineBreakAccessor

All Implemented Interfaces:

ReadAccessor

public class HiveLineBreakAccessor
extends HiveAccessor

Specialization of HiveAccessor for a Hive table stored as Text files. Use together with HiveInputFormatFragmenter/HiveStringPassResolver.

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
HiveLineBreakAccessor(InputData input) Constructs a HiveLineBreakAccessor.

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

HiveLineBreakAccessor

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

Constructs a HiveLineBreakAccessor.

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