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 Summary
Nested 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 Summary
Fields inherited from class org.apache.storm.thrift.async.TAsyncClient
___currentMethod, ___manager, ___protocolFactory, ___transport -
Constructor Summary
ConstructorsConstructorDescriptionAsyncClient(org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.async.TAsyncClientManager clientManager, org.apache.storm.thrift.transport.TNonblockingTransport transport) -
Method Summary
Modifier 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.TAsyncClient
checkReady, getError, getProtocolFactory, getTimeout, hasError, hasTimeout, onComplete, onError, setTimeout
-
Constructor Details
-
AsyncClient
public AsyncClient(org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.async.TAsyncClientManager clientManager, org.apache.storm.thrift.transport.TNonblockingTransport transport)
-
-
Method Details
-
submitTopology
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 - Specified by:
submitTopologyin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
submitTopologyWithOpts
public 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 interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
killTopology
public void killTopology(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
killTopologyin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
killTopologyWithOpts
public void killTopologyWithOpts(String name, KillOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
killTopologyWithOptsin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
activate
public void activate(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
activatein interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
deactivate
public void deactivate(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
deactivatein interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
rebalance
public void rebalance(String name, RebalanceOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
rebalancein interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
setLogConfig
public void setLogConfig(String name, LogConfig config, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
setLogConfigin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getLogConfig
public void getLogConfig(String name, org.apache.storm.thrift.async.AsyncMethodCallback<LogConfig> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getLogConfigin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
debug
public 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 interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
setWorkerProfiler
public void setWorkerProfiler(String id, ProfileRequest profileRequest, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
setWorkerProfilerin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getComponentPendingProfileActions
public 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 interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
uploadNewCredentials
public void uploadNewCredentials(String name, Credentials creds, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
uploadNewCredentialsin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
beginCreateBlob
public void beginCreateBlob(String key, SettableBlobMeta meta, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
beginCreateBlobin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
beginUpdateBlob
public void beginUpdateBlob(String key, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
beginUpdateBlobin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
uploadBlobChunk
public void uploadBlobChunk(String session, ByteBuffer chunk, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
uploadBlobChunkin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
finishBlobUpload
public void finishBlobUpload(String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
finishBlobUploadin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
cancelBlobUpload
public void cancelBlobUpload(String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
cancelBlobUploadin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getBlobMeta
public void getBlobMeta(String key, org.apache.storm.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getBlobMetain interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
setBlobMeta
public void setBlobMeta(String key, SettableBlobMeta meta, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
setBlobMetain interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
beginBlobDownload
public void beginBlobDownload(String key, org.apache.storm.thrift.async.AsyncMethodCallback<BeginDownloadResult> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
beginBlobDownloadin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
downloadBlobChunk
public void downloadBlobChunk(String session, org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
downloadBlobChunkin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
deleteBlob
public void deleteBlob(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
deleteBlobin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
listBlobs
public void listBlobs(String session, org.apache.storm.thrift.async.AsyncMethodCallback<ListBlobsResult> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
listBlobsin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getBlobReplication
public void getBlobReplication(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getBlobReplicationin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
updateBlobReplication
public void updateBlobReplication(String key, int replication, org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
updateBlobReplicationin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
createStateInZookeeper
public void createStateInZookeeper(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
createStateInZookeeperin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
beginFileUpload
public void beginFileUpload(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
beginFileUploadin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
uploadChunk
public void uploadChunk(String location, ByteBuffer chunk, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
uploadChunkin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
finishFileUpload
public void finishFileUpload(String location, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
finishFileUploadin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
downloadChunk
public void downloadChunk(String id, org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
downloadChunkin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getNimbusConf
public void getNimbusConf(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getNimbusConfin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getClusterInfo
public void getClusterInfo(org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getClusterInfoin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getTopologySummaries
public void getTopologySummaries(org.apache.storm.thrift.async.AsyncMethodCallback<List<TopologySummary>> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getTopologySummariesin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getTopologySummaryByName
public void getTopologySummaryByName(String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getTopologySummaryByNamein interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getTopologySummary
public void getTopologySummary(String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getTopologySummaryin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getLeader
public void getLeader(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getLeaderin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
isTopologyNameAllowed
public void isTopologyNameAllowed(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
isTopologyNameAllowedin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getTopologyInfoByName
public void getTopologyInfoByName(String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getTopologyInfoByNamein interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getTopologyInfo
public void getTopologyInfo(String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getTopologyInfoin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getTopologyInfoByNameWithOpts
public void getTopologyInfoByNameWithOpts(String name, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getTopologyInfoByNameWithOptsin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getTopologyInfoWithOpts
public void getTopologyInfoWithOpts(String id, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getTopologyInfoWithOptsin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getTopologyPageInfo
public 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 interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getSupervisorPageInfo
public 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 interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getComponentPageInfo
public 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 interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getTopologyConf
public void getTopologyConf(String id, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getTopologyConfin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getTopology
public void getTopology(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getTopologyin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getUserTopology
public void getUserTopology(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getUserTopologyin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getTopologyHistory
public void getTopologyHistory(String user, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getTopologyHistoryin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getOwnerResourceSummaries
public void getOwnerResourceSummaries(String owner, org.apache.storm.thrift.async.AsyncMethodCallback<List<OwnerResourceSummary>> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getOwnerResourceSummariesin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
getSupervisorAssignments
public void getSupervisorAssignments(String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
getSupervisorAssignmentsin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
sendSupervisorWorkerHeartbeats
public void sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
sendSupervisorWorkerHeartbeatsin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
sendSupervisorWorkerHeartbeat
public void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
sendSupervisorWorkerHeartbeatin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
processWorkerMetrics
public void processWorkerMetrics(WorkerMetrics metrics, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
processWorkerMetricsin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-
isRemoteBlobExists
public void isRemoteBlobExists(String blobKey, org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws org.apache.storm.thrift.TException - Specified by:
isRemoteBlobExistsin interfaceNimbus.AsyncIface- Throws:
org.apache.storm.thrift.TException
-