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 TypeMethodDescriptionvoidbeginBlobDownload(String key) beginCreateBlob(String key, SettableBlobMeta meta) beginUpdateBlob(String key) voidcancelBlobUpload(String session) voidvoiddeactivate(String name) voidEnable/disable logging the tuples generated in topology via an internal EventLogger bolt.voiddeleteBlob(String key) downloadBlobChunk(String session) downloadChunk(String id) voidfinishBlobUpload(String session) voidfinishFileUpload(String location) getBlobMeta(String key) intgetBlobReplication(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.booleanisRemoteBlobExists(String blobKey) Decide if the blob is removed from cluster.booleanisTopologyNameAllowed(String name) voidkillTopology(String name) voidkillTopologyWithOpts(String name, KillOptions options) voidprocessWorkerMetrics(WorkerMetrics metrics) voidrebalance(String name, RebalanceOptions options) voidSend supervisor local worker heartbeat when a supervisor is unreachablevoidSend supervisor worker heartbeats for a specific supervisorvoidsetBlobMeta(String key, SettableBlobMeta meta) voidsetLogConfig(String name, LogConfig config) voidsetWorkerProfiler(String id, ProfileRequest profileRequest) voidsubmitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) voidsubmitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) intupdateBlobReplication(String key, int replication) voiduploadBlobChunk(String session, ByteBuffer chunk) voiduploadChunk(String location, ByteBuffer chunk) voiduploadNewCredentials(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:
AlreadyAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.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:
AlreadyAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
killTopology
void killTopology(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
killTopologyWithOpts
void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
activate
void activate(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
deactivate
void deactivate(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
rebalance
void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.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:
NotAliveExceptionAuthorizationExceptionorg.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:
NotAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
beginCreateBlob
String beginCreateBlob(String key, SettableBlobMeta meta) throws AuthorizationException, KeyAlreadyExistsException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionKeyAlreadyExistsExceptionorg.apache.storm.thrift.TException
-
beginUpdateBlob
String beginUpdateBlob(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
uploadBlobChunk
void uploadBlobChunk(String session, ByteBuffer chunk) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
finishBlobUpload
void finishBlobUpload(String session) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
cancelBlobUpload
void cancelBlobUpload(String session) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getBlobMeta
ReadableBlobMeta getBlobMeta(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
setBlobMeta
void setBlobMeta(String key, SettableBlobMeta meta) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
beginBlobDownload
BeginDownloadResult beginBlobDownload(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
downloadBlobChunk
ByteBuffer downloadBlobChunk(String session) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
deleteBlob
void deleteBlob(String key) throws AuthorizationException, KeyNotFoundException, IllegalStateException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionKeyNotFoundExceptionIllegalStateExceptionorg.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:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
updateBlobReplication
int updateBlobReplication(String key, int replication) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
createStateInZookeeper
- Throws:
org.apache.storm.thrift.TException
-
beginFileUpload
- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
uploadChunk
void uploadChunk(String location, ByteBuffer chunk) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
finishFileUpload
void finishFileUpload(String location) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
downloadChunk
ByteBuffer downloadChunk(String id) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getNimbusConf
- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getClusterInfo
- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologySummaries
List<TopologySummary> getTopologySummaries() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologySummaryByName
TopologySummary getTopologySummaryByName(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologySummary
TopologySummary getTopologySummary(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getLeader
- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
isTopologyNameAllowed
boolean isTopologyNameAllowed(String name) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologyInfoByName
TopologyInfo getTopologyInfoByName(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologyInfo
TopologyInfo getTopologyInfo(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologyInfoByNameWithOpts
TopologyInfo getTopologyInfoByNameWithOpts(String name, GetInfoOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologyInfoWithOpts
TopologyInfo getTopologyInfoWithOpts(String id, GetInfoOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologyPageInfo
TopologyPageInfo getTopologyPageInfo(String id, String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getSupervisorPageInfo
SupervisorPageInfo getSupervisorPageInfo(String id, String host, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveExceptionAuthorizationExceptionorg.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:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologyConf
String getTopologyConf(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Throws:
NotAliveExceptionAuthorizationExceptionorg.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:
NotAliveExceptionAuthorizationExceptionorg.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:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologyHistory
TopologyHistoryInfo getTopologyHistory(String user) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getOwnerResourceSummaries
List<OwnerResourceSummary> getOwnerResourceSummaries(String owner) throws AuthorizationException, org.apache.storm.thrift.TException - Throws:
AuthorizationExceptionorg.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:
AuthorizationExceptionorg.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:
AuthorizationExceptionorg.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:
AuthorizationExceptionNotAliveExceptionorg.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:
AuthorizationExceptionorg.apache.storm.thrift.TException
-