Package | Description |
---|---|
org.apache.storm | |
org.apache.storm.generated | |
org.apache.storm.kafka.trident | |
org.apache.storm.starter.util |
Modifier and Type | Method and Description |
---|---|
static void |
StormSubmitter.submitTopology(String name,
Map stormConf,
StormTopology topology)
Submits a topology to run on the cluster.
|
void |
ILocalCluster.submitTopology(String topologyName,
Map conf,
StormTopology topology) |
static void |
StormSubmitter.submitTopology(String name,
Map stormConf,
StormTopology topology,
SubmitOptions opts)
Submits a topology to run on the cluster.
|
static void |
StormSubmitter.submitTopology(String name,
Map stormConf,
StormTopology topology,
SubmitOptions opts,
StormSubmitter.ProgressListener progressListener)
Submits a topology to run on the cluster.
|
static void |
StormSubmitter.submitTopologyAs(String name,
Map stormConf,
StormTopology topology,
SubmitOptions opts,
StormSubmitter.ProgressListener progressListener,
String asUser)
Submits a topology to run on the cluster as a particular user.
|
void |
ILocalCluster.submitTopologyWithOpts(String topologyName,
Map conf,
StormTopology topology,
SubmitOptions submitOpts) |
static void |
StormSubmitter.submitTopologyWithProgressBar(String name,
Map stormConf,
StormTopology topology)
Submits a topology to run on the cluster with a progress bar.
|
static void |
StormSubmitter.submitTopologyWithProgressBar(String name,
Map stormConf,
StormTopology topology,
SubmitOptions opts)
Submits a topology to run on the cluster with a progress bar.
|
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 |
TridentKafkaClientWordCountNamedTopics.run(String[] args) |
Modifier and Type | Method and Description |
---|---|
static void |
StormRunner.runTopologyRemotely(StormTopology topology,
String topologyName,
Config conf) |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.