backtype.storm.transactional

Interface ICommitterTransactionalSpout.Emitter

All Superinterfaces:

ITransactionalSpout.Emitter

All Known Implementing Classes:

OpaquePartitionedTransactionalSpoutExecutor.Emitter

Enclosing interface:

ICommitterTransactionalSpout<X>

public static interface ICommitterTransactionalSpout.Emitter
extends ITransactionalSpout.Emitter

Method Summary

Methods

Modifier and Type	Method and Description
void	commit(TransactionAttempt attempt)

Methods inherited from interface backtype.storm.transactional.ITransactionalSpout.Emitter

cleanupBefore, close, emitBatch

Method Detail

commit

void commit(TransactionAttempt attempt)