From dbec495fe689bd4ead55f5ebb25ebcbaaff9c1e8 Mon Sep 17 00:00:00 2001 From: Xin Wang Date: Wed, 8 Jun 2016 13:36:25 +0800 Subject: [PATCH] STORM-1888: add description for shell command --- bin/storm.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/bin/storm.py b/bin/storm.py index c9667c72213..5b3f392d567 100755 --- a/bin/storm.py +++ b/bin/storm.py @@ -485,6 +485,11 @@ def kill_workers(*args): extrajars=[USER_CONF_DIR, os.path.join(STORM_DIR, "bin")]) def shell(resourcesdir, command, *args): + """Syntax: [storm shell resourcesdir command args] + + Archives resources to jar and uploads jar to Nimbus, and executes following arguments on "local". Useful for non JVM languages. + eg: `storm shell resources/ python topology.py arg1 arg2` + """ tmpjarpath = "stormshell" + str(random.randint(0, 10000000)) + ".jar" os.system("jar cf %s %s" % (tmpjarpath, resourcesdir)) runnerargs = [tmpjarpath, command]