storm.trident.spout
Class OpaquePartitionedTridentSpoutExecutor.Emitter

java.lang.Object
  extended by storm.trident.spout.OpaquePartitionedTridentSpoutExecutor.Emitter
All Implemented Interfaces:
ICommitterTridentSpout.Emitter, ITridentSpout.Emitter
Enclosing class:
OpaquePartitionedTridentSpoutExecutor

public class OpaquePartitionedTridentSpoutExecutor.Emitter
extends java.lang.Object
implements ICommitterTridentSpout.Emitter


Constructor Summary
OpaquePartitionedTridentSpoutExecutor.Emitter(java.lang.String txStateId, java.util.Map conf, TopologyContext context)
           
 
Method Summary
 void close()
          Release any resources held by this emitter.
 void commit(TransactionAttempt attempt)
           
 void emitBatch(TransactionAttempt tx, java.lang.Object coordinatorMeta, TridentCollector collector)
          Emit a batch for the specified transaction attempt and metadata for the transaction.
 void success(TransactionAttempt tx)
          This attempt committed successfully, so all state for this commit and before can be safely cleaned up.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

OpaquePartitionedTridentSpoutExecutor.Emitter

public OpaquePartitionedTridentSpoutExecutor.Emitter(java.lang.String txStateId,
                                                     java.util.Map conf,
                                                     TopologyContext context)
Method Detail

emitBatch

public void emitBatch(TransactionAttempt tx,
                      java.lang.Object coordinatorMeta,
                      TridentCollector collector)
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 initializeTranaction method. This method must always emit the same batch of tuples across all tasks for the same transaction id.

Specified by:
emitBatch in interface ITridentSpout.Emitter

success

public void success(TransactionAttempt tx)
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 interface ITridentSpout.Emitter

commit

public void commit(TransactionAttempt attempt)
Specified by:
commit in interface ICommitterTridentSpout.Emitter

close

public void close()
Description copied from interface: ITridentSpout.Emitter
Release any resources held by this emitter.

Specified by:
close in interface ITridentSpout.Emitter