public static class Nimbus.AsyncClient extends org.apache.thrift.async.TAsyncClient implements Nimbus.AsyncIface
| Constructor and Description |
|---|
Nimbus.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 resultHandler) |
void |
beginFileDownload(String file,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
beginFileUpload(org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
deactivate(String name,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
downloadChunk(String id,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
finishFileUpload(String location,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
getClusterInfo(org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
getNimbusConf(org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
getTopology(String id,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
getTopologyConf(String id,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
getTopologyInfo(String id,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
getTopologyInfoWithOpts(String id,
GetInfoOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
getUserTopology(String id,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
killTopology(String name,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
killTopologyWithOpts(String name,
KillOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
rebalance(String name,
RebalanceOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
submitTopology(String name,
String uploadedJarLocation,
String jsonConf,
StormTopology topology,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
submitTopologyWithOpts(String name,
String uploadedJarLocation,
String jsonConf,
StormTopology topology,
SubmitOptions options,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
uploadChunk(String location,
ByteBuffer chunk,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
uploadNewCredentials(String name,
Credentials creds,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
public Nimbus.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 resultHandler) throws org.apache.thrift.TException
submitTopology in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
submitTopologyWithOpts in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void killTopology(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
killTopology in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void killTopologyWithOpts(String name, KillOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
killTopologyWithOpts in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void activate(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
activate in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void deactivate(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
deactivate in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void rebalance(String name, RebalanceOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
rebalance in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void uploadNewCredentials(String name, Credentials creds, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
uploadNewCredentials in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void beginFileUpload(org.apache.thrift.async.AsyncMethodCallback resultHandler)
throws org.apache.thrift.TException
beginFileUpload in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void uploadChunk(String location, ByteBuffer chunk, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
uploadChunk in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void finishFileUpload(String location, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
finishFileUpload in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void beginFileDownload(String file, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
beginFileDownload in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void downloadChunk(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
downloadChunk in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void getNimbusConf(org.apache.thrift.async.AsyncMethodCallback resultHandler)
throws org.apache.thrift.TException
getNimbusConf in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void getClusterInfo(org.apache.thrift.async.AsyncMethodCallback resultHandler)
throws org.apache.thrift.TException
getClusterInfo in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void getTopologyInfo(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
getTopologyInfo in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void getTopologyInfoWithOpts(String id, GetInfoOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
getTopologyInfoWithOpts in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void getTopologyConf(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
getTopologyConf in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void getTopology(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
getTopology in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionpublic void getUserTopology(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
getUserTopology in interface Nimbus.AsyncIfaceorg.apache.thrift.TExceptionCopyright © 2015. All rights reserved.