storm.trident.spout

Interface IOpaquePartitionedTridentSpout<Partitions,Partition extends ISpoutPartition,M>

All Superinterfaces:

Serializable

All Known Implementing Classes:

OpaqueTridentKafkaSpout

public interface IOpaquePartitionedTridentSpout<Partitions,Partition extends ISpoutPartition,M>
extends Serializable

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	IOpaquePartitionedTridentSpout.Coordinator<Partitions>
static interface	IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition extends ISpoutPartition,M>

Method Summary

Modifier and Type	Method and Description
Map	getComponentConfiguration()
IOpaquePartitionedTridentSpout.Coordinator	getCoordinator(Map conf, TopologyContext context)
IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,M>	getEmitter(Map conf, TopologyContext context)
Fields	getOutputFields()

Method Detail

getEmitter

IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,M> getEmitter(Map conf,
                                                                          TopologyContext context)

getCoordinator

IOpaquePartitionedTridentSpout.Coordinator getCoordinator(Map conf,
                                                          TopologyContext context)

getComponentConfiguration

Map getComponentConfiguration()

getOutputFields

Fields getOutputFields()