Uses of Class
org.apache.storm.generated.SubmitOptions
-
Packages that use SubmitOptions Package Description org.apache.storm org.apache.storm.daemon.nimbus org.apache.storm.generated org.apache.storm.sql -
-
Uses of SubmitOptions in org.apache.storm
Methods in org.apache.storm with parameters of type SubmitOptions Modifier and Type Method Description 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.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.ILocalCluster.ILocalTopology
ILocalCluster. submitTopologyWithOpts(String topologyName, Map<String,Object> conf, StormTopology topology, SubmitOptions submitOpts)
Submit a topology to be run in local mode.ILocalCluster.ILocalTopology
ILocalClusterTrackedTopologyAware. submitTopologyWithOpts(String topologyName, Map<String,Object> conf, TrackedTopology topology, SubmitOptions submitOpts)
Submit a tracked topology to be run in local mode.void
LocalCluster. submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
LocalCluster.LocalTopology
LocalCluster. submitTopologyWithOpts(String topologyName, Map<String,Object> conf, StormTopology topology, SubmitOptions submitOpts)
LocalCluster.LocalTopology
LocalCluster. submitTopologyWithOpts(String topologyName, Map<String,Object> conf, TrackedTopology topology, SubmitOptions submitOpts)
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. -
Uses of SubmitOptions in org.apache.storm.daemon.nimbus
Methods in org.apache.storm.daemon.nimbus with parameters of type SubmitOptions Modifier and Type Method Description void
Nimbus. submitTopologyWithOpts(String topoName, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
-
Uses of SubmitOptions in org.apache.storm.generated
Methods in org.apache.storm.generated that return SubmitOptions Modifier and Type Method Description SubmitOptions
SubmitOptions. deepCopy()
SubmitOptions
Nimbus.submitTopologyWithOpts_args. get_options()
Methods in org.apache.storm.generated with parameters of type SubmitOptions Modifier and Type Method Description int
SubmitOptions. compareTo(SubmitOptions other)
boolean
SubmitOptions. equals(SubmitOptions that)
void
Nimbus.Client. send_submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
void
Nimbus.submitTopologyWithOpts_args. set_options(SubmitOptions options)
void
Nimbus.AsyncClient. submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void
Nimbus.AsyncIface. submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void
Nimbus.Client. submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
void
Nimbus.Iface. submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
Constructors in org.apache.storm.generated with parameters of type SubmitOptions Constructor Description SubmitOptions(SubmitOptions other)
Performs a deep copy on other.submitTopologyWithOpts_args(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
submitTopologyWithOpts_call(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.storm.thrift.async.TAsyncClient client, org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.transport.TNonblockingTransport transport)
-
Uses of SubmitOptions in org.apache.storm.sql
Methods in org.apache.storm.sql with parameters of type SubmitOptions Modifier and Type Method Description abstract void
StormSql. submit(String name, Iterable<String> statements, Map<String,Object> topoConf, SubmitOptions opts, StormSubmitter.ProgressListener progressListener, String asUser)
Submit the SQL statements to Nimbus and run it as a topology.
-