public class StreamXmlRecordReader extends StreamBaseRecordReader
LOG
Constructor and Description |
---|
StreamXmlRecordReader(FSDataInputStream in,
FileSplit split,
Reporter reporter,
JobConf job,
FileSystem fs) |
Modifier and Type | Method and Description |
---|---|
void |
init() |
boolean |
next(Text key,
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 StreamXmlRecordReader(FSDataInputStream in, FileSplit split, Reporter reporter, JobConf job, FileSystem fs) throws IOException
IOException
public void init() throws IOException
IOException
public boolean next(Text key, Text value) throws IOException
StreamBaseRecordReader
next
in interface RecordReader<Text,Text>
next
in class StreamBaseRecordReader
key
- the key to read data intovalue
- the value to read data intoIOException
public void seekNextRecordBoundary() throws IOException
StreamBaseRecordReader
seekNextRecordBoundary
in class StreamBaseRecordReader
IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.