org.apache.hadoop.hive.ql.io

Class FlatFileInputFormat.FlatFileRecordReader<R>

java.lang.Object

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

All Implemented Interfaces:

org.apache.hadoop.mapred.RecordReader<Void,FlatFileInputFormat.RowContainer<R>>

Enclosing class:

FlatFileInputFormat<T>

Deprecated.

@Deprecated
public class FlatFileInputFormat.FlatFileRecordReader<R>
extends Object
implements org.apache.hadoop.mapred.RecordReader<Void,FlatFileInputFormat.RowContainer<R>>

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 String	SerializationContextImplKey Deprecated. The JobConf key of the SerializationContext to use.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close() Deprecated.
Void	createKey() Deprecated.
FlatFileInputFormat.RowContainer<R>	createValue() Deprecated.
long	getPos() Deprecated.
float	getProgress() Deprecated.
boolean	next(Void key, FlatFileInputFormat.RowContainer<R> value) Deprecated. 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 String SerializationContextImplKey

Deprecated.

The JobConf key of the SerializationContext to use.

See Also:

Constant Field Values

Constructor Detail

FlatFileRecordReader

public FlatFileRecordReader(org.apache.hadoop.conf.Configuration conf,
                            org.apache.hadoop.mapred.FileSplit split)
                     throws IOException

Deprecated.

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

Parameters:

conf - the jobconf

split - the split for this file

Throws:

IOException

Method Detail

createKey

public Void createKey()

Deprecated.

Specified by:

createKey in interface org.apache.hadoop.mapred.RecordReader<Void,FlatFileInputFormat.RowContainer<R>>

Returns:

null

createValue

public FlatFileInputFormat.RowContainer<R> createValue()

Deprecated.

Specified by:

createValue in interface org.apache.hadoop.mapred.RecordReader<Void,FlatFileInputFormat.RowContainer<R>>

Returns:

a new R instance.

next

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

Deprecated.

Returns the next row # and value.

Specified by:

next in interface org.apache.hadoop.mapred.RecordReader<Void,FlatFileInputFormat.RowContainer<R>>

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:

IOException - from the deserializer

getProgress

public float getProgress()
                  throws IOException

Deprecated.

Specified by:

getProgress in interface org.apache.hadoop.mapred.RecordReader<Void,FlatFileInputFormat.RowContainer<R>>

Throws:

IOException

getPos

public long getPos()
            throws IOException

Deprecated.

Specified by:

getPos in interface org.apache.hadoop.mapred.RecordReader<Void,FlatFileInputFormat.RowContainer<R>>

Throws:

IOException

close

public void close()
           throws IOException

Deprecated.

Specified by:

close in interface org.apache.hadoop.mapred.RecordReader<Void,FlatFileInputFormat.RowContainer<R>>

Throws:

IOException