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