org.apache.storm.trident.spout

Interface IPartitionedTridentSpout<Partitions,Partition extends ISpoutPartition,T>

All Superinterfaces:

ITridentDataSource, Serializable

All Known Implementing Classes:

KafkaTridentSpoutTransactional, TransactionalTridentEventHubSpout, TransactionalTridentKafkaSpout

public interface IPartitionedTridentSpout<Partitions,Partition extends ISpoutPartition,T>
extends ITridentDataSource

This interface defines a transactional spout that reads its tuples from a partitioned set of brokers. It automates the storing of metadata for each partition to ensure that the same batch is always emitted for the same transaction id. The partition metadata is stored in Zookeeper.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	IPartitionedTridentSpout.Coordinator<Partitions>
static interface	IPartitionedTridentSpout.Emitter<Partitions,Partition extends ISpoutPartition,X>

Method Summary

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

Method Detail

getCoordinator

IPartitionedTridentSpout.Coordinator<Partitions> getCoordinator(Map conf,
                                                                TopologyContext context)

getEmitter

IPartitionedTridentSpout.Emitter<Partitions,Partition,T> getEmitter(Map conf,
                                                                    TopologyContext context)

getComponentConfiguration

Map<String,Object> getComponentConfiguration()

getOutputFields

Fields getOutputFields()