Called during shutdown.

Delete the topo dir if it contains zero port dirs.

Clean up any temporary files. This will be called after updating a blob, either successfully or if an error has occurred. The goal is to find any fil

Marks an offset as committed. This method has side effects - it sets the internal state in such a way that future calls to {@link #findNextCommitOffse

Commit the new version and make it available for the end user. PRECONDITION: uncompressToTempLocationIfNeeded will have been called. PRECONDITION: thi

expires events that fall out of the window every EXPIRE_EVENTS_THRESHOLD so that the window does not grow too big.

Completely remove anything that is cached locally for this blob and all tracking files also stored for it. This will be called after the blob was dete

computes max bolt capacity. @param executorSumms a list of ExecutorSummary @return max bolt capacity

Compute a map of user topology specific components. @param topology userTopology @return a map of Component Id to Component

Compute the capacity of a executor. approximation of the % of time spent doing real work. @param summary the stats for the executor. @return the capac

convert {topology-id -> SchedulerAssignment} to {topology-id -> {executor [node port]}}. @return {topology-id -> {executor [node port]}} mapping

Convert {topology-id -> SchedulerAssignment} to {topology-id -> {WorkerSlot WorkerResources}}. Make sure this can deal with other non-RAS schedulers l

compute a topology-id -> alive executors map. @param existingAssignment the current assignments @param topologyToExecutors the executors for the cur

Convert assignment information in zk to SchedulerAssignment, so it can be used by scheduler api. @param existingAssignments current assignments

Computes the min ts across all streams.

Configures metric processor (running on supervisor) to use the class specified in the conf. @param conf the supervisor config @return WorkerMetricsPr

Connect to the specified server via framed transport. @param transport The underlying Thrift transport. @param serverHost server host @param asUser

Provides the JMS <code>ConnectionFactory</code> @return the connection factory @throws Exception

Non blocking. Returns immediately if Q is empty. Returns number of elements consumed from Q.

Ensures that we only return heartbeats for executors assigned to this worker.

convert thrift ExecutorStats structure into a java HashMap.

Convert Long Executor Ids in ZkHbs to Integer ones structure to java maps.

convert executors stats into a HashMap, note that ExecutorStats are remained unchanged.