Gets an available port. Consider if it is possible to pass port 0 to the server instead of using this method, since there is no guarantee that the por

Return all the available slots on this supervisor.

Given the results Map from UIHelper.getTopologySummary(), return the entry for the requested boltId. @param result Map from UIHelper.getTopologySumma

getComponentErrorInfo. @param errorInfo errorInfo @param config config @param topologyId topologyId @param asLastError Pass a value of true if the res

Returns a list of all component definitions. @return components

Return the current (total) counts of all tracked objects, then advance the window. <p/> Whenever this method is called, we consider the counts of the

Get all of the configured Credential Renewer Plugins. @param conf the storm configuration to use. @return the configured credential renewers.

Get the log lines that contain the unique {@link StringDecorator} string for the given component. Test spouts and bolts can write logs containing the

Return eviction information as map {scheduled topo : evicted topos} NOTE this method returns the map of a completed scheduling round. If scheduling is

get the exit code. @return the exit code of the process

Get the list of events expired from the window since the last time the window was generated. <p> <b>Note: </b> This is not supported when using window

From a set of topologies that have been found to cleanup, return a set that has been detected for a minimum amount of time. Topology entries first det

Get the fields associated with a stream. The streams passed in are returned by the {@link RecordTranslator#streams() } method. @param stream the stre

A simple numeric value may not be sufficient for certain formats consequently this is a String.

This is used as a Zookeeper node path for storing metadata.

Gets the Integer field with a specific name. @throws ClassCastException If that field is not an Integer @throws IllegalArgumentException - if f

Finds directories for specific worker ids that can be cleaned up. @param logDirs directories to check whether they're worker directories or not @para

get the metadata string Id portion of the key for metadata keys. @return the metadata string Id @throws RuntimeException if the key is not a metadat

Get the list of newly added events in the window since the last time the window was generated. <p> <b>Note: </b> This is not supported when using wind

Get the next key version number that should be used for this topology id. This is expected to only ever be called from nimbus, but it is acceptable if

Get all the Nimbus Auto cred plugins. @param conf nimbus configuration to use. @return nimbus auto credential plugins.

Get a map from nodeId to hostname. @return a map from nodeId to hostname