public static interface Nimbus.Iface
void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException
AlreadyAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionvoid submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException
AlreadyAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionvoid killTopology(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionvoid killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionvoid activate(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionvoid deactivate(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionvoid rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionvoid setLogConfig(String name, LogConfig config) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionLogConfig getLogConfig(String name) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionvoid debug(String name, String component, boolean enable, double samplingPercentage) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
Enable/disable logging the tuples generated in topology via an internal EventLogger bolt. The component name is optional and if null or empty, the debug flag will apply to the entire topology.
The ‘samplingPercentage’ will limit loggging to a percentage of generated tuples.
name - component - enable - samplingPercentage - NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionvoid setWorkerProfiler(String id, ProfileRequest profileRequest) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionList<ProfileRequest> getComponentPendingProfileActions(String id, String component_id, ProfileAction action) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionvoid uploadNewCredentials(String name, Credentials creds) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionString beginCreateBlob(String key, SettableBlobMeta meta) throws AuthorizationException, KeyAlreadyExistsException, org.apache.storm.thrift.TException
AuthorizationExceptionKeyAlreadyExistsExceptionorg.apache.storm.thrift.TExceptionString beginUpdateBlob(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionvoid uploadBlobChunk(String session, ByteBuffer chunk) throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionvoid finishBlobUpload(String session) throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionvoid cancelBlobUpload(String session) throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionReadableBlobMeta getBlobMeta(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionvoid setBlobMeta(String key, SettableBlobMeta meta) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionBeginDownloadResult beginBlobDownload(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionByteBuffer downloadBlobChunk(String session) throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionvoid deleteBlob(String key) throws AuthorizationException, KeyNotFoundException, IllegalStateException, org.apache.storm.thrift.TException
AuthorizationExceptionKeyNotFoundExceptionIllegalStateExceptionorg.apache.storm.thrift.TExceptionListBlobsResult listBlobs(String session) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionint getBlobReplication(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionint updateBlobReplication(String key, int replication) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionvoid createStateInZookeeper(String key) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionString beginFileUpload() throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionvoid uploadChunk(String location, ByteBuffer chunk) throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionvoid finishFileUpload(String location) throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionByteBuffer downloadChunk(String id) throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionString getNimbusConf() throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionClusterSummary getClusterInfo() throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionList<TopologySummary> getTopologySummaries() throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionTopologySummary getTopologySummaryByName(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionTopologySummary getTopologySummary(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionNimbusSummary getLeader() throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionboolean isTopologyNameAllowed(String name) throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionTopologyInfo getTopologyInfoByName(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionTopologyInfo getTopologyInfo(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionTopologyInfo getTopologyInfoByNameWithOpts(String name, GetInfoOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionTopologyInfo getTopologyInfoWithOpts(String id, GetInfoOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionTopologyPageInfo getTopologyPageInfo(String id, String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionSupervisorPageInfo getSupervisorPageInfo(String id, String host, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionComponentPageInfo getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionString getTopologyConf(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionStormTopology getTopology(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
Returns the compiled topology that contains ackers and metrics consumsers. Compare getUserTopology(String id).
id - NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionStormTopology getUserTopology(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
Returns the user specified topology as submitted originally. Compare getTopology(String id).
id - NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionTopologyHistoryInfo getTopologyHistory(String user) throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionList<OwnerResourceSummary> getOwnerResourceSummaries(String owner) throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionSupervisorAssignments getSupervisorAssignments(String node) throws AuthorizationException, org.apache.storm.thrift.TException
Get assigned assignments for a specific supervisor
node - AuthorizationExceptionorg.apache.storm.thrift.TExceptionvoid sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) throws AuthorizationException, org.apache.storm.thrift.TException
Send supervisor worker heartbeats for a specific supervisor
heartbeats - AuthorizationExceptionorg.apache.storm.thrift.TExceptionvoid sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) throws AuthorizationException, NotAliveException, org.apache.storm.thrift.TException
Send supervisor local worker heartbeat when a supervisor is unreachable
heatbeat - AuthorizationExceptionNotAliveExceptionorg.apache.storm.thrift.TExceptionvoid processWorkerMetrics(WorkerMetrics metrics) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionboolean isRemoteBlobExists(String blobKey) throws AuthorizationException, org.apache.storm.thrift.TException
Decide if the blob is removed from cluster.
blobKey - AuthorizationExceptionorg.apache.storm.thrift.TExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.