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
Modifier and TypeClassDescriptionstatic class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
-
Field Summary
Fields inherited from class org.apache.storm.thrift.async.TAsyncClient
___currentMethod, ___manager, ___protocolFactory, ___transport
-
Constructor Summary
ConstructorDescriptionAsyncClient
(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 TypeMethodDescriptionvoid
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) 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:
submitTopology
in 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:
submitTopologyWithOpts
in 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:
killTopology
in 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:
killTopologyWithOpts
in 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:
activate
in 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:
deactivate
in 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:
rebalance
in 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:
setLogConfig
in 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:
getLogConfig
in 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:
debug
in 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:
setWorkerProfiler
in 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:
getComponentPendingProfileActions
in 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:
uploadNewCredentials
in 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:
beginCreateBlob
in 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:
beginUpdateBlob
in 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:
uploadBlobChunk
in 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:
finishBlobUpload
in 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:
cancelBlobUpload
in 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:
getBlobMeta
in 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:
setBlobMeta
in 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:
beginBlobDownload
in 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:
downloadBlobChunk
in 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:
deleteBlob
in 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:
listBlobs
in 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:
getBlobReplication
in 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:
updateBlobReplication
in 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:
createStateInZookeeper
in 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:
beginFileUpload
in 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:
uploadChunk
in 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:
finishFileUpload
in 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:
downloadChunk
in 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:
getNimbusConf
in 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:
getClusterInfo
in 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:
getTopologySummaries
in 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:
getTopologySummaryByName
in 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:
getTopologySummary
in 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:
getLeader
in 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:
isTopologyNameAllowed
in 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:
getTopologyInfoByName
in 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:
getTopologyInfo
in 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:
getTopologyInfoByNameWithOpts
in 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:
getTopologyInfoWithOpts
in 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:
getTopologyPageInfo
in 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:
getSupervisorPageInfo
in 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:
getComponentPageInfo
in 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:
getTopologyConf
in 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:
getTopology
in 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:
getUserTopology
in 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:
getTopologyHistory
in 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:
getOwnerResourceSummaries
in 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:
getSupervisorAssignments
in 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:
sendSupervisorWorkerHeartbeats
in 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:
sendSupervisorWorkerHeartbeat
in 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:
processWorkerMetrics
in 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:
isRemoteBlobExists
in interfaceNimbus.AsyncIface
- Throws:
org.apache.storm.thrift.TException
-