org.apache.hadoop.hive.ql.exec
Class TextRecordReader

java.lang.Object
  org.apache.hadoop.hive.ql.exec.TextRecordReader

All Implemented Interfaces:

RecordReader

public class TextRecordReader
extends Object
implements RecordReader

TextRecordReader.

Constructor Summary

TextRecordReader()

Method Summary

void	close()
org.apache.hadoop.io.Writable	createRow()
void	initialize(InputStream in, org.apache.hadoop.conf.Configuration conf, Properties tbl)
int	next(org.apache.hadoop.io.Writable row) Returns the number of bytes that we consumed.

Methods inherited from class java.lang.Object

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

Constructor Detail

TextRecordReader

public TextRecordReader()

Method Detail

initialize

public void initialize(InputStream in,
                       org.apache.hadoop.conf.Configuration conf,
                       Properties tbl)
                throws IOException

Specified by:

initialize in interface RecordReader

Throws:

IOException

createRow

public org.apache.hadoop.io.Writable createRow()
                                        throws IOException

Specified by:

createRow in interface RecordReader

Throws:

IOException

next

public int next(org.apache.hadoop.io.Writable row)
         throws IOException

Description copied from interface: RecordReader

Returns the number of bytes that we consumed. -1 means end of stream.

Specified by:

next in interface RecordReader

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface RecordReader

Throws:

IOException