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 © 2023 The Apache Software Foundation. All rights reserved.