storm.trident.spout
Interface ICommitterTridentSpout.Emitter

All Superinterfaces:

ITridentSpout.Emitter

All Known Implementing Classes:

OpaquePartitionedTridentSpoutExecutor.Emitter

Enclosing interface:

ICommitterTridentSpout<X>

public static interface ICommitterTridentSpout.Emitter
extends ITridentSpout.Emitter

Method Summary

void	commit(TransactionAttempt attempt)

Methods inherited from interface storm.trident.spout.ITridentSpout.Emitter

close, emitBatch, success

Method Detail

commit

void commit(TransactionAttempt attempt)