def admin(*args):
    "Syntax: [storm admin cmd [options]]\n\n    The storm admin command provides access to several operations that can help\n    an administrator debug or fix a cluster.\n\n    remove_corrupt_topologies - This command should be run on a nimbus node as\n    the same user nimbus runs as.  It will go directly to zookeeper + blobstore\n    and find topologies that appear to be corrupted because of missing blobs.\n    It will kill those topologies.\n\n    zk_cli [options] - This command will launch a zookeeper cli pointing to the\n    storm zookeeper instance logged in as the nimbus user.  It should be run on\n    a nimbus server as the user nimbus runs as.\n        -s --server <connection string>: Set the connection string to use,\n            defaults to storm connection string.\n        -t --time-out <timeout>:  Set the timeout to use, defaults to storm\n            zookeeper timeout.\n        -w --write: Allow for writes, defaults to read only, we don't want to\n            cause problems.\n        -n --no-root: Don't include the storm root on the default connection string.\n        -j --jaas <jaas_file>: Include a jaas file that should be used when\n            authenticating with ZK defaults to the\n            java.security.auth.login.config conf.\n\n    creds topology_id - Print the credential keys for a topology.\n    "
    exec_storm_class('org.apache.storm.command.AdminCommands', args=args, jvmtype='-client', extrajars=[USER_CONF_DIR, os.path.join(STORM_DIR, 'bin')])
Syntax: [storm admin cmd [options]]

The storm admin command provides access to several operations that can help
an administrator debug or fix a cluster.

remove_corrupt_topologies - This command should be run on a nimbus node as
the same user nimbus runs as.  It will go directly to zookeeper + blobstore
and find topologies that appear to be corrupted because of missing blobs.
It will kill those topologies.

zk_cli [options] - This command will launch a zookeeper cli pointing to the
storm zookeeper instance logged in as the nimbus user.  It should be run on
a nimbus server as the user nimbus runs as.
    -s --server <connection string>: Set the connection string to use,
        defaults to storm connection string.
    -t --time-out <timeout>:  Set the timeout to use, defaults to storm
        zookeeper timeout.
    -w --write: Allow for writes, defaults to read only, we don't want to
        cause problems.
    -n --no-root: Don't include the storm root on the default connection string.
    -j --jaas <jaas_file>: Include a jaas file that should be used when
        authenticating with ZK defaults to the
        java.security.auth.login.config conf.

creds topology_id - Print the credential keys for a topology.
def admin(*args):
    "Syntax: [storm admin cmd [options]]\n\n    The storm admin command provides access to several operations that can help\n    an administrator debug or fix a cluster.\n\n    remove_corrupt_topologies - This command should be run on a nimbus node as\n    the same user nimbus runs as.  It will go directly to zookeeper + blobstore\n    and find topologies that appear to be corrupted because of missing blobs.\n    It will kill those topologies.\n\n    zk_cli [options] - This command will launch a zookeeper cli pointing to the\n    storm zookeeper instance logged in as the nimbus user.  It should be run on\n    a nimbus server as the user nimbus runs as.\n        -s --server <connection string>: Set the connection string to use,\n            defaults to storm connection string.\n        -t --time-out <timeout>:  Set the timeout to use, defaults to storm\n            zookeeper timeout.\n        -w --write: Allow for writes, defaults to read only, we don't want to\n            cause problems.\n        -n --no-root: Don't include the storm root on the default connection string.\n        -j --jaas <jaas_file>: Include a jaas file that should be used when\n            authenticating with ZK defaults to the\n            java.security.auth.login.config conf.\n\n    creds topology_id - Print the credential keys for a topology.\n    "
    exec_storm_class('org.apache.storm.command.AdminCommands', args=args, jvmtype='-client', extrajars=[USER_CONF_DIR, os.path.join(STORM_DIR, 'bin')])