To compose launch command based on workerId and existing command. @param workerId the worker id @param existingCommand the current command to run that

Get the current leader's address. @return the current leader's address, may return null if no one has the lock.

Get the version of the blob cached locally. If the version is unknown or it has not been downloaded NOT_DOWNLOADED_VERSION should be returned. PRECON

Get the Logviewer worker log URLs for the specified component.

Gets all logs for the specified component, concatenated to a single string.

getLogviewerLink. @param host host @param fname fname @param config config @param port port @return getLogviewerLink.

Get system free memory in megabytes. @return system free memory in megabytes @throws IOException on I/O exception

Return a metadata file (worker.yaml) for given worker log directory. @param logDir worker log directory

Get log link to nimbus log. @param host nimbus host name @param config storm config @return log link.

Get a map from RasNodeId to HostName. @return map of nodeId to hostname

Get all the available worker slots in the cluster, that are not blacklisted. @param blacklistedSupervisorIds list of supervisor ids that should also b

Get the resources in the cluster that are available for scheduling. @param blacklistedSupervisorIds other ids that are tentatively blacklisted.

Get the number of topologies with cached heartbeats. @return the number of topologies with cached heartbeats.

Gets the off heap memory requirement for a certain task within a topology. @param exec the executor the inquiry is concerning. @return Double the amo

Get offset lags. @param newKafkaSpoutOffsetQuery represents the information needed to query kafka for log head and spout offsets @return log head offs

Gets the on heap memory requirement for a certain task within a topology. @param exec the executor the inquiry is concerning. @return Double the amou

Return a relative path that the tuple should be written to. For example, if an HdfsBolt were configured to write to /common/output and a partitioner r

Gets the partitions for the following batches. The emitter will be asked to refresh partitions when this value changes. @return The partitions for th

Get the userId of the onwer of the path by running "ls -dn path" command. This command works on Posix systems only. @param fpath full path to the fil

Returns the pending acks. @return the pending acks

Make the best effort to obtain the Process ID from the Process object. Thus staying entirely with the JVM. @param p Process instance returned upon ex

Return the port associated with this.

Support method to obtain additional log info for the process. Use the contents of comm and cmdline in the process directory. Note that this method wor

Provides the ReadOnlyStringMetadataCache interface to the cache instance. @throws MetricException if the cache instance was not created