public static class Nimbus.AsyncClient extends org.apache.thrift.async.TAsyncClient implements Nimbus.AsyncIface
Constructor and Description |
---|
AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.async.TAsyncClientManager clientManager,
org.apache.thrift.transport.TNonblockingTransport transport) |
Modifier and Type | Method and Description |
---|---|
void |
activate(String name,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.activate_call> resultHandler) |
void |
beginFileDownload(String file,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.beginFileDownload_call> resultHandler) |
void |
beginFileUpload(org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.beginFileUpload_call> resultHandler) |
void |
deactivate(String name,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.deactivate_call> resultHandler) |
void |
downloadChunk(String id,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.downloadChunk_call> resultHandler) |
void |
finishFileUpload(String location,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.finishFileUpload_call> resultHandler) |
void |
getClusterInfo(org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.getClusterInfo_call> resultHandler) |
void |
getNimbusConf(org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.getNimbusConf_call> resultHandler) |
void |
getTopology(String id,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.getTopology_call> resultHandler) |
void |
getTopologyConf(String id,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.getTopologyConf_call> resultHandler) |
void |
getTopologyInfo(String id,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.getTopologyInfo_call> resultHandler) |
void |
getUserTopology(String id,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.getUserTopology_call> resultHandler) |
void |
killTopology(String name,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.killTopology_call> resultHandler) |
void |
killTopologyWithOpts(String name,
KillOptions options,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.killTopologyWithOpts_call> resultHandler) |
void |
rebalance(String name,
RebalanceOptions options,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.rebalance_call> resultHandler) |
void |
submitTopology(String name,
String uploadedJarLocation,
String jsonConf,
StormTopology topology,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.submitTopology_call> resultHandler) |
void |
submitTopologyWithOpts(String name,
String uploadedJarLocation,
String jsonConf,
StormTopology topology,
SubmitOptions options,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.submitTopologyWithOpts_call> resultHandler) |
void |
uploadChunk(String location,
ByteBuffer chunk,
org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.uploadChunk_call> resultHandler) |
public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport)
public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.submitTopology_call> resultHandler) throws org.apache.thrift.TException
submitTopology
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.submitTopologyWithOpts_call> resultHandler) throws org.apache.thrift.TException
submitTopologyWithOpts
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void killTopology(String name, org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.killTopology_call> resultHandler) throws org.apache.thrift.TException
killTopology
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void killTopologyWithOpts(String name, KillOptions options, org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.killTopologyWithOpts_call> resultHandler) throws org.apache.thrift.TException
killTopologyWithOpts
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void activate(String name, org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.activate_call> resultHandler) throws org.apache.thrift.TException
activate
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void deactivate(String name, org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.deactivate_call> resultHandler) throws org.apache.thrift.TException
deactivate
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void rebalance(String name, RebalanceOptions options, org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.rebalance_call> resultHandler) throws org.apache.thrift.TException
rebalance
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void beginFileUpload(org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.beginFileUpload_call> resultHandler) throws org.apache.thrift.TException
beginFileUpload
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void uploadChunk(String location, ByteBuffer chunk, org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.uploadChunk_call> resultHandler) throws org.apache.thrift.TException
uploadChunk
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void finishFileUpload(String location, org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.finishFileUpload_call> resultHandler) throws org.apache.thrift.TException
finishFileUpload
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void beginFileDownload(String file, org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.beginFileDownload_call> resultHandler) throws org.apache.thrift.TException
beginFileDownload
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void downloadChunk(String id, org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.downloadChunk_call> resultHandler) throws org.apache.thrift.TException
downloadChunk
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void getNimbusConf(org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.getNimbusConf_call> resultHandler) throws org.apache.thrift.TException
getNimbusConf
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void getClusterInfo(org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.getClusterInfo_call> resultHandler) throws org.apache.thrift.TException
getClusterInfo
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void getTopologyInfo(String id, org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.getTopologyInfo_call> resultHandler) throws org.apache.thrift.TException
getTopologyInfo
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void getTopologyConf(String id, org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.getTopologyConf_call> resultHandler) throws org.apache.thrift.TException
getTopologyConf
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void getTopology(String id, org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.getTopology_call> resultHandler) throws org.apache.thrift.TException
getTopology
in interface Nimbus.AsyncIface
org.apache.thrift.TException
public void getUserTopology(String id, org.apache.thrift.async.AsyncMethodCallback<Nimbus.AsyncClient.getUserTopology_call> resultHandler) throws org.apache.thrift.TException
getUserTopology
in interface Nimbus.AsyncIface
org.apache.thrift.TException
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.