Used for local cluster. @param supervisor {@link org.apache.storm.daemon.supervisor.Supervisor}

Simulated time wait for a cluster. This is intended for internal testing.

Targeted validation against StatsUtil.aggTopoExecsStats() to verify that when a bolt or spout has an error reported, it is included in the returned To

Targeted validation against StatsUtil.aggTopoExecsStats() to verify that when a bolt and spout does NOT have an error reported, it gracefully handles

Applies this function to the given arguments. @param input1 the first function argument @param input2 the second function argument @return the functi

Returns a new state by applying the value on the current state. @param state the current state @param value the value @return the new state

Joins two values and produces a {@link Pair} of the values as the result. @param value1 the first value @param value2 the second value @return a pair

Joins two values and produces a result. @param value1 the first value @param value2 the second value @return the result