cascading.tap.hadoop.util
Class MeasuredRecordReader

java.lang.Object
  extended by cascading.tap.hadoop.util.MeasuredRecordReader
All Implemented Interfaces:
org.apache.hadoop.mapred.RecordReader

public class MeasuredRecordReader
extends Object
implements org.apache.hadoop.mapred.RecordReader


Constructor Summary
MeasuredRecordReader(FlowProcess flowProcess, Enum counter)
           
 
Method Summary
 void close()
           
 Object createKey()
           
 Object createValue()
           
 long getPos()
           
 float getProgress()
           
 org.apache.hadoop.mapred.RecordReader getRecordReader()
           
 boolean next(Object key, Object value)
           
 void setRecordReader(org.apache.hadoop.mapred.RecordReader recordReader)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MeasuredRecordReader

public MeasuredRecordReader(FlowProcess flowProcess,
                            Enum counter)
Method Detail

getRecordReader

public org.apache.hadoop.mapred.RecordReader getRecordReader()

setRecordReader

public void setRecordReader(org.apache.hadoop.mapred.RecordReader recordReader)

next

public boolean next(Object key,
                    Object value)
             throws IOException
Specified by:
next in interface org.apache.hadoop.mapred.RecordReader
Throws:
IOException

createKey

public Object createKey()
Specified by:
createKey in interface org.apache.hadoop.mapred.RecordReader

createValue

public Object createValue()
Specified by:
createValue in interface org.apache.hadoop.mapred.RecordReader

getPos

public long getPos()
            throws IOException
Specified by:
getPos in interface org.apache.hadoop.mapred.RecordReader
Throws:
IOException

close

public void close()
           throws IOException
Specified by:
close in interface org.apache.hadoop.mapred.RecordReader
Throws:
IOException

getProgress

public float getProgress()
                  throws IOException
Specified by:
getProgress in interface org.apache.hadoop.mapred.RecordReader
Throws:
IOException


Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.