| 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  | 
Coordinator  | 
| Modifier and Type | Method and Description | 
|---|---|
IOpaquePartitionedTridentSpout.Coordinator<Partitions> | 
OpaqueTridentEventHubSpout.getCoordinator(Map<String,Object> conf,
              TopologyContext context)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
KafkaTridentSpoutCoordinator<K,V>  | 
| Modifier and Type | Method and Description | 
|---|---|
IOpaquePartitionedTridentSpout.Coordinator<List<Map<String,Object>>> | 
KafkaTridentSpoutOpaque.getCoordinator(Map<String,Object> conf,
              TopologyContext context)  | 
| Modifier and Type | Method and Description | 
|---|---|
IOpaquePartitionedTridentSpout.Coordinator<PartitionsT> | 
IOpaquePartitionedTridentSpout.getCoordinator(Map<String,Object> conf,
              TopologyContext context)  | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.