Reset the context back to a default. used for testing.

Used by SaslTokenMessage::processToken() to respond to server SASL tokens. @param token Server's SASL token @return token to send back to the server.

Drop the only first element and create a new list. equivalent to drop(list, 1). @param list the list @return newly created sublist that drops the fir

Returns Jedis instance to pool. @param jedis Jedis instance to return to pool

Returns JedisCluster instance to pool. @param jedisCluster JedisCluster instance to return to pool

Run the topology and verify that the number and contents of count based windows is as expected once the spout and bolt have emitted sufficient tuples.

Run the topology and verify that the number and contents of time based windows is as expected once the spout and bolt have emitted sufficient tuples.

Run docker command using {@link Config#SUPERVISOR_WORKER_LAUNCHER}. @param conf the storm conf @param dockerCommand the docker command

Respond to server's SASL token. @param saslTokenMessage contains server's SASL token @return client's response SASL token

Scale the parallelism of this component by v. The aggregate throughput will be the same. The parallelism will be rounded up to the next largest whole

Scan events in the queue, using the expiration policy to check if the event should be evicted or not. @param fullScan if set, will scan the entire qu

This method is invoked to calculate a scheduling for topology td. Cluster will reject any changes that are not for the given topology. Any changes m

Schedule a function to run recurrently with jitter. @param delaySecs the number of seconds to delay before running the function @param recurSecs the