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.

Nested Class Summary

static interface	IOpaquePartitionedTransactionalSpout.Coordinator
static interface	IOpaquePartitionedTransactionalSpout.Emitter<X>

Method Summary

IOpaquePartitionedTransactionalSpout.Coordinator	getCoordinator(java.util.Map conf, TopologyContext context)
IOpaquePartitionedTransactionalSpout.Emitter<T>	getEmitter(java.util.Map conf, TopologyContext context)

Methods inherited from interface backtype.storm.topology.IComponent

declareOutputFields, getComponentConfiguration

Method Detail

getEmitter

IOpaquePartitionedTransactionalSpout.Emitter<T> getEmitter(java.util.Map conf,
                                                           TopologyContext context)

getCoordinator

IOpaquePartitionedTransactionalSpout.Coordinator getCoordinator(java.util.Map conf,
                                                                TopologyContext context)