public class StreamXmlRecordReader extends StreamBaseRecordReader
LOG
Constructor and Description |
---|
StreamXmlRecordReader(org.apache.hadoop.fs.FSDataInputStream in,
org.apache.hadoop.mapred.FileSplit split,
org.apache.hadoop.mapred.Reporter reporter,
org.apache.hadoop.mapred.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 StreamXmlRecordReader(org.apache.hadoop.fs.FSDataInputStream in, org.apache.hadoop.mapred.FileSplit split, org.apache.hadoop.mapred.Reporter reporter, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.fs.FileSystem fs) throws IOException
IOException
public void init() throws IOException
IOException
public boolean next(org.apache.hadoop.io.Text key, org.apache.hadoop.io.Text value) throws IOException
StreamBaseRecordReader
next
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
next
in class StreamBaseRecordReader
IOException
public void seekNextRecordBoundary() throws IOException
StreamBaseRecordReader
seekNextRecordBoundary
in class StreamBaseRecordReader
IOException
Copyright © 2017 Apache Software Foundation. All Rights Reserved.