Package org.apache.storm.generated
Interface Nimbus.Iface
- All Known Implementing Classes:
LocalCluster
,Nimbus
,Nimbus.Client
- Enclosing class:
- Nimbus
public static interface Nimbus.Iface
-
Method Summary
Modifier and TypeMethodDescriptionvoid
beginBlobDownload
(String key) beginCreateBlob
(String key, SettableBlobMeta meta) beginUpdateBlob
(String key) void
cancelBlobUpload
(String session) void
void
deactivate
(String name) void
Enable/disable logging the tuples generated in topology via an internal EventLogger bolt.void
deleteBlob
(String key) downloadBlobChunk
(String session) downloadChunk
(String id) void
finishBlobUpload
(String session) void
finishFileUpload
(String location) getBlobMeta
(String key) int
getBlobReplication
(String key) getComponentPageInfo
(String topology_id, String component_id, String window, boolean is_include_sys) getComponentPendingProfileActions
(String id, String component_id, ProfileAction action) getLogConfig
(String name) getOwnerResourceSummaries
(String owner) Get assigned assignments for a specific supervisorgetSupervisorPageInfo
(String id, String host, boolean is_include_sys) getTopology
(String id) Returns the compiled topology that contains ackers and metrics consumsers.getTopologyHistory
(String user) getTopologyInfoByName
(String name) getTopologyInfoByNameWithOpts
(String name, GetInfoOptions options) getTopologyInfoWithOpts
(String id, GetInfoOptions options) getTopologyPageInfo
(String id, String window, boolean is_include_sys) Returns the user specified topology as submitted originally.boolean
isRemoteBlobExists
(String blobKey) Decide if the blob is removed from cluster.boolean
isTopologyNameAllowed
(String name) void
killTopology
(String name) void
killTopologyWithOpts
(String name, KillOptions options) void
processWorkerMetrics
(WorkerMetrics metrics) void
rebalance
(String name, RebalanceOptions options) void
Send supervisor local worker heartbeat when a supervisor is unreachablevoid
Send supervisor worker heartbeats for a specific supervisorvoid
setBlobMeta
(String key, SettableBlobMeta meta) void
setLogConfig
(String name, LogConfig config) void
setWorkerProfiler
(String id, ProfileRequest profileRequest) void
submitTopology
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) void
submitTopologyWithOpts
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) int
updateBlobReplication
(String key, int replication) void
uploadBlobChunk
(String session, ByteBuffer chunk) void
uploadChunk
(String location, ByteBuffer chunk) void
uploadNewCredentials
(String name, Credentials creds)
-
Method Details
-
submitTopology
void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
AlreadyAliveException
InvalidTopologyException
AuthorizationException
org.apache.storm.thrift.TException
-
submitTopologyWithOpts
void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
AlreadyAliveException
InvalidTopologyException
AuthorizationException
org.apache.storm.thrift.TException
-
killTopology
void killTopology(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
killTopologyWithOpts
void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
activate
void activate(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
deactivate
void deactivate(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
rebalance
void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveException
InvalidTopologyException
AuthorizationException
org.apache.storm.thrift.TException
-
setLogConfig
- Throws:
org.apache.storm.thrift.TException
-
getLogConfig
- Throws:
org.apache.storm.thrift.TException
-
debug
void 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.- Parameters:
name
-component
-enable
-samplingPercentage
-- Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
setWorkerProfiler
void setWorkerProfiler(String id, ProfileRequest profileRequest) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
getComponentPendingProfileActions
List<ProfileRequest> getComponentPendingProfileActions(String id, String component_id, ProfileAction action) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
uploadNewCredentials
void uploadNewCredentials(String name, Credentials creds) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveException
InvalidTopologyException
AuthorizationException
org.apache.storm.thrift.TException
-
beginCreateBlob
String beginCreateBlob(String key, SettableBlobMeta meta) throws AuthorizationException, KeyAlreadyExistsException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
KeyAlreadyExistsException
org.apache.storm.thrift.TException
-
beginUpdateBlob
String beginUpdateBlob(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
KeyNotFoundException
org.apache.storm.thrift.TException
-
uploadBlobChunk
void uploadBlobChunk(String session, ByteBuffer chunk) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
finishBlobUpload
void finishBlobUpload(String session) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
cancelBlobUpload
void cancelBlobUpload(String session) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
getBlobMeta
ReadableBlobMeta getBlobMeta(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
KeyNotFoundException
org.apache.storm.thrift.TException
-
setBlobMeta
void setBlobMeta(String key, SettableBlobMeta meta) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
KeyNotFoundException
org.apache.storm.thrift.TException
-
beginBlobDownload
BeginDownloadResult beginBlobDownload(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
KeyNotFoundException
org.apache.storm.thrift.TException
-
downloadBlobChunk
ByteBuffer downloadBlobChunk(String session) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
deleteBlob
void deleteBlob(String key) throws AuthorizationException, KeyNotFoundException, IllegalStateException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
KeyNotFoundException
IllegalStateException
org.apache.storm.thrift.TException
-
listBlobs
- Throws:
org.apache.storm.thrift.TException
-
getBlobReplication
int getBlobReplication(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
KeyNotFoundException
org.apache.storm.thrift.TException
-
updateBlobReplication
int updateBlobReplication(String key, int replication) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
KeyNotFoundException
org.apache.storm.thrift.TException
-
createStateInZookeeper
- Throws:
org.apache.storm.thrift.TException
-
beginFileUpload
- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
uploadChunk
void uploadChunk(String location, ByteBuffer chunk) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
finishFileUpload
void finishFileUpload(String location) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
downloadChunk
ByteBuffer downloadChunk(String id) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
getNimbusConf
- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
getClusterInfo
- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
getTopologySummaries
List<TopologySummary> getTopologySummaries() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
getTopologySummaryByName
TopologySummary getTopologySummaryByName(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
getTopologySummary
TopologySummary getTopologySummary(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
getLeader
- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
isTopologyNameAllowed
boolean isTopologyNameAllowed(String name) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
getTopologyInfoByName
TopologyInfo getTopologyInfoByName(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
getTopologyInfo
TopologyInfo getTopologyInfo(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
getTopologyInfoByNameWithOpts
TopologyInfo getTopologyInfoByNameWithOpts(String name, GetInfoOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
getTopologyInfoWithOpts
TopologyInfo getTopologyInfoWithOpts(String id, GetInfoOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
getTopologyPageInfo
TopologyPageInfo getTopologyPageInfo(String id, String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
getSupervisorPageInfo
SupervisorPageInfo getSupervisorPageInfo(String id, String host, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
getComponentPageInfo
ComponentPageInfo getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
getTopologyConf
String getTopologyConf(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
getTopology
StormTopology getTopology(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException Returns the compiled topology that contains ackers and metrics consumsers. ComparegetUserTopology(String id)
.- Parameters:
id
-- Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
getUserTopology
StormTopology getUserTopology(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException Returns the user specified topology as submitted originally. ComparegetTopology(String id)
.- Parameters:
id
-- Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
getTopologyHistory
TopologyHistoryInfo getTopologyHistory(String user) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
getOwnerResourceSummaries
List<OwnerResourceSummary> getOwnerResourceSummaries(String owner) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
getSupervisorAssignments
SupervisorAssignments getSupervisorAssignments(String node) throws AuthorizationException, org.apache.storm.thrift.TException Get assigned assignments for a specific supervisor- Parameters:
node
-- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
sendSupervisorWorkerHeartbeats
void sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) throws AuthorizationException, org.apache.storm.thrift.TException Send supervisor worker heartbeats for a specific supervisor- Parameters:
heartbeats
-- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
sendSupervisorWorkerHeartbeat
void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) throws AuthorizationException, NotAliveException, org.apache.storm.thrift.TException Send supervisor local worker heartbeat when a supervisor is unreachable- Parameters:
heatbeat
-- Throws:
AuthorizationException
NotAliveException
org.apache.storm.thrift.TException
-
processWorkerMetrics
- Throws:
org.apache.storm.thrift.TException
-
isRemoteBlobExists
boolean isRemoteBlobExists(String blobKey) throws AuthorizationException, org.apache.storm.thrift.TException Decide if the blob is removed from cluster.- Parameters:
blobKey
-- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-