Package org.apache.storm.trident.spout
Class OpaquePartitionedTridentSpoutExecutor.Emitter
java.lang.Object
org.apache.storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Emitter
- All Implemented Interfaces:
- ICommitterTridentSpout.Emitter,- ITridentSpout.Emitter
- Enclosing class:
- OpaquePartitionedTridentSpoutExecutor
public class OpaquePartitionedTridentSpoutExecutor.Emitter
extends Object
implements ICommitterTridentSpout.Emitter
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidclose()Release any resources held by this emitter.voidcommit(TransactionAttempt attempt) voidemitBatch(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector) Emit a batch for the specified transaction attempt and metadata for the transaction.voidThis attempt committed successfully, so all state for this commit and before can be safely cleaned up.toString()
- 
Constructor Details- 
Emitter
 
- 
- 
Method Details- 
emitBatchDescription copied from interface:ITridentSpout.EmitterEmit a batch for the specified transaction attempt and metadata for the transaction. The metadata was created by the Coordinator in the initializeTransaction method. This method must always emit the same batch of tuples across all tasks for the same transaction id.- Specified by:
- emitBatchin interface- ITridentSpout.Emitter
- Parameters:
- tx- transaction id
- coordinatorMeta- metadata from the coordinator defining this transaction
- collector- output tuple collector
 
- 
successDescription copied from interface:ITridentSpout.EmitterThis attempt committed successfully, so all state for this commit and before can be safely cleaned up.- Specified by:
- successin interface- ITridentSpout.Emitter
- Parameters:
- tx- attempt object containing transaction id and attempt number
 
- 
commit- Specified by:
- commitin interface- ICommitterTridentSpout.Emitter
 
- 
closepublic void close()Description copied from interface:ITridentSpout.EmitterRelease any resources held by this emitter.- Specified by:
- closein interface- ITridentSpout.Emitter
 
- 
toString
 
-