public static class Nimbus.AsyncClient extends org.apache.storm.thrift.async.TAsyncClient implements Nimbus.AsyncIface
| Constructor and Description |
|---|
AsyncClient(org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.storm.thrift.async.TAsyncClientManager clientManager,
org.apache.storm.thrift.transport.TNonblockingTransport transport) |
| Modifier and Type | Method and Description |
|---|---|
void |
activate(String name,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
beginBlobDownload(String key,
org.apache.storm.thrift.async.AsyncMethodCallback<BeginDownloadResult> resultHandler) |
void |
beginCreateBlob(String key,
SettableBlobMeta meta,
org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) |
void |
beginFileUpload(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) |
void |
beginUpdateBlob(String key,
org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) |
void |
cancelBlobUpload(String session,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
createStateInZookeeper(String key,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
deactivate(String name,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
debug(String name,
String component,
boolean enable,
double samplingPercentage,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
deleteBlob(String key,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
downloadBlobChunk(String session,
org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler) |
void |
downloadChunk(String id,
org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler) |
void |
finishBlobUpload(String session,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
finishFileUpload(String location,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
getBlobMeta(String key,
org.apache.storm.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler) |
void |
getBlobReplication(String key,
org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler) |
void |
getClusterInfo(org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler) |
void |
getComponentPageInfo(String topology_id,
String component_id,
String window,
boolean is_include_sys,
org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> resultHandler) |
void |
getComponentPendingProfileActions(String id,
String component_id,
ProfileAction action,
org.apache.storm.thrift.async.AsyncMethodCallback<List<ProfileRequest>> resultHandler) |
void |
getLeader(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) |
void |
getLogConfig(String name,
org.apache.storm.thrift.async.AsyncMethodCallback<LogConfig> resultHandler) |
void |
getNimbusConf(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) |
void |
getOwnerResourceSummaries(String owner,
org.apache.storm.thrift.async.AsyncMethodCallback<List<OwnerResourceSummary>> resultHandler) |
void |
getSupervisorAssignments(String node,
org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) |
void |
getSupervisorPageInfo(String id,
String host,
boolean is_include_sys,
org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> resultHandler) |
void |
getTopology(String id,
org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) |
void |
getTopologyConf(String id,
org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) |
void |
getTopologyHistory(String user,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler) |
void |
getTopologyInfo(String id,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) |
void |
getTopologyInfoByName(String name,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) |
void |
getTopologyInfoByNameWithOpts(String name,
GetInfoOptions options,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) |
void |
getTopologyInfoWithOpts(String id,
GetInfoOptions options,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) |
void |
getTopologyPageInfo(String id,
String window,
boolean is_include_sys,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler) |
void |
getTopologySummaries(org.apache.storm.thrift.async.AsyncMethodCallback<List<TopologySummary>> resultHandler) |
void |
getTopologySummary(String id,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) |
void |
getTopologySummaryByName(String name,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) |
void |
getUserTopology(String id,
org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) |
void |
isRemoteBlobExists(String blobKey,
org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler) |
void |
isTopologyNameAllowed(String name,
org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler) |
void |
killTopology(String name,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
killTopologyWithOpts(String name,
KillOptions options,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
listBlobs(String session,
org.apache.storm.thrift.async.AsyncMethodCallback<ListBlobsResult> resultHandler) |
void |
processWorkerMetrics(WorkerMetrics metrics,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
rebalance(String name,
RebalanceOptions options,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
setBlobMeta(String key,
SettableBlobMeta meta,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
setLogConfig(String name,
LogConfig config,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
setWorkerProfiler(String id,
ProfileRequest profileRequest,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
submitTopology(String name,
String uploadedJarLocation,
String jsonConf,
StormTopology topology,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
submitTopologyWithOpts(String name,
String uploadedJarLocation,
String jsonConf,
StormTopology topology,
SubmitOptions options,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
updateBlobReplication(String key,
int replication,
org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler) |
void |
uploadBlobChunk(String session,
ByteBuffer chunk,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
uploadChunk(String location,
ByteBuffer chunk,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
uploadNewCredentials(String name,
Credentials creds,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
public AsyncClient(org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.storm.thrift.async.TAsyncClientManager clientManager,
org.apache.storm.thrift.transport.TNonblockingTransport transport)
public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
submitTopology in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
submitTopologyWithOpts in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void killTopology(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
killTopology in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void killTopologyWithOpts(String name, KillOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
killTopologyWithOpts in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void activate(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
activate in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void deactivate(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
deactivate in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void rebalance(String name, RebalanceOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
rebalance in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void setLogConfig(String name, LogConfig config, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
setLogConfig in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getLogConfig(String name, org.apache.storm.thrift.async.AsyncMethodCallback<LogConfig> resultHandler) throws org.apache.storm.thrift.TException
getLogConfig in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void debug(String name, String component, boolean enable, double samplingPercentage, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
debug in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void setWorkerProfiler(String id, ProfileRequest profileRequest, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
setWorkerProfiler in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getComponentPendingProfileActions(String id, String component_id, ProfileAction action, org.apache.storm.thrift.async.AsyncMethodCallback<List<ProfileRequest>> resultHandler) throws org.apache.storm.thrift.TException
getComponentPendingProfileActions in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void uploadNewCredentials(String name, Credentials creds, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
uploadNewCredentials in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void beginCreateBlob(String key, SettableBlobMeta meta, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException
beginCreateBlob in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void beginUpdateBlob(String key, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException
beginUpdateBlob in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void uploadBlobChunk(String session, ByteBuffer chunk, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
uploadBlobChunk in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void finishBlobUpload(String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
finishBlobUpload in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void cancelBlobUpload(String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
cancelBlobUpload in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getBlobMeta(String key, org.apache.storm.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler) throws org.apache.storm.thrift.TException
getBlobMeta in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void setBlobMeta(String key, SettableBlobMeta meta, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
setBlobMeta in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void beginBlobDownload(String key, org.apache.storm.thrift.async.AsyncMethodCallback<BeginDownloadResult> resultHandler) throws org.apache.storm.thrift.TException
beginBlobDownload in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void downloadBlobChunk(String session, org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException
downloadBlobChunk in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void deleteBlob(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
deleteBlob in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void listBlobs(String session, org.apache.storm.thrift.async.AsyncMethodCallback<ListBlobsResult> resultHandler) throws org.apache.storm.thrift.TException
listBlobs in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getBlobReplication(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler) throws org.apache.storm.thrift.TException
getBlobReplication in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void updateBlobReplication(String key, int replication, org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler) throws org.apache.storm.thrift.TException
updateBlobReplication in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void createStateInZookeeper(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
createStateInZookeeper in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void beginFileUpload(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException
beginFileUpload in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void uploadChunk(String location, ByteBuffer chunk, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
uploadChunk in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void finishFileUpload(String location, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
finishFileUpload in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void downloadChunk(String id, org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException
downloadChunk in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getNimbusConf(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException
getNimbusConf in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getClusterInfo(org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler) throws org.apache.storm.thrift.TException
getClusterInfo in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getTopologySummaries(org.apache.storm.thrift.async.AsyncMethodCallback<List<TopologySummary>> resultHandler) throws org.apache.storm.thrift.TException
getTopologySummaries in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getTopologySummaryByName(String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) throws org.apache.storm.thrift.TException
getTopologySummaryByName in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getTopologySummary(String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) throws org.apache.storm.thrift.TException
getTopologySummary in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getLeader(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) throws org.apache.storm.thrift.TException
getLeader in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void isTopologyNameAllowed(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws org.apache.storm.thrift.TException
isTopologyNameAllowed in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getTopologyInfoByName(String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException
getTopologyInfoByName in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getTopologyInfo(String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException
getTopologyInfo in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getTopologyInfoByNameWithOpts(String name, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException
getTopologyInfoByNameWithOpts in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getTopologyInfoWithOpts(String id, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException
getTopologyInfoWithOpts in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getTopologyPageInfo(String id, String window, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler) throws org.apache.storm.thrift.TException
getTopologyPageInfo in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getSupervisorPageInfo(String id, String host, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> resultHandler) throws org.apache.storm.thrift.TException
getSupervisorPageInfo in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> resultHandler) throws org.apache.storm.thrift.TException
getComponentPageInfo in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getTopologyConf(String id, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException
getTopologyConf in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getTopology(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException
getTopology in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getUserTopology(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException
getUserTopology in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getTopologyHistory(String user, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler) throws org.apache.storm.thrift.TException
getTopologyHistory in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getOwnerResourceSummaries(String owner, org.apache.storm.thrift.async.AsyncMethodCallback<List<OwnerResourceSummary>> resultHandler) throws org.apache.storm.thrift.TException
getOwnerResourceSummaries in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void getSupervisorAssignments(String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) throws org.apache.storm.thrift.TException
getSupervisorAssignments in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
sendSupervisorWorkerHeartbeats in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
sendSupervisorWorkerHeartbeat in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void processWorkerMetrics(WorkerMetrics metrics, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
processWorkerMetrics in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionpublic void isRemoteBlobExists(String blobKey, org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws org.apache.storm.thrift.TException
isRemoteBlobExists in interface Nimbus.AsyncIfaceorg.apache.storm.thrift.TExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.