| Package | Description |
|---|---|
| backtype.storm |
| Modifier and Type | Method and Description |
|---|---|
static String |
StormSubmitter.submitJar(Map conf,
String localJar,
StormSubmitter.ProgressListener listener)
Submit jar file
|
static String |
StormSubmitter.submitJarAs(Map conf,
String localJar,
StormSubmitter.ProgressListener listener,
String asUser) |
static void |
StormSubmitter.submitTopology(String name,
Map stormConf,
StormTopology topology,
SubmitOptions opts,
StormSubmitter.ProgressListener progressListener)
Submits a topology to run on the cluster.
|
static void |
StormSubmitter.submitTopologyAs(String name,
Map stormConf,
StormTopology topology,
SubmitOptions opts,
StormSubmitter.ProgressListener progressListener,
String asUser) |
Copyright © 2015. All rights reserved.