Package org.apache.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

Modifier and Type	Method	Description
void	commit(TransactionAttempt attempt)

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

close, emitBatch, success

Method Details

commit

void commit(TransactionAttempt attempt)