backtype.storm.transactional.partitioned
Interface IOpaquePartitionedTransactionalSpout<T>
- All Superinterfaces:
- IComponent, java.io.Serializable
- All Known Implementing Classes:
- BaseOpaquePartitionedTransactionalSpout
public interface IOpaquePartitionedTransactionalSpout<T>
- extends IComponent
This defines a transactional spout which does *not* necessarily
replay the same batch every time it emits a batch for a transaction id.
getEmitter
IOpaquePartitionedTransactionalSpout.Emitter<T> getEmitter(java.util.Map conf,
TopologyContext context)