<p> Determine how many bound ackers to put into the given workerSlot. Then try to assign the ackers one by one into this workerSlot upto the calculate

Attempt to assign current executor (execIndex points to) to worker and node. Assignment validity check is done before calling this method. @param exe

Assign a single executor to a slot, even if other things are in the slot. @param ws the slot to assign it to. @param exec the executor to assign. @par

Assign a slot to the given node. @param n the node to assign a slot to. @return true if there are more slots to assign else false.

this is called after the assignment is changed in ZK.

Diff old/new assignment to find nodes which assigned assignments has changed. @param oldAss old assigned assignment @param newAss new assigned assign

Wait for the caller to gain leadership. This should only be used in single-Nimbus clusters, and is only useful to allow testing code to wait for a Loc

Get backpressure topologies. Note: In Storm 2.0. Retained for enabling transition from 1.x. Will be removed soon.

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

Build a Response object representing download a file. @param contentDispositionName The name to set in the Content-Disposition header @param file fil

Calculate throughput. @return events/sec

Rewrites a topology so that all the tuples flowing through it are captured. @param topology the topology to rewrite @return the modified topology and

Checks if the topology's resource requirements are initialized. Will modify topologyResources by adding the appropriate defaults @param topologyResour

Clean up the container partly preparing for restart. By default delete all of the temp directories we are going to get a new worker_id anyways. POST C

This function will be called when the worker needs to shutdown. This function should include logic to clean up after a worker is shutdown. @param use

Actually cleanup the blobs to try and get below the target cache size. @param store the blobs store client used to check if the blob has been deleted

called once when the system is shutting down, should be idempotent.

Schedule a reconnect if we closed a non-null channel, and acquired the right to provide a replacement by successfully setting a null to the channel fi

This function returns the scheduler's configuration. @return The scheduler's configuration.

convert thrift executor heartbeats into a java HashMap.