public class StreamXmlRecordReader extends StreamBaseRecordReader
LOG
构造器和说明 |
---|
StreamXmlRecordReader(FSDataInputStream in,
FileSplit split,
Reporter reporter,
JobConf job,
FileSystem fs) |
限定符和类型 | 方法和说明 |
---|---|
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
在接口中 RecordReader<Text,Text>
next
在类中 StreamBaseRecordReader
key
- the key to read data intovalue
- the value to read data intoIOException
public void seekNextRecordBoundary() throws IOException
StreamBaseRecordReader
seekNextRecordBoundary
在类中 StreamBaseRecordReader
IOException
Copyright © 2009 The Apache Software Foundation