public class MeasuredOutputCollector extends Object implements OutputCollector, Flushable, Closeable
Constructor and Description |
---|
MeasuredOutputCollector(FlowProcess flowProcess,
Enum counter) |
MeasuredOutputCollector(FlowProcess flowProcess,
Enum counter,
OutputCollector outputCollector) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
collect(Object key,
Object value) |
void |
flush() |
OutputCollector |
getOutputCollector() |
void |
setOutputCollector(OutputCollector outputCollector) |
public MeasuredOutputCollector(FlowProcess flowProcess, Enum counter)
public MeasuredOutputCollector(FlowProcess flowProcess, Enum counter, OutputCollector outputCollector)
public OutputCollector getOutputCollector()
public void setOutputCollector(OutputCollector outputCollector)
public void collect(Object key, Object value) throws IOException
collect
in interface OutputCollector
IOException
public void flush() throws IOException
flush
in interface Flushable
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.