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 Summary
Nested classes/interfaces inherited from interface org.apache.storm.trident.spout.IOpaquePartitionedTridentSpout
IOpaquePartitionedTridentSpout.Coordinator<PartitionsT>, IOpaquePartitionedTridentSpout.Emitter<PartitionsT,
PartitionT extends ISpoutPartition, M> -
Constructor Summary
ConstructorDescriptionKafkaTridentSpoutOpaque
(KafkaTridentSpoutConfig<K, V> kafkaSpoutConfig) Creates a new opaque transactional Trident Kafka spout. -
Method Summary
Modifier 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 String
toString()
-
Constructor Details
-
KafkaTridentSpoutOpaque
Creates a new opaque transactional Trident Kafka spout.
-
-
Method Details
-
getEmitter
public IOpaquePartitionedTridentSpout.Emitter<List<Map<String,Object>>, getEmitterKafkaTridentSpoutTopicPartition, Map<String, Object>> (Map<String, Object> conf, TopologyContext context) - Specified by:
getEmitter
in interfaceIOpaquePartitionedTridentSpout<List<Map<String,
Object>>, KafkaTridentSpoutTopicPartition, Map<String, Object>>
-
getCoordinator
public IOpaquePartitionedTridentSpout.Coordinator<List<Map<String,Object>>> getCoordinator(Map<String, Object> conf, TopologyContext context) - Specified by:
getCoordinator
in interfaceIOpaquePartitionedTridentSpout<List<Map<String,
Object>>, KafkaTridentSpoutTopicPartition, Map<String, Object>>
-
getComponentConfiguration
- Specified by:
getComponentConfiguration
in interfaceIOpaquePartitionedTridentSpout<List<Map<String,
Object>>, KafkaTridentSpoutTopicPartition, Map<String, Object>>
-
getOutputFields
- Specified by:
getOutputFields
in interfaceIOpaquePartitionedTridentSpout<List<Map<String,
Object>>, KafkaTridentSpoutTopicPartition, Map<String, Object>>
-
toString
-