| Package | Description | 
|---|---|
| org.apache.storm | |
| org.apache.storm.daemon.nimbus | |
| org.apache.storm.elasticsearch.bolt | 
 ElasticSearch examples classes. 
 | 
| org.apache.storm.elasticsearch.trident | 
 ElasticSearch Trident example classes. 
 | 
| org.apache.storm.generated | |
| org.apache.storm.kafka.trident | |
| org.apache.storm.utils | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
StormSubmitter.submitTopology(String name,
              Map<String,Object> topoConf,
              StormTopology topology)
Submits a topology to run on the cluster. 
 | 
static void | 
StormSubmitter.submitTopology(String name,
              Map<String,Object> topoConf,
              StormTopology topology,
              SubmitOptions opts)
Submits a topology to run on the cluster. 
 | 
static void | 
StormSubmitter.submitTopology(String name,
              Map<String,Object> topoConf,
              StormTopology topology,
              SubmitOptions opts,
              StormSubmitter.ProgressListener progressListener)
Submits a topology to run on the cluster. 
 | 
void | 
LocalCluster.submitTopology(String name,
              String uploadedJarLocation,
              String jsonConf,
              StormTopology topology)  | 
static void | 
StormSubmitter.submitTopologyAs(String name,
                Map<String,Object> topoConf,
                StormTopology topology,
                SubmitOptions opts,
                StormSubmitter.ProgressListener progressListener,
                String asUser)
Submits a topology to run on the cluster as a particular user. 
 | 
void | 
LocalCluster.submitTopologyWithOpts(String name,
                      String uploadedJarLocation,
                      String jsonConf,
                      StormTopology topology,
                      SubmitOptions options)  | 
static void | 
StormSubmitter.submitTopologyWithProgressBar(String name,
                             Map<String,Object> topoConf,
                             StormTopology topology)
Submits a topology to run on the cluster with a progress bar. 
 | 
static void | 
StormSubmitter.submitTopologyWithProgressBar(String name,
                             Map<String,Object> topoConf,
                             StormTopology topology,
                             SubmitOptions opts)
Submits a topology to run on the cluster with a progress bar. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
Nimbus.submitTopology(String name,
              String uploadedJarLocation,
              String jsonConf,
              StormTopology topology)  | 
void | 
Nimbus.submitTopologyWithOpts(String topoName,
                      String uploadedJarLocation,
                      String jsonConf,
                      StormTopology topology,
                      SubmitOptions options)  | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
EsIndexTopology.main(String[] args)
The example’s main method. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
TridentEsTopology.main(String[] args)
The example’s main method. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
AlreadyAliveException | 
AlreadyAliveException.deepCopy()  | 
AlreadyAliveException | 
Nimbus.submitTopology_result.get_e()  | 
AlreadyAliveException | 
Nimbus.submitTopologyWithOpts_result.get_e()  | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
AlreadyAliveException.compareTo(AlreadyAliveException other)  | 
boolean | 
AlreadyAliveException.equals(AlreadyAliveException that)  | 
void | 
Nimbus.submitTopology_result.set_e(AlreadyAliveException e)  | 
void | 
Nimbus.submitTopologyWithOpts_result.set_e(AlreadyAliveException e)  | 
| Modifier and Type | Method and Description | 
|---|---|
Void | 
Nimbus.AsyncClient.submitTopology_call.getResult()  | 
Void | 
Nimbus.AsyncClient.submitTopologyWithOpts_call.getResult()  | 
void | 
Nimbus.Client.recv_submitTopology()  | 
void | 
Nimbus.Client.recv_submitTopologyWithOpts()  | 
void | 
Nimbus.Iface.submitTopology(String name,
              String uploadedJarLocation,
              String jsonConf,
              StormTopology topology)  | 
void | 
Nimbus.Client.submitTopology(String name,
              String uploadedJarLocation,
              String jsonConf,
              StormTopology topology)  | 
void | 
Nimbus.Iface.submitTopologyWithOpts(String name,
                      String uploadedJarLocation,
                      String jsonConf,
                      StormTopology topology,
                      SubmitOptions options)  | 
void | 
Nimbus.Client.submitTopologyWithOpts(String name,
                      String uploadedJarLocation,
                      String jsonConf,
                      StormTopology topology,
                      SubmitOptions options)  | 
| Constructor and Description | 
|---|
AlreadyAliveException(AlreadyAliveException other)
Performs a deep copy on other. 
 | 
submitTopology_result(AlreadyAliveException e,
                     InvalidTopologyException ite,
                     AuthorizationException aze)  | 
submitTopologyWithOpts_result(AlreadyAliveException e,
                             InvalidTopologyException ite,
                             AuthorizationException aze)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected void | 
TridentKafkaClientTopologyNamedTopics.run(String[] args)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
WrappedAlreadyAliveException
Wraps the generated TException to allow getMessage() to return a valid string. 
 | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.