org.apache.storm.transactional.partitioned

Interface IOpaquePartitionedTransactionalSpout<T>

All Superinterfaces:

IComponent, Serializable

All Known Implementing Classes:

BaseOpaquePartitionedTransactionalSpout, OpaqueMemoryTransactionalSpout

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

Nested Classes

Modifier and Type	Interface and Description
static interface	IOpaquePartitionedTransactionalSpout.Coordinator
static interface	IOpaquePartitionedTransactionalSpout.Emitter<X>

Method Summary

Modifier and Type	Method and Description
IOpaquePartitionedTransactionalSpout.Coordinator	getCoordinator(Map conf, TopologyContext context)
IOpaquePartitionedTransactionalSpout.Emitter<T>	getEmitter(Map conf, TopologyContext context)

Methods inherited from interface org.apache.storm.topology.IComponent

declareOutputFields, getComponentConfiguration

Method Detail

getEmitter

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

getCoordinator

IOpaquePartitionedTransactionalSpout.Coordinator getCoordinator(Map conf,
                                                                TopologyContext context)