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