Package org.apache.storm.generated
Class Nimbus.AsyncClient
java.lang.Object
org.apache.storm.thrift.async.TAsyncClient
org.apache.storm.generated.Nimbus.AsyncClient
- All Implemented Interfaces:
- Nimbus.AsyncIface
- Enclosing class:
- Nimbus
public static class Nimbus.AsyncClient
extends org.apache.storm.thrift.async.TAsyncClient
implements Nimbus.AsyncIface
- 
Nested Class SummaryNested ClassesModifier and TypeClassDescriptionstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic class
- 
Field SummaryFields inherited from class org.apache.storm.thrift.async.TAsyncClient___currentMethod, ___manager, ___protocolFactory, ___transport
- 
Constructor SummaryConstructorsConstructorDescriptionAsyncClient(org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.async.TAsyncClientManager clientManager, org.apache.storm.thrift.transport.TNonblockingTransport transport) 
- 
Method SummaryModifier and TypeMethodDescriptionvoidvoidbeginBlobDownload(String key, org.apache.storm.thrift.async.AsyncMethodCallback<BeginDownloadResult> resultHandler) voidbeginCreateBlob(String key, SettableBlobMeta meta, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) voidbeginFileUpload(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) voidbeginUpdateBlob(String key, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) voidcancelBlobUpload(String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidcreateStateInZookeeper(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voiddeactivate(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voiddebug(String name, String component, boolean enable, double samplingPercentage, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voiddeleteBlob(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voiddownloadBlobChunk(String session, org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler) voiddownloadChunk(String id, org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler) voidfinishBlobUpload(String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidfinishFileUpload(String location, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidgetBlobMeta(String key, org.apache.storm.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler) voidgetBlobReplication(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler) voidgetClusterInfo(org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler) voidgetComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> resultHandler) voidgetComponentPendingProfileActions(String id, String component_id, ProfileAction action, org.apache.storm.thrift.async.AsyncMethodCallback<List<ProfileRequest>> resultHandler) voidgetLeader(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) voidgetLogConfig(String name, org.apache.storm.thrift.async.AsyncMethodCallback<LogConfig> resultHandler) voidgetNimbusConf(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) voidgetOwnerResourceSummaries(String owner, org.apache.storm.thrift.async.AsyncMethodCallback<List<OwnerResourceSummary>> resultHandler) voidgetSupervisorAssignments(String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) voidgetSupervisorPageInfo(String id, String host, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> resultHandler) voidgetTopology(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) voidgetTopologyConf(String id, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) voidgetTopologyHistory(String user, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler) voidgetTopologyInfo(String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) voidgetTopologyInfoByName(String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) voidgetTopologyInfoByNameWithOpts(String name, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) voidgetTopologyInfoWithOpts(String id, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) voidgetTopologyPageInfo(String id, String window, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler) voidgetTopologySummaries(org.apache.storm.thrift.async.AsyncMethodCallback<List<TopologySummary>> resultHandler) voidgetTopologySummary(String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) voidgetTopologySummaryByName(String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) voidgetUserTopology(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) voidisRemoteBlobExists(String blobKey, org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler) voidisTopologyNameAllowed(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler) voidkillTopology(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidkillTopologyWithOpts(String name, KillOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidlistBlobs(String session, org.apache.storm.thrift.async.AsyncMethodCallback<ListBlobsResult> resultHandler) voidprocessWorkerMetrics(WorkerMetrics metrics, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidrebalance(String name, RebalanceOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidsendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidsendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidsetBlobMeta(String key, SettableBlobMeta meta, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidsetLogConfig(String name, LogConfig config, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidsetWorkerProfiler(String id, ProfileRequest profileRequest, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidsubmitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidsubmitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidupdateBlobReplication(String key, int replication, org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler) voiduploadBlobChunk(String session, ByteBuffer chunk, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voiduploadChunk(String location, ByteBuffer chunk, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voiduploadNewCredentials(String name, Credentials creds, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) Methods inherited from class org.apache.storm.thrift.async.TAsyncClientcheckReady, getError, getProtocolFactory, getTimeout, hasError, hasTimeout, onComplete, onError, setTimeout
- 
Constructor Details- 
AsyncClientpublic AsyncClient(org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.async.TAsyncClientManager clientManager, org.apache.storm.thrift.transport.TNonblockingTransport transport) 
 
- 
- 
Method Details- 
submitTopologypublic void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- submitTopologyin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
submitTopologyWithOptspublic 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 - Specified by:
- submitTopologyWithOptsin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
killTopologypublic void killTopology(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- killTopologyin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
killTopologyWithOptspublic void killTopologyWithOpts(String name, KillOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- killTopologyWithOptsin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
activatepublic void activate(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- activatein interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
deactivatepublic void deactivate(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- deactivatein interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
rebalancepublic void rebalance(String name, RebalanceOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- rebalancein interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
setLogConfigpublic void setLogConfig(String name, LogConfig config, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- setLogConfigin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getLogConfigpublic void getLogConfig(String name, org.apache.storm.thrift.async.AsyncMethodCallback<LogConfig> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getLogConfigin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
debugpublic void debug(String name, String component, boolean enable, double samplingPercentage, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- debugin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
setWorkerProfilerpublic void setWorkerProfiler(String id, ProfileRequest profileRequest, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- setWorkerProfilerin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getComponentPendingProfileActionspublic void getComponentPendingProfileActions(String id, String component_id, ProfileAction action, org.apache.storm.thrift.async.AsyncMethodCallback<List<ProfileRequest>> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getComponentPendingProfileActionsin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
uploadNewCredentialspublic void uploadNewCredentials(String name, Credentials creds, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- uploadNewCredentialsin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
beginCreateBlobpublic void beginCreateBlob(String key, SettableBlobMeta meta, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- beginCreateBlobin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
beginUpdateBlobpublic void beginUpdateBlob(String key, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- beginUpdateBlobin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
uploadBlobChunkpublic void uploadBlobChunk(String session, ByteBuffer chunk, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- uploadBlobChunkin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
finishBlobUploadpublic void finishBlobUpload(String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- finishBlobUploadin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
cancelBlobUploadpublic void cancelBlobUpload(String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- cancelBlobUploadin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getBlobMetapublic void getBlobMeta(String key, org.apache.storm.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getBlobMetain interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
setBlobMetapublic void setBlobMeta(String key, SettableBlobMeta meta, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- setBlobMetain interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
beginBlobDownloadpublic void beginBlobDownload(String key, org.apache.storm.thrift.async.AsyncMethodCallback<BeginDownloadResult> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- beginBlobDownloadin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
downloadBlobChunkpublic void downloadBlobChunk(String session, org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- downloadBlobChunkin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
deleteBlobpublic void deleteBlob(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- deleteBlobin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
listBlobspublic void listBlobs(String session, org.apache.storm.thrift.async.AsyncMethodCallback<ListBlobsResult> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- listBlobsin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getBlobReplicationpublic void getBlobReplication(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getBlobReplicationin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
updateBlobReplicationpublic void updateBlobReplication(String key, int replication, org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- updateBlobReplicationin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
createStateInZookeeperpublic void createStateInZookeeper(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- createStateInZookeeperin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
beginFileUploadpublic void beginFileUpload(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- beginFileUploadin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
uploadChunkpublic void uploadChunk(String location, ByteBuffer chunk, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- uploadChunkin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
finishFileUploadpublic void finishFileUpload(String location, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- finishFileUploadin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
downloadChunkpublic void downloadChunk(String id, org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- downloadChunkin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getNimbusConfpublic void getNimbusConf(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getNimbusConfin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getClusterInfopublic void getClusterInfo(org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getClusterInfoin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologySummariespublic void getTopologySummaries(org.apache.storm.thrift.async.AsyncMethodCallback<List<TopologySummary>> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getTopologySummariesin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologySummaryByNamepublic void getTopologySummaryByName(String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getTopologySummaryByNamein interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologySummarypublic void getTopologySummary(String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getTopologySummaryin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getLeaderpublic void getLeader(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getLeaderin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
isTopologyNameAllowedpublic void isTopologyNameAllowed(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- isTopologyNameAllowedin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologyInfoByNamepublic void getTopologyInfoByName(String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getTopologyInfoByNamein interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologyInfopublic void getTopologyInfo(String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getTopologyInfoin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologyInfoByNameWithOptspublic void getTopologyInfoByNameWithOpts(String name, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getTopologyInfoByNameWithOptsin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologyInfoWithOptspublic void getTopologyInfoWithOpts(String id, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getTopologyInfoWithOptsin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologyPageInfopublic void getTopologyPageInfo(String id, String window, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getTopologyPageInfoin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getSupervisorPageInfopublic void getSupervisorPageInfo(String id, String host, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getSupervisorPageInfoin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getComponentPageInfopublic 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 - Specified by:
- getComponentPageInfoin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologyConfpublic void getTopologyConf(String id, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getTopologyConfin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologypublic void getTopology(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getTopologyin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getUserTopologypublic void getUserTopology(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getUserTopologyin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologyHistorypublic void getTopologyHistory(String user, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getTopologyHistoryin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getOwnerResourceSummariespublic void getOwnerResourceSummaries(String owner, org.apache.storm.thrift.async.AsyncMethodCallback<List<OwnerResourceSummary>> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getOwnerResourceSummariesin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
getSupervisorAssignmentspublic void getSupervisorAssignments(String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- getSupervisorAssignmentsin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
sendSupervisorWorkerHeartbeatspublic void sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- sendSupervisorWorkerHeartbeatsin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
sendSupervisorWorkerHeartbeatpublic void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- sendSupervisorWorkerHeartbeatin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
processWorkerMetricspublic void processWorkerMetrics(WorkerMetrics metrics, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- processWorkerMetricsin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
- 
isRemoteBlobExistspublic void isRemoteBlobExists(String blobKey, org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
- isRemoteBlobExistsin interface- Nimbus.AsyncIface
- Throws:
- org.apache.storm.thrift.TException
 
 
-