org.apache.hadoop.mapred
Class SequenceFileAsTextRecordReader

java.lang.Object
  extended by org.apache.hadoop.mapred.SequenceFileAsTextRecordReader
All Implemented Interfaces:
RecordReader<Text,Text>

@InterfaceAudience.Public
@InterfaceStability.Stable
public class SequenceFileAsTextRecordReader
extends Object
implements RecordReader<Text,Text>

This class converts the input keys and values to their String forms by calling toString() method. This class to SequenceFileAsTextInputFormat class is as LineRecordReader class to TextInputFormat class.


Constructor Summary
SequenceFileAsTextRecordReader(Configuration conf, FileSplit split)
           
 
Method Summary
 void close()
          Close this InputSplit to future operations.
 Text createKey()
          Create an object of the appropriate type to be used as a key.
 Text createValue()
          Create an object of the appropriate type to be used as a value.
 long getPos()
          Returns the current position in the input.
 float getProgress()
          How much of the input has the RecordReader consumed i.e.
 boolean next(Text key, Text value)
          Read key/value pair in a line.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SequenceFileAsTextRecordReader

public SequenceFileAsTextRecordReader(Configuration conf,
                                      FileSplit split)
                               throws IOException
Throws:
IOException
Method Detail

createKey

public Text createKey()
Description copied from interface: RecordReader
Create an object of the appropriate type to be used as a key.

Specified by:
createKey in interface RecordReader<Text,Text>
Returns:
a new key object.

createValue

public Text createValue()
Description copied from interface: RecordReader
Create an object of the appropriate type to be used as a value.

Specified by:
createValue in interface RecordReader<Text,Text>
Returns:
a new value object.

next

public boolean next(Text key,
                    Text value)
             throws IOException
Read key/value pair in a line.

Specified by:
next in interface RecordReader<Text,Text>
Parameters:
key - the key to read data into
value - the value to read data into
Returns:
true iff a key/value was read, false if at EOF
Throws:
IOException

getProgress

public float getProgress()
                  throws IOException
Description copied from interface: RecordReader
How much of the input has the RecordReader consumed i.e. has been processed by?

Specified by:
getProgress in interface RecordReader<Text,Text>
Returns:
progress from 0.0 to 1.0.
Throws:
IOException

getPos

public long getPos()
            throws IOException
Description copied from interface: RecordReader
Returns the current position in the input.

Specified by:
getPos in interface RecordReader<Text,Text>
Returns:
the current position in the input.
Throws:
IOException

close

public void close()
           throws IOException
Description copied from interface: RecordReader
Close this InputSplit to future operations.

Specified by:
close in interface RecordReader<Text,Text>
Throws:
IOException


Copyright © 2012 Apache Software Foundation. All Rights Reserved.