cascading.tap.hadoop.util
Class MeasuredOutputCollector
java.lang.Object
cascading.tap.hadoop.util.MeasuredOutputCollector
- All Implemented Interfaces:
- Closeable, org.apache.hadoop.mapred.OutputCollector
public class MeasuredOutputCollector
- extends Object
- implements org.apache.hadoop.mapred.OutputCollector, Closeable
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MeasuredOutputCollector
public MeasuredOutputCollector(FlowProcess flowProcess,
Enum counter)
MeasuredOutputCollector
public MeasuredOutputCollector(FlowProcess flowProcess,
Enum counter,
org.apache.hadoop.mapred.OutputCollector outputCollector)
getOutputCollector
public org.apache.hadoop.mapred.OutputCollector getOutputCollector()
setOutputCollector
public void setOutputCollector(org.apache.hadoop.mapred.OutputCollector outputCollector)
collect
public void collect(Object key,
Object value)
throws IOException
- Specified by:
collect
in interface org.apache.hadoop.mapred.OutputCollector
- Throws:
IOException
close
public void close()
throws IOException
- Specified by:
close
in interface Closeable
- Throws:
IOException
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.