public static interface Nimbus.Iface
Modifier and Type | Method and Description |
---|---|
void |
activate(String name) |
String |
beginFileDownload(String file) |
String |
beginFileUpload() |
void |
deactivate(String name) |
ByteBuffer |
downloadChunk(String id) |
void |
finishFileUpload(String location) |
ClusterSummary |
getClusterInfo() |
String |
getNimbusConf() |
StormTopology |
getTopology(String id) |
String |
getTopologyConf(String id) |
TopologyInfo |
getTopologyInfo(String id) |
StormTopology |
getUserTopology(String id) |
void |
killTopology(String name) |
void |
killTopologyWithOpts(String name,
KillOptions options) |
void |
rebalance(String name,
RebalanceOptions options) |
void |
submitTopology(String name,
String uploadedJarLocation,
String jsonConf,
StormTopology topology) |
void |
submitTopologyWithOpts(String name,
String uploadedJarLocation,
String jsonConf,
StormTopology topology,
SubmitOptions options) |
void |
uploadChunk(String location,
ByteBuffer chunk) |
void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, org.apache.thrift.TException
AlreadyAliveException
InvalidTopologyException
org.apache.thrift.TException
void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, org.apache.thrift.TException
AlreadyAliveException
InvalidTopologyException
org.apache.thrift.TException
void killTopology(String name) throws NotAliveException, org.apache.thrift.TException
NotAliveException
org.apache.thrift.TException
void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, org.apache.thrift.TException
NotAliveException
org.apache.thrift.TException
void activate(String name) throws NotAliveException, org.apache.thrift.TException
NotAliveException
org.apache.thrift.TException
void deactivate(String name) throws NotAliveException, org.apache.thrift.TException
NotAliveException
org.apache.thrift.TException
void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, org.apache.thrift.TException
NotAliveException
InvalidTopologyException
org.apache.thrift.TException
String beginFileUpload() throws org.apache.thrift.TException
org.apache.thrift.TException
void uploadChunk(String location, ByteBuffer chunk) throws org.apache.thrift.TException
org.apache.thrift.TException
void finishFileUpload(String location) throws org.apache.thrift.TException
org.apache.thrift.TException
String beginFileDownload(String file) throws org.apache.thrift.TException
org.apache.thrift.TException
ByteBuffer downloadChunk(String id) throws org.apache.thrift.TException
org.apache.thrift.TException
String getNimbusConf() throws org.apache.thrift.TException
org.apache.thrift.TException
ClusterSummary getClusterInfo() throws org.apache.thrift.TException
org.apache.thrift.TException
TopologyInfo getTopologyInfo(String id) throws NotAliveException, org.apache.thrift.TException
NotAliveException
org.apache.thrift.TException
String getTopologyConf(String id) throws NotAliveException, org.apache.thrift.TException
NotAliveException
org.apache.thrift.TException
StormTopology getTopology(String id) throws NotAliveException, org.apache.thrift.TException
NotAliveException
org.apache.thrift.TException
StormTopology getUserTopology(String id) throws NotAliveException, org.apache.thrift.TException
NotAliveException
org.apache.thrift.TException
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.