| Package | Description | 
|---|---|
| org.apache.storm.jms.trident | |
| org.apache.storm.trident | |
| org.apache.storm.trident.spout | |
| org.apache.storm.trident.testing | |
| org.apache.storm.trident.topology | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | TridentJmsSpoutTrident implementation of the JmsSpout. | 
| Modifier and Type | Method and Description | 
|---|---|
| Stream | TridentTopology. newStream(String txId,
         ITridentSpout spout) | 
| Modifier and Type | Interface and Description | 
|---|---|
| interface  | ICommitterTridentSpout<X> | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | BatchSpoutExecutor | 
| class  | OpaquePartitionedTridentSpoutExecutor | 
| class  | PartitionedTridentSpoutExecutor | 
| class  | RichSpoutBatchExecutor | 
| Constructor and Description | 
|---|
| TridentSpoutCoordinator(String id,
                       ITridentSpout<Object> spout) | 
| TridentSpoutExecutor(String txStateId,
                    String streamName,
                    ITridentSpout<Object> spout) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | FeederBatchSpout | 
| class  | FeederCommitterBatchSpout | 
| Modifier and Type | Method and Description | 
|---|---|
| SpoutDeclarer | TridentTopologyBuilder. setSpout(String id,
        String streamName,
        String txStateId,
        ITridentSpout spout,
        Integer parallelism,
        String batchGroup) | 
| Constructor and Description | 
|---|
| MasterBatchCoordinator(List<String> spoutIds,
                      List<ITridentSpout> spouts) | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.