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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
commit(TransactionAttempt attempt)
-
Methods inherited from interface org.apache.storm.trident.spout.ITridentSpout.Emitter
close, emitBatch, success
-
-
-
-
Method Detail
-
commit
void commit(TransactionAttempt attempt)
-
-