org.apache.hadoop.hive.ql.io

Class FlatFileInputFormat.FlatFileRecordReader<R>

java.lang.Object

org.apache.hadoop.hive.ql.io.FlatFileInputFormat.FlatFileRecordReader<R>

Enclosing class:

FlatFileInputFormat<T>

public class FlatFileInputFormat.FlatFileRecordReader<R>
extends java.lang.Object

An RecordReader for plain files with Deserializer records Reads one row at a time of type R. R is intended to be a base class of something such as: Record, Writable, Text, ...

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	SerializationContextImplKey The JobConf key of the SerializationContext to use.

Constructor Summary

Constructors

Constructor and Description
FlatFileRecordReader(Configuration conf, FileSplit split) FlatFileRecordReader constructor constructs the underlying stream (potentially decompressed) and creates the deserializer.

Method Summary

Modifier and Type	Method and Description
void	close()
java.lang.Void	createKey()
FlatFileInputFormat.RowContainer<R>	createValue()
long	getPos()
float	getProgress()
boolean	next(java.lang.Void key, FlatFileInputFormat.RowContainer<R> value) Returns the next row # and value.

Methods inherited from class java.lang.Object

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

Field Detail

SerializationContextImplKey

public static final java.lang.String SerializationContextImplKey

The JobConf key of the SerializationContext to use.

See Also:

Constant Field Values

Constructor Detail

FlatFileRecordReader

public FlatFileRecordReader(Configuration conf,
                            FileSplit split)
                     throws java.io.IOException

FlatFileRecordReader constructor constructs the underlying stream (potentially decompressed) and creates the deserializer.

Parameters:

conf - the jobconf

split - the split for this file

Throws:

java.io.IOException

Method Detail

createKey

public java.lang.Void createKey()

Returns:

null

createValue

public FlatFileInputFormat.RowContainer<R> createValue()

Returns:

a new R instance.

next

public boolean next(java.lang.Void key,
                    FlatFileInputFormat.RowContainer<R> value)
             throws java.io.IOException

Returns the next row # and value.

Parameters:

key - - void as these files have a value only

value - - the row container which is always re-used, but the internal value may be set to a new Object

Returns:

whether the key and value were read. True if they were and false if EOF

Throws:

java.io.IOException - from the deserializer

getProgress

public float getProgress()
                  throws java.io.IOException

Throws:

java.io.IOException

getPos

public long getPos()
            throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException