| Package | Description | 
|---|---|
| org.apache.storm.eventhubs.trident | |
| org.apache.storm.kafka.spout.trident | |
| org.apache.storm.trident.spout | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
TransactionalTridentEventHubEmitter  | 
| Modifier and Type | Method and Description | 
|---|---|
IPartitionedTridentSpout.Emitter<Partitions,Partition,Map<String,Object>> | 
TransactionalTridentEventHubSpout.getEmitter(Map<String,Object> conf,
          TopologyContext context)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
KafkaTridentTransactionalSpoutEmitter<K,V>  | 
| Modifier and Type | Method and Description | 
|---|---|
IPartitionedTridentSpout.Emitter<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>> | 
KafkaTridentSpoutTransactional.getEmitter(Map<String,Object> conf,
          TopologyContext context)  | 
| Modifier and Type | Method and Description | 
|---|---|
IPartitionedTridentSpout.Emitter<PartitionsT,PartitionT,T> | 
IPartitionedTridentSpout.getEmitter(Map<String,Object> conf,
          TopologyContext context)  | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.