public class KafkaTridentSpoutTransactional<K,V> extends Object implements IPartitionedTridentSpout<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>>, Serializable
IPartitionedTridentSpout.Coordinator<PartitionsT>, IPartitionedTridentSpout.Emitter<PartitionsT,PartitionT extends ISpoutPartition,X>| Constructor and Description |
|---|
KafkaTridentSpoutTransactional(KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig)
Creates a new non-opaque transactional Trident Kafka spout.
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,Object> |
getComponentConfiguration() |
IPartitionedTridentSpout.Coordinator<List<Map<String,Object>>> |
getCoordinator(Map<String,Object> conf,
TopologyContext context) |
IPartitionedTridentSpout.Emitter<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>> |
getEmitter(Map<String,Object> conf,
TopologyContext context) |
Fields |
getOutputFields() |
public KafkaTridentSpoutTransactional(KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig)
Creates a new non-opaque transactional Trident Kafka spout.
public IPartitionedTridentSpout.Coordinator<List<Map<String,Object>>> getCoordinator(Map<String,Object> conf, TopologyContext context)
getCoordinator in interface IPartitionedTridentSpout<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>>public IPartitionedTridentSpout.Emitter<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>> getEmitter(Map<String,Object> conf, TopologyContext context)
getEmitter in interface IPartitionedTridentSpout<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>>public Map<String,Object> getComponentConfiguration()
getComponentConfiguration in interface IPartitionedTridentSpout<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>>public Fields getOutputFields()
getOutputFields in interface IPartitionedTridentSpout<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>>Copyright © 2021 The Apache Software Foundation. All rights reserved.