org.apache.storm.trident.spout

Interface IOpaquePartitionedTridentSpout<Partitions,Partition extends ISpoutPartition,M>

All Superinterfaces:

ITridentDataSource, Serializable

All Known Implementing Classes:

KafkaTridentSpoutOpaque, OpaqueTridentEventHubSpout, OpaqueTridentKafkaSpout

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

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

Method Summary

Modifier and Type	Method and Description
Map<String,Object>	getComponentConfiguration()
IOpaquePartitionedTridentSpout.Coordinator<Partitions>	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<Partitions> getCoordinator(Map conf,
                                                                      TopologyContext context)

getComponentConfiguration

Map<String,Object> getComponentConfiguration()

getOutputFields

Fields getOutputFields()