Uses of Class
org.apache.storm.generated.SubmitOptions
Package
Description
-
Uses of SubmitOptions in org.apache.storm
Modifier and TypeMethodDescriptionstatic 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.submitTopologyWithOpts
(String topologyName, Map<String, Object> conf, StormTopology topology, SubmitOptions submitOpts) Submit a topology to be run in local mode.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.submitTopologyWithOpts
(String topologyName, Map<String, Object> conf, StormTopology topology, SubmitOptions submitOpts) 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
Modifier and TypeMethodDescriptionvoid
Nimbus.submitTopologyWithOpts
(String topoName, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) -
Uses of SubmitOptions in org.apache.storm.generated
Modifier and TypeMethodDescriptionSubmitOptions.deepCopy()
Nimbus.submitTopologyWithOpts_args.get_options()
Modifier and TypeMethodDescriptionint
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) ModifierConstructorDescriptionSubmitOptions
(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
Modifier and TypeMethodDescriptionabstract 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.