cascading.tap.hadoop.util
Class MeasuredOutputCollector
java.lang.Object
cascading.tap.hadoop.util.MeasuredOutputCollector
- All Implemented Interfaces:
- Closeable, OutputCollector
public class MeasuredOutputCollector
- extends Object
- implements 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,
OutputCollector outputCollector)
getOutputCollector
public OutputCollector getOutputCollector()
setOutputCollector
public void setOutputCollector(OutputCollector outputCollector)
collect
public void collect(Object key,
Object value)
throws IOException
- Specified by:
collect
in interface OutputCollector
- Throws:
IOException
close
public void close()
throws IOException
- Specified by:
close
in interface Closeable
- Throws:
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.