This is for testing only. It allows a test to reset the static state relating to resource names. We reset the mapping because some algorithms sadly ha

Restore the trigger policy from the state that was earlier checkpointed by the framework. @param state the state

Run a profiling request. @param request the request to run @param stop is this a stop request? @return true if it succeeded, else false @throws IOEx

Scale the stats by v. This is not scaling everything proportionally. We don't want the stddev to increase so instead we scale the mean and shift ever

Schedule a function to be executed in the timer. @param delaySecs the number of seconds to delay before running the function @param func the

Send node specific assignments to supervisor @param assignments

Set the list of hosts that are blacklisted. @param hosts the new hosts that are blacklisted.

Provide an instance of this class for delegates to use. To mock out delegated methods, provide an instance of a subclass that overrides the implement

Provide an instance of this class for delegates to use. To mock out delegated methods, provide an instance of a subclass that overrides the implementa

Set {@link #jmsProvider}. <p>Set the <code>JmsProvider</code> implementation that this Spout will use to connect to a JMS <code>jakarta.jms.Desinatio

Set the <code>JmsTupleProducer</code> implementation that will convert <code>jakarta.jms.Message</code> object to <code>org.apache.storm.tuple.Values<

Defines the max number of polled offsets (records) that can be pending commit, before another poll can take place. Once this limit is reached, no more