public class StormSubmitter extends Object
| Modifier and Type | Class and Description |
|---|---|
static interface |
StormSubmitter.ProgressListener
Interface use to track progress of file upload
|
| Modifier and Type | Field and Description |
|---|---|
static org.slf4j.Logger |
LOG |
static Pattern |
zkDigestPattern |
| Constructor and Description |
|---|
StormSubmitter() |
| Modifier and Type | Method and Description |
|---|---|
static Map |
prepareZookeeperAuthentication(Map conf) |
static void |
pushCredentials(String name,
Map stormConf,
Map<String,String> credentials)
Push a new set of credentials to the running topology.
|
static void |
setLocalNimbus(ILocalCluster localNimbusHandler) |
static String |
submitJar(Map conf,
String localJar)
Submit jar file
|
static String |
submitJar(Map conf,
String localJar,
StormSubmitter.ProgressListener listener)
Submit jar file
|
static String |
submitJarAs(Map conf,
String localJar,
StormSubmitter.ProgressListener listener,
String asUser) |
static void |
submitTopology(String name,
Map stormConf,
StormTopology topology)
Submits a topology to run on the cluster.
|
static void |
submitTopology(String name,
Map stormConf,
StormTopology topology,
SubmitOptions opts)
Submits a topology to run on the cluster.
|
static void |
submitTopology(String name,
Map stormConf,
StormTopology topology,
SubmitOptions opts,
StormSubmitter.ProgressListener progressListener)
Submits a topology to run on the cluster.
|
static void |
submitTopologyAs(String name,
Map stormConf,
StormTopology topology,
SubmitOptions opts,
StormSubmitter.ProgressListener progressListener,
String asUser) |
static void |
submitTopologyWithProgressBar(String name,
Map stormConf,
StormTopology topology)
Submits a topology to run on the cluster with a progress bar.
|
static void |
submitTopologyWithProgressBar(String name,
Map stormConf,
StormTopology topology,
SubmitOptions opts)
Submits a topology to run on the cluster with a progress bar.
|
static boolean |
validateZKDigestPayload(String payload) |
public static org.slf4j.Logger LOG
public static final Pattern zkDigestPattern
public static void setLocalNimbus(ILocalCluster localNimbusHandler)
public static boolean validateZKDigestPayload(String payload)
public static void pushCredentials(String name, Map stormConf, Map<String,String> credentials) throws AuthorizationException, NotAliveException, InvalidTopologyException
name - the name of the topology to push credentials to.stormConf - the topology-specific configuration, if desired. See Config.credentials - the credentials to push.AuthorizationException - if you are not authorized ot push credentials.NotAliveException - if the topology is not aliveInvalidTopologyException - if any other error happenspublic static void submitTopology(String name, Map stormConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException
name - the name of the storm.stormConf - the topology-specific configuration. See Config.topology - the processing to execute.AlreadyAliveException - if a topology with this name is already runningInvalidTopologyException - if an invalid topology was submittedAuthorizationException - if authorization is failedpublic static void submitTopology(String name, Map stormConf, StormTopology topology, SubmitOptions opts) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException
name - the name of the storm.stormConf - the topology-specific configuration. See Config.topology - the processing to execute.opts - to manipulate the starting of the topology.AlreadyAliveException - if a topology with this name is already runningInvalidTopologyException - if an invalid topology was submittedAuthorizationException - if authorization is failedpublic static void submitTopologyAs(String name, Map stormConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener, String asUser) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException
name - stormConf - topology - opts - progressListener - asUser - The user as which this topology should be submitted.AlreadyAliveExceptionInvalidTopologyExceptionAuthorizationExceptionpublic static void submitTopology(String name, Map stormConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException
name - the name of the storm.stormConf - the topology-specific configuration. See Config.topology - the processing to execute.opts - to manipulate the starting of the topologyprogressListener - to track the progress of the jar upload processAlreadyAliveException - if a topology with this name is already runningInvalidTopologyException - if an invalid topology was submittedAuthorizationException - if authorization is failedpublic static void submitTopologyWithProgressBar(String name, Map stormConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException
name - the name of the storm.stormConf - the topology-specific configuration. See Config.topology - the processing to execute.AlreadyAliveException - if a topology with this name is already runningInvalidTopologyException - if an invalid topology was submittedAuthorizationException - if authorization is failedpublic static void submitTopologyWithProgressBar(String name, Map stormConf, StormTopology topology, SubmitOptions opts) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException
name - the name of the storm.stormConf - the topology-specific configuration. See Config.topology - the processing to execute.opts - to manipulate the starting of the topologyAlreadyAliveException - if a topology with this name is already runningInvalidTopologyException - if an invalid topology was submittedAuthorizationException - if authorization is failedpublic static String submitJar(Map conf, String localJar)
conf - the topology-specific configuration. See Config.localJar - file path of the jar file to submitpublic static String submitJarAs(Map conf, String localJar, StormSubmitter.ProgressListener listener, String asUser)
public static String submitJar(Map conf, String localJar, StormSubmitter.ProgressListener listener)
conf - the topology-specific configuration. See Config.localJar - file path of the jar file to submitlistener - progress listener to track the jar file uploadCopyright © 2015. All rights reserved.