Class KafkaTridentSpoutTransactional<K,V> 
java.lang.Object
org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTransactional<K,V> 
- All Implemented Interfaces:
- Serializable,- IPartitionedTridentSpout<List<Map<String,,- Object>>, - KafkaTridentSpoutTopicPartition, - Map<String, - Object>> - ITridentDataSource
public class KafkaTridentSpoutTransactional<K,V> 
extends Object
implements IPartitionedTridentSpout<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>>, Serializable    
- See Also:
- 
Nested Class SummaryNested classes/interfaces inherited from interface org.apache.storm.trident.spout.IPartitionedTridentSpoutIPartitionedTridentSpout.Coordinator<PartitionsT>, IPartitionedTridentSpout.Emitter<PartitionsT,PartitionT extends ISpoutPartition, X> 
- 
Constructor SummaryConstructorsConstructorDescriptionKafkaTridentSpoutTransactional(KafkaTridentSpoutConfig<K, V> kafkaSpoutConfig) Creates a new non-opaque transactional Trident Kafka spout.
- 
Method SummaryModifier and TypeMethodDescriptiongetCoordinator(Map<String, Object> conf, TopologyContext context) IPartitionedTridentSpout.Emitter<List<Map<String,Object>>, KafkaTridentSpoutTopicPartition, Map<String, Object>> getEmitter(Map<String, Object> conf, TopologyContext context) 
- 
Constructor Details- 
KafkaTridentSpoutTransactionalCreates a new non-opaque transactional Trident Kafka spout.
 
- 
- 
Method Details- 
getCoordinatorpublic IPartitionedTridentSpout.Coordinator<List<Map<String,Object>>> getCoordinator(Map<String, Object> conf, TopologyContext context) - Specified by:
- getCoordinatorin interface- IPartitionedTridentSpout<List<Map<String,- Object>>, - KafkaTridentSpoutTopicPartition, - Map<String, - Object>> 
 
- 
getEmitterpublic IPartitionedTridentSpout.Emitter<List<Map<String,Object>>, getEmitterKafkaTridentSpoutTopicPartition, Map<String, Object>> (Map<String, Object> conf, TopologyContext context) - Specified by:
- getEmitterin interface- IPartitionedTridentSpout<List<Map<String,- Object>>, - KafkaTridentSpoutTopicPartition, - Map<String, - Object>> 
 
- 
getComponentConfiguration- Specified by:
- getComponentConfigurationin interface- IPartitionedTridentSpout<List<Map<String,- Object>>, - KafkaTridentSpoutTopicPartition, - Map<String, - Object>> 
 
- 
getOutputFields- Specified by:
- getOutputFieldsin interface- IPartitionedTridentSpout<List<Map<String,- Object>>, - KafkaTridentSpoutTopicPartition, - Map<String, - Object>> 
 
 
-