public class MeasuredRecordReader extends Object implements RecordReader
Constructor and Description |
---|
MeasuredRecordReader(FlowProcess flowProcess,
Enum counter) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Object |
createKey() |
Object |
createValue() |
long |
getPos() |
float |
getProgress() |
RecordReader |
getRecordReader() |
boolean |
next(Object key,
Object value) |
void |
setRecordReader(RecordReader recordReader) |
public MeasuredRecordReader(FlowProcess flowProcess, Enum counter)
public RecordReader getRecordReader()
public void setRecordReader(RecordReader recordReader)
public boolean next(Object key, Object value) throws IOException
next
in interface RecordReader
IOException
public Object createKey()
createKey
in interface RecordReader
public Object createValue()
createValue
in interface RecordReader
public long getPos() throws IOException
getPos
in interface RecordReader
IOException
public void close() throws IOException
close
in interface RecordReader
IOException
public float getProgress() throws IOException
getProgress
in interface RecordReader
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.