Package org.apache.storm.trident.spout
Interface IPartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,T>
- All Superinterfaces:
ITridentDataSource
,Serializable
- All Known Implementing Classes:
KafkaTridentSpoutTransactional
public interface IPartitionedTridentSpout<PartitionsT,PartitionT 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
Modifier and TypeInterfaceDescriptionstatic interface
static interface
-
Method Summary
Modifier and TypeMethodDescriptiongetCoordinator
(Map<String, Object> conf, TopologyContext context) getEmitter
(Map<String, Object> conf, TopologyContext context)
-
Method Details
-
getCoordinator
IPartitionedTridentSpout.Coordinator<PartitionsT> getCoordinator(Map<String, Object> conf, TopologyContext context) -
getEmitter
IPartitionedTridentSpout.Emitter<PartitionsT,PartitionT, getEmitterT> (Map<String, Object> conf, TopologyContext context) -
getComponentConfiguration
-
getOutputFields
Fields getOutputFields()
-