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

Constructors

Constructor and Description
TextRecordReader()

Method Summary

Modifier and Type	Method and Description
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

clone, equals, finalize, 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