Package org.apache.storm.coordination
Class BatchOutputCollectorImpl
- java.lang.Object
-
- org.apache.storm.coordination.BatchOutputCollector
-
- org.apache.storm.coordination.BatchOutputCollectorImpl
-
public class BatchOutputCollectorImpl extends BatchOutputCollector
-
-
Constructor Summary
Constructors Constructor Description BatchOutputCollectorImpl(OutputCollector collector)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidack(Tuple tup)List<Integer>emit(String streamId, List<Object> tuple)voidemitDirect(int taskId, String streamId, List<Object> tuple)voidfail(Tuple tup)voidflush()Flush any buffered tuples (when batching is enabled).voidreportError(Throwable error)-
Methods inherited from class org.apache.storm.coordination.BatchOutputCollector
emit, emitDirect
-
-
-
-
Constructor Detail
-
BatchOutputCollectorImpl
public BatchOutputCollectorImpl(OutputCollector collector)
-
-
Method Detail
-
emit
public List<Integer> emit(String streamId, List<Object> tuple)
- Specified by:
emitin classBatchOutputCollector
-
emitDirect
public void emitDirect(int taskId, String streamId, List<Object> tuple)- Specified by:
emitDirectin classBatchOutputCollector
-
flush
public void flush()
Description copied from class:BatchOutputCollectorFlush any buffered tuples (when batching is enabled).- Specified by:
flushin classBatchOutputCollector
-
reportError
public void reportError(Throwable error)
- Specified by:
reportErrorin classBatchOutputCollector
-
ack
public void ack(Tuple tup)
-
fail
public void fail(Tuple tup)
-
-