| 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  | 
TridentJmsSpout
Trident 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 © 2019 The Apache Software Foundation. All Rights Reserved.