public static class Nimbus.Client extends org.apache.thrift.TServiceClient implements Nimbus.Iface
Modifier and Type | Class and Description |
---|---|
static class |
Nimbus.Client.Factory |
Constructor and Description |
---|
Client(org.apache.thrift.protocol.TProtocol prot) |
Client(org.apache.thrift.protocol.TProtocol iprot,
org.apache.thrift.protocol.TProtocol oprot) |
public Client(org.apache.thrift.protocol.TProtocol prot)
public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot)
public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, org.apache.thrift.TException
submitTopology
in interface Nimbus.Iface
AlreadyAliveException
InvalidTopologyException
org.apache.thrift.TException
public void send_submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_submitTopology() throws AlreadyAliveException, InvalidTopologyException, org.apache.thrift.TException
AlreadyAliveException
InvalidTopologyException
org.apache.thrift.TException
public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, org.apache.thrift.TException
submitTopologyWithOpts
in interface Nimbus.Iface
AlreadyAliveException
InvalidTopologyException
org.apache.thrift.TException
public void send_submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_submitTopologyWithOpts() throws AlreadyAliveException, InvalidTopologyException, org.apache.thrift.TException
AlreadyAliveException
InvalidTopologyException
org.apache.thrift.TException
public void killTopology(String name) throws NotAliveException, org.apache.thrift.TException
killTopology
in interface Nimbus.Iface
NotAliveException
org.apache.thrift.TException
public void send_killTopology(String name) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_killTopology() throws NotAliveException, org.apache.thrift.TException
NotAliveException
org.apache.thrift.TException
public void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, org.apache.thrift.TException
killTopologyWithOpts
in interface Nimbus.Iface
NotAliveException
org.apache.thrift.TException
public void send_killTopologyWithOpts(String name, KillOptions options) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_killTopologyWithOpts() throws NotAliveException, org.apache.thrift.TException
NotAliveException
org.apache.thrift.TException
public void activate(String name) throws NotAliveException, org.apache.thrift.TException
activate
in interface Nimbus.Iface
NotAliveException
org.apache.thrift.TException
public void send_activate(String name) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_activate() throws NotAliveException, org.apache.thrift.TException
NotAliveException
org.apache.thrift.TException
public void deactivate(String name) throws NotAliveException, org.apache.thrift.TException
deactivate
in interface Nimbus.Iface
NotAliveException
org.apache.thrift.TException
public void send_deactivate(String name) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_deactivate() throws NotAliveException, org.apache.thrift.TException
NotAliveException
org.apache.thrift.TException
public void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, org.apache.thrift.TException
rebalance
in interface Nimbus.Iface
NotAliveException
InvalidTopologyException
org.apache.thrift.TException
public void send_rebalance(String name, RebalanceOptions options) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_rebalance() throws NotAliveException, InvalidTopologyException, org.apache.thrift.TException
NotAliveException
InvalidTopologyException
org.apache.thrift.TException
public String beginFileUpload() throws org.apache.thrift.TException
beginFileUpload
in interface Nimbus.Iface
org.apache.thrift.TException
public void send_beginFileUpload() throws org.apache.thrift.TException
org.apache.thrift.TException
public String recv_beginFileUpload() throws org.apache.thrift.TException
org.apache.thrift.TException
public void uploadChunk(String location, ByteBuffer chunk) throws org.apache.thrift.TException
uploadChunk
in interface Nimbus.Iface
org.apache.thrift.TException
public void send_uploadChunk(String location, ByteBuffer chunk) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_uploadChunk() throws org.apache.thrift.TException
org.apache.thrift.TException
public void finishFileUpload(String location) throws org.apache.thrift.TException
finishFileUpload
in interface Nimbus.Iface
org.apache.thrift.TException
public void send_finishFileUpload(String location) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_finishFileUpload() throws org.apache.thrift.TException
org.apache.thrift.TException
public String beginFileDownload(String file) throws org.apache.thrift.TException
beginFileDownload
in interface Nimbus.Iface
org.apache.thrift.TException
public void send_beginFileDownload(String file) throws org.apache.thrift.TException
org.apache.thrift.TException
public String recv_beginFileDownload() throws org.apache.thrift.TException
org.apache.thrift.TException
public ByteBuffer downloadChunk(String id) throws org.apache.thrift.TException
downloadChunk
in interface Nimbus.Iface
org.apache.thrift.TException
public void send_downloadChunk(String id) throws org.apache.thrift.TException
org.apache.thrift.TException
public ByteBuffer recv_downloadChunk() throws org.apache.thrift.TException
org.apache.thrift.TException
public String getNimbusConf() throws org.apache.thrift.TException
getNimbusConf
in interface Nimbus.Iface
org.apache.thrift.TException
public void send_getNimbusConf() throws org.apache.thrift.TException
org.apache.thrift.TException
public String recv_getNimbusConf() throws org.apache.thrift.TException
org.apache.thrift.TException
public ClusterSummary getClusterInfo() throws org.apache.thrift.TException
getClusterInfo
in interface Nimbus.Iface
org.apache.thrift.TException
public void send_getClusterInfo() throws org.apache.thrift.TException
org.apache.thrift.TException
public ClusterSummary recv_getClusterInfo() throws org.apache.thrift.TException
org.apache.thrift.TException
public TopologyInfo getTopologyInfo(String id) throws NotAliveException, org.apache.thrift.TException
getTopologyInfo
in interface Nimbus.Iface
NotAliveException
org.apache.thrift.TException
public void send_getTopologyInfo(String id) throws org.apache.thrift.TException
org.apache.thrift.TException
public TopologyInfo recv_getTopologyInfo() throws NotAliveException, org.apache.thrift.TException
NotAliveException
org.apache.thrift.TException
public String getTopologyConf(String id) throws NotAliveException, org.apache.thrift.TException
getTopologyConf
in interface Nimbus.Iface
NotAliveException
org.apache.thrift.TException
public void send_getTopologyConf(String id) throws org.apache.thrift.TException
org.apache.thrift.TException
public String recv_getTopologyConf() throws NotAliveException, org.apache.thrift.TException
NotAliveException
org.apache.thrift.TException
public StormTopology getTopology(String id) throws NotAliveException, org.apache.thrift.TException
getTopology
in interface Nimbus.Iface
NotAliveException
org.apache.thrift.TException
public void send_getTopology(String id) throws org.apache.thrift.TException
org.apache.thrift.TException
public StormTopology recv_getTopology() throws NotAliveException, org.apache.thrift.TException
NotAliveException
org.apache.thrift.TException
public StormTopology getUserTopology(String id) throws NotAliveException, org.apache.thrift.TException
getUserTopology
in interface Nimbus.Iface
NotAliveException
org.apache.thrift.TException
public void send_getUserTopology(String id) throws org.apache.thrift.TException
org.apache.thrift.TException
public StormTopology recv_getUserTopology() throws NotAliveException, org.apache.thrift.TException
NotAliveException
org.apache.thrift.TException
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.