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