getNimbusSummary. @param clusterInfo clusterInfo @param config config @return getNimbusSummary

Get the number of nodes and slots this would provide to get the slots needed. @param slots the number of slots needed @return the number of nodes and

Get the nodes needed to schedule an isolated topology. @param td the topology to be scheduled @param allNodes the nodes already scheduled for this top

Get the nodes needed to schedule a non-isolated topology. @param td the topology to be scheduled @param allNodes the nodes already scheduled for this

<p> Determine how many bound ackers to put in before assigning the executor to current workerSlot. Note that the worker slot must be a new worker to b

getNumaIdForPort for a specific supervisor. @param port port @param supervisorConf supervisorConf @return getNumaIdForPort

gets the set of all configured numa ports for a specific supervisor. @param supervisorConf supervisorConf @return set of all numa ports

If clocks in sync, then acquires the oldest expired lock Else, on first call, just remembers the oldest expired lock, on next call check if the lock i

Prioritize the list of all topologies in the cluster. @return ordered list of topologies to schedule.

Get override service ID. @return the service ID of the local override DRPC instance

Get prettified ownerResourceSummaries. @param ownerResourceSummaries ownerResourceSummaries from thrift call @param conf Storm conf @return map to be

Get a specific owner resource summary. @param ownerResourceSummaries Result from thrift call. @param client client @param id Owner id. @param config S

If this task spawns any subprocesses, those subprocesses must immediately write their PID to this directory on the local filesystem to ensure that Sto

Get the partitions that should be handled by this task.

Get an optional password for a user. If no password for the user is found the option will be empty and another PasswordProvider would be tried. @par

Returns pending triggers to be emitted.

Get PID. @return pid, if the process has been launched, null otherwise.

Get port. @return the port ZK is listening on (localhost)

Get supervisor info in a map. @param supervisorSummary from nimbus call. @param config Storm config. @return prettified supervisor info map.

Get the private key using BouncyCastle library from a PKCS#1 format file. @return The Private Key @throws IOException The IOException

get the current sub-process executing the given command. @return process executing the command

* Returns a random integer between min (inclusive) and max (inclusive)

* Returns a random integer between min (inclusive) and max (inclusive)

* Returns a random integer between min (inclusive) and max (inclusive)

Client facing API to get the last update time of existing blobs in a blobstore. This is only required for use on supervisors. @return the timestamp

Get the version of the blob in the blob store. PRECONDITION: this can only be called with a lock on this instance held.

Gets the memory reserved by the given topology across all ports on this supervisor. @param topologyId The topology id @return The memory reserved by

Returns the current thread classloader.

In case no resources are specified, returns empty map. In case differing types of resources are specified, throw. Otherwise, add all the resources for