Returns the commands of this instance. Arguments with spaces in are presented with quotes round; other arguments are presented raw @return a string r

Truncates path to the last numElements. @param path The path to truncate. @param numElements The number of elements to preserve at the end of the path

Unassign everything for the given topology id. @param topoId the is of the topology to unassign

Updates the timestamp of when a metadata string was last used. Adds the type of the string if it is a new type. @param metricTimestamp the timesta

If a node or rack has a kind of resource not in a request, make that resource negative so when sorting that node or rack will be less likely to be sel

Update the cache with heartbeats from a worker through zookeeper. @param topoId the id to the topology. @param executorBeats the HB data. @par

Updates the last update time of existing blobs in the blobstore to the current time. @throws IOException on any error

Update serialized byte counts for each message. @param sourceTaskId source task @param message serialized message

Overrides the default file extension.

Add an AggregateStats entry to the TopologyPageInfo instance. @param boltId Id of the bolt to add the entry for. @param aggregateStats Defines the ent

addLogviewerInfo. @param config config @param result result

add mock data for the spout. @param spoutId the spout to be mocked @param streamId the stream of the spout to be mocked @param valueses the mocked d

Adds the user supplied function as a shutdown hook for cleanup. Also adds a function that sleeps for numSecs and then halts the runtime to avoid any z

Add an AggregateStats entry to the TopologyPageInfo instance. @param spoutId Id of the spout to add the entry for. @param aggregateStats Defines the e

Add a new worker lifecycle hook. @param workerHook the lifecycle hook to add

aggregate number acked and complete latencies across all streams.

aggregate topo executors stats. @param topologyId topology id @param exec2nodePort executor -> host+port @param task2component task -> component

aggregate statistics per worker for a topology. Optionally filtering on specific supervisors @param stormId topology id @param stormName

compute an weighted average from a list of average maps and a corresponding count maps extracted from a list of ExecutorSummary. @param avgSeq a li

aggregate weighted average of all streams. @param avgs a Map of {win -> stream -> average value} @param counts a Map of {win -> stream -> count val

Return true if any of the resources are > 0.

## Repartitioning Operation. <p>All tuples in the batch are sent to the same partition. Different batches in the stream may go to different partition

Builds container for single Redis environment. @param config configuration for JedisPool @return container for single Redis environment

Builds an empty ComponentAggregateStats instance for bolts. @return empty ComponentAggregateStats instance.

Builds an empty ComponentAggregateStats instance for spouts. @return empty ComponentAggregateStats instance.

Build a Response object representing success response with HTML entity. @param content HTML entity content, String type

Factory method that creates a Builder with String key/value deserializers. @param bootstrapServers The bootstrap servers for the consumer @param topi

Determine if the given constructor/method parameter types are compatible given arguments List. Consider if list coercian can make it possible. @param

Clean up a container. PRECONDITION: All of the processes have died. @param dynamicState current state @param staticState static data @param nextState

Clear all the state for a storm. @param stormId storm id

Close the {@link #session} and {@link #connection}. <p>When overridden, should always call {@code super} to finalize the active connections.

for unit tests.