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

Methods

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

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

close, emitBatch, success

Method Detail

commit

void commit(TransactionAttempt attempt)