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 Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
Release any resources held by this emitter.void
commit
(TransactionAttempt attempt) void
emitBatch
(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector) Emit a batch for the specified transaction attempt and metadata for the transaction.void
This attempt committed successfully, so all state for this commit and before can be safely cleaned up.toString()
-
Constructor Details
-
Emitter
-
-
Method Details
-
emitBatch
Description copied from interface:ITridentSpout.Emitter
Emit 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:
emitBatch
in interfaceITridentSpout.Emitter
- Parameters:
tx
- transaction idcoordinatorMeta
- metadata from the coordinator defining this transactioncollector
- output tuple collector
-
success
Description copied from interface:ITridentSpout.Emitter
This attempt committed successfully, so all state for this commit and before can be safely cleaned up.- Specified by:
success
in interfaceITridentSpout.Emitter
- Parameters:
tx
- attempt object containing transaction id and attempt number
-
commit
- Specified by:
commit
in interfaceICommitterTridentSpout.Emitter
-
close
public void close()Description copied from interface:ITridentSpout.Emitter
Release any resources held by this emitter.- Specified by:
close
in interfaceITridentSpout.Emitter
-
toString
-