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