org.apache.hadoop.hive.ql.io

Class NullRowsInputFormat.NullRowsRecordReader

java.lang.Object

org.apache.hadoop.hive.ql.io.NullRowsInputFormat.NullRowsRecordReader

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.mapred.RecordReader

Direct Known Subclasses:

OneNullRowInputFormat.OneNullRowRecordReader

Enclosing class:

NullRowsInputFormat

public static class NullRowsInputFormat.NullRowsRecordReader
extends Object
implements org.apache.hadoop.mapred.RecordReader

Field Summary

Fields

Modifier and Type	Field and Description
protected VectorizedRowBatchCtx	rbCtx

Constructor Summary

Constructors

Constructor and Description
NullRowsRecordReader(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapred.InputSplit split)

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.io.NullWritable	createKey()
Object	createValue()
long	getPos()
float	getProgress()
protected void	makeNullVrb(Object value, int size)
boolean	next(Object arg0, Object value)

Methods inherited from class java.lang.Object

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

Field Detail

rbCtx

protected final VectorizedRowBatchCtx rbCtx

Constructor Detail

NullRowsRecordReader

public NullRowsRecordReader(org.apache.hadoop.conf.Configuration conf,
                            org.apache.hadoop.mapred.InputSplit split)
                     throws IOException

Throws:

IOException

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.hadoop.mapred.RecordReader

Throws:

IOException

createKey

public org.apache.hadoop.io.NullWritable createKey()

Specified by:

createKey in interface org.apache.hadoop.mapred.RecordReader

createValue

public Object createValue()

Specified by:

createValue in interface org.apache.hadoop.mapred.RecordReader

getPos

public long getPos()
            throws IOException

Specified by:

getPos in interface org.apache.hadoop.mapred.RecordReader

Throws:

IOException

getProgress

public float getProgress()
                  throws IOException

Specified by:

getProgress in interface org.apache.hadoop.mapred.RecordReader

Throws:

IOException

next

public boolean next(Object arg0,
                    Object value)
             throws IOException

Specified by:

next in interface org.apache.hadoop.mapred.RecordReader

Throws:

IOException

makeNullVrb

protected void makeNullVrb(Object value,
                           int size)