public abstract class StreamBasedRecordReader<T>
extends org.apache.hadoop.mapreduce.RecordReader<String,T>
RecordReader
to reading files out as streamsConstructor and Description |
---|
StreamBasedRecordReader(org.apache.hadoop.mapreduce.lib.input.CombineFileSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context,
Integer index) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
String |
getCurrentKey() |
T |
getCurrentValue() |
float |
getProgress() |
void |
initialize(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
boolean |
nextKeyValue() |
abstract T |
parseStream(PortableDataStream inStream)
Parse the stream (and close it afterwards) and return the value as in type T
|
public StreamBasedRecordReader(org.apache.hadoop.mapreduce.lib.input.CombineFileSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context, Integer index)
public void initialize(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
initialize
in class org.apache.hadoop.mapreduce.RecordReader<String,T>
public void close()
close
in interface java.io.Closeable
close
in interface AutoCloseable
close
in class org.apache.hadoop.mapreduce.RecordReader<String,T>
public float getProgress()
getProgress
in class org.apache.hadoop.mapreduce.RecordReader<String,T>
public String getCurrentKey()
getCurrentKey
in class org.apache.hadoop.mapreduce.RecordReader<String,T>
public T getCurrentValue()
getCurrentValue
in class org.apache.hadoop.mapreduce.RecordReader<String,T>
public boolean nextKeyValue()
nextKeyValue
in class org.apache.hadoop.mapreduce.RecordReader<String,T>
public abstract T parseStream(PortableDataStream inStream)
inStream
- the stream to be read in