Uses of Interface
org.apache.storm.StormSubmitter.ProgressListener
-
Uses of StormSubmitter.ProgressListener in org.apache.storm
Modifier and TypeMethodDescriptionstatic String
StormSubmitter.submitJar
(Map<String, Object> conf, String localJar, StormSubmitter.ProgressListener listener) Submit jar file.static String
StormSubmitter.submitJarAs
(Map<String, Object> conf, String localJar, StormSubmitter.ProgressListener listener, String asUser) static String
StormSubmitter.submitJarAs
(Map<String, Object> conf, String localJar, StormSubmitter.ProgressListener listener, NimbusClient client) 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. -
Uses of StormSubmitter.ProgressListener 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.