Wait for the cluster to be idle. This is intended to be used with Simulated time and is for internal testing. Note that this does not wait for spout

Continue to execute body repeatedly until condition is true or TEST_TIMEOUT_MS has passed. @param condition what we are waiting for @param body what t

Reset the slot count of any tracked objects to zero for the given slot.

Add in a single OutputStream to this component. @param stream the stream to add @return this

This method sends a bolt message to a non-JVM bolt process. @param msg bolt message

This method sends a list of task IDs to a non-JVM bolt process. @param taskIds list of task IDs

Finds a oldest expired lock file (using modification timestamp), then takes ownership of the lock file. Impt: Assumes access to lockFilesDir has been

Add a child link. @param child a child the consumes from this

Add Command line options for configuring the output of this. @param options command line options to update

Add in a single config. @param config the key for the config @param value the value of the config @return this for chaining.

Adds an additional value to the metric.

Add a StateStorageListener to the connection. @param listener A StateStorageListener to handle changing cluster state events.

Aggregates number executed, process latency, and execute latency across all streams. @param id2execAvg { global stream id -> exec avg value }, e.g.,

aggregate bolt stats. @param statsSeq a seq of ExecutorStats @param includeSys whether to include system streams @return aggregated bolt stats: {me

aggregate all bolt streams. @param stats a Map of {metric -> win -> stream id -> value} @return a Map of {metric -> win -> aggregated value}

Aggregates the values for each key of this stream using the given initial value, accumulator and combiner. @param initialValue the initial value of t

aggregate common stats from a spout/bolt, called in aggregateSpoutStats/aggregateBoltStats.

Returns all slots that are available for the next round of scheduling. A slot is available for scheduling if it is free and can be assigned to, or if

Take all compressed serialized files in {@link #originalResourcePath} and create anonymized versions or the topology and configuration in the {@link #

Find if all processes for the user on workId are dead. This method attempts to optimize the calls by: <p> <li>checking a collection of ProcessIds

Check if worker tokens should be enabled on the server side or not. @param multiThriftServer a collection of Thrift servers to know if the transport

Convert {@link Artifact} object to String for printing. @param artifact Artifact object @return String representation of Artifact