public class StreamXmlRecordReader extends StreamBaseRecordReader
LOG
Constructor and Description |
---|
StreamXmlRecordReader(org.apache.hadoop.fs.FSDataInputStream in,
FileSplit split,
Reporter reporter,
JobConf job,
org.apache.hadoop.fs.FileSystem fs) |
Modifier and Type | Method and Description |
---|---|
void |
init() |
boolean |
next(org.apache.hadoop.io.Text key,
org.apache.hadoop.io.Text value)
Read a record.
|
void |
seekNextRecordBoundary()
Implementation should seek forward in_ to the first byte of the next record.
|
close, createKey, createValue, getPos, getProgress
public void init() throws java.io.IOException
java.io.IOException
public boolean next(org.apache.hadoop.io.Text key, org.apache.hadoop.io.Text value) throws java.io.IOException
StreamBaseRecordReader
next
in interface RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
next
in class StreamBaseRecordReader
key
- the key to read data intovalue
- the value to read data intojava.io.IOException
public void seekNextRecordBoundary() throws java.io.IOException
StreamBaseRecordReader
seekNextRecordBoundary
in class StreamBaseRecordReader
java.io.IOException
Copyright © 2009 The Apache Software Foundation