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
-
Constructor Summary
Constructors Constructor Description AsyncClient(org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.async.TAsyncClientManager clientManager, org.apache.storm.thrift.transport.TNonblockingTransport transport)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidactivate(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)voidbeginBlobDownload(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)
-
-
-
Method Detail
-
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
-
-