public class StreamRecordReader extends StreamBasedRecordReader<PortableDataStream>
Constructor and Description |
---|
StreamRecordReader(org.apache.hadoop.mapreduce.lib.input.CombineFileSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context,
Integer index) |
Modifier and Type | Method and Description |
---|---|
PortableDataStream |
parseStream(PortableDataStream inStream)
Parse the stream (and close it afterwards) and return the value as in type T
|
close, getCurrentKey, getCurrentValue, getProgress, initialize, nextKeyValue
public StreamRecordReader(org.apache.hadoop.mapreduce.lib.input.CombineFileSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context, Integer index)
public PortableDataStream parseStream(PortableDataStream inStream)
StreamBasedRecordReader
parseStream
in class StreamBasedRecordReader<PortableDataStream>
inStream
- the stream to be read in