storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [1/3] git commit: STORM-501: Missing StormSubmitter API
Date Tue, 23 Sep 2014 18:49:18 GMT
Repository: storm
Updated Branches:
  refs/heads/master a9fb9c58c -> cfcedcf4a


STORM-501: Missing StormSubmitter API


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/32ff6e1f
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/32ff6e1f
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/32ff6e1f

Branch: refs/heads/master
Commit: 32ff6e1fd62a64e156b58af24924ec7b7d5277a4
Parents: 5aae768
Author: Robert (Bobby) Evans <evans@yahoo-inc.com>
Authored: Fri Sep 19 16:03:50 2014 +0000
Committer: Robert (Bobby) Evans <evans@yahoo-inc.com>
Committed: Fri Sep 19 16:24:34 2014 +0000

----------------------------------------------------------------------
 .../src/jvm/backtype/storm/StormSubmitter.java      | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/32ff6e1f/storm-core/src/jvm/backtype/storm/StormSubmitter.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/StormSubmitter.java b/storm-core/src/jvm/backtype/storm/StormSubmitter.java
index 5dfb34b..282c828 100644
--- a/storm-core/src/jvm/backtype/storm/StormSubmitter.java
+++ b/storm-core/src/jvm/backtype/storm/StormSubmitter.java
@@ -71,6 +71,22 @@ public class StormSubmitter {
     }    
 
     /**
+     * Submits a topology to run on the cluster. A topology runs forever or until 
+     * explicitly killed.
+     *
+     * @param name the name of the storm.
+     * @param stormConf the topology-specific configuration. See {@link Config}. 
+     * @param topology the processing to execute.
+     * @param opts to manipulate the starting of the topology.
+     * @throws AlreadyAliveException if a topology with this name is already running
+     * @throws InvalidTopologyException if an invalid topology was submitted
+     */
+    public static void submitTopology(String name, Map stormConf, StormTopology topology,
SubmitOptions opts) 
+            throws AlreadyAliveException, InvalidTopologyException {
+        submitTopology(name, stormConf, topology, opts, null);
+    }
+
+    /**
      * Submits a topology to run on the cluster. A topology runs forever or until
      * explicitly killed.
      *


Mime
View raw message