org.apache.hawq.pxf.plugins.hdfs

Class LineBreakAccessor

java.lang.Object

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

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

org.apache.hawq.pxf.plugins.hdfs.LineBreakAccessor

All Implemented Interfaces:

ReadAccessor, WriteAccessor

public class LineBreakAccessor
extends HdfsSplittableDataAccessor
implements WriteAccessor

A PXF Accessor for reading delimited plain text records.

Field Summary

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

data, inputFormat, iter, jobConf, key, reader

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

inputData

Constructor Summary

Constructors

Constructor and Description
LineBreakAccessor(InputData input) Constructs a LineReaderAccessor.

Method Summary

Modifier and Type	Method and Description
void	closeForWrite() Closes the output stream after done writing.
protected java.lang.Object	getReader(org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.mapred.InputSplit split) Specialized accessors will override this method and implement their own recordReader.
boolean	openForWrite() Opens file for write.
boolean	writeNextObject(OneRow onerow) Writes row into stream.

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

closeForRead, getNextSplit, isThreadSafe, openForRead, readNextObject

Methods inherited from class java.lang.Object

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

Constructor Detail

LineBreakAccessor

public LineBreakAccessor(InputData input)

Constructs a LineReaderAccessor.

Parameters:

input - all input parameters coming from the client request

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: HdfsSplittableDataAccessor

Specialized accessors will override this method and implement their own recordReader. For example, a plain delimited text accessor may want to return a LineRecordReader.

Specified by:

getReader in class HdfsSplittableDataAccessor

Parameters:

jobConf - the hadoop jobconf to use for the selected InputFormat

split - the input split to be read by the accessor

Returns:

a recordreader to be used for reading the data records of the split

Throws:

java.io.IOException - if recordreader could not be created

openForWrite

public boolean openForWrite()
                     throws java.lang.Exception

Opens file for write.

Specified by:

openForWrite in interface WriteAccessor

Returns:

true if the resource is successfully opened

Throws:

java.lang.Exception - if opening the resource failed

writeNextObject

public boolean writeNextObject(OneRow onerow)
                        throws java.lang.Exception

Writes row into stream.

Specified by:

writeNextObject in interface WriteAccessor

Parameters:

onerow - the object to be written

Returns:

true if the write succeeded

Throws:

java.lang.Exception - writing to the resource failed

closeForWrite

public void closeForWrite()
                   throws java.lang.Exception

Closes the output stream after done writing.

Specified by:

closeForWrite in interface WriteAccessor

Throws:

java.lang.Exception - if closing the resource failed