Package org.apache.storm.coordination
Class BatchOutputCollectorImpl
java.lang.Object
org.apache.storm.coordination.BatchOutputCollector
org.apache.storm.coordination.BatchOutputCollectorImpl
- 
Constructor SummaryConstructors
- 
Method SummaryMethods inherited from class org.apache.storm.coordination.BatchOutputCollectoremit, emitDirect
- 
Constructor Details- 
BatchOutputCollectorImpl
 
- 
- 
Method Details- 
emit- Specified by:
- emitin class- BatchOutputCollector
 
- 
emitDirect- Specified by:
- emitDirectin class- BatchOutputCollector
 
- 
flushpublic void flush()Description copied from class:BatchOutputCollectorFlush any buffered tuples (when batching is enabled).- Specified by:
- flushin class- BatchOutputCollector
 
- 
reportError- Specified by:
- reportErrorin class- BatchOutputCollector
 
- 
ack
- 
fail
 
-