|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.mapreduce.RecordReader<Text,Text> org.apache.hadoop.mapreduce.lib.input.SequenceFileAsTextRecordReader
@InterfaceAudience.Public @InterfaceStability.Stable public class SequenceFileAsTextRecordReader
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()
|
Method Summary | |
---|---|
void |
close()
Close the record reader. |
Text |
getCurrentKey()
Get the current key |
Text |
getCurrentValue()
Get the current value. |
float |
getProgress()
The current progress of the record reader through its data. |
void |
initialize(InputSplit split,
TaskAttemptContext context)
Called once at initialization. |
boolean |
nextKeyValue()
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 |
---|
public SequenceFileAsTextRecordReader() throws IOException
IOException
Method Detail |
---|
public void initialize(InputSplit split, TaskAttemptContext context) throws IOException, InterruptedException
RecordReader
initialize
in class RecordReader<Text,Text>
split
- the split that defines the range of records to readcontext
- the information about the task
IOException
InterruptedException
public Text getCurrentKey() throws IOException, InterruptedException
RecordReader
getCurrentKey
in class RecordReader<Text,Text>
IOException
InterruptedException
public Text getCurrentValue() throws IOException, InterruptedException
RecordReader
getCurrentValue
in class RecordReader<Text,Text>
IOException
InterruptedException
public boolean nextKeyValue() throws IOException, InterruptedException
nextKeyValue
in class RecordReader<Text,Text>
IOException
InterruptedException
public float getProgress() throws IOException, InterruptedException
RecordReader
getProgress
in class RecordReader<Text,Text>
IOException
InterruptedException
public void close() throws IOException
RecordReader
close
in interface Closeable
close
in class RecordReader<Text,Text>
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |