You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/09/23 20:49:18 UTC
[1/3] git commit: STORM-501: Missing StormSubmitter API
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 <ev...@yahoo-inc.com>
Authored: Fri Sep 19 16:03:50 2014 +0000
Committer: Robert (Bobby) Evans <ev...@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.
*
[2/3] git commit: Merge branch 'STORM-501' of
http://github.com/revans2/incubator-storm into STORM-501
Posted by bo...@apache.org.
Merge branch 'STORM-501' of http://github.com/revans2/incubator-storm into STORM-501
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/94e731c1
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/94e731c1
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/94e731c1
Branch: refs/heads/master
Commit: 94e731c153488996c60fd764b030ae90a5bb0639
Parents: a9fb9c5 32ff6e1
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Tue Sep 23 13:43:27 2014 -0500
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Tue Sep 23 13:43:27 2014 -0500
----------------------------------------------------------------------
.../src/jvm/backtype/storm/StormSubmitter.java | 16 ++++++++++++++++
1 file changed, 16 insertions(+)
----------------------------------------------------------------------
[3/3] git commit: Added STORM-501 to changelog
Posted by bo...@apache.org.
Added STORM-501 to changelog
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/cfcedcf4
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/cfcedcf4
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/cfcedcf4
Branch: refs/heads/master
Commit: cfcedcf4ad5e5c96fe3f30a0b710cfc604063231
Parents: 94e731c
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Tue Sep 23 13:43:57 2014 -0500
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Tue Sep 23 13:43:57 2014 -0500
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/cfcedcf4/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 30082b8..24d89c3 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -74,6 +74,7 @@
* STORM-336: Logback version should be upgraded
* STORM-386: nodejs multilang protocol implementation and examples
* STORM-500: Add Spinner when UI is loading stats from nimbus
+ * STORM-501: Missing StormSubmitter API
## 0.9.2-incubating
* STORM-66: send taskid on initial handshake