Check if the container is over its memory limit AND needs to be killed. This does not necessarily mean that it just went over the limit. @throws IOEx

Given the first byte of a vint/vlong, determine the sign. @param value the first byte @return is the value negative

Checks if {@link OffsetAndMetadata} was committed by a {@link KafkaSpout} instance in this topology. @param tp The topic partition the commit metadat

Extracting out to mock it for tests. @return true if on Linux.

If the stateful windowed bolt should have its windows persisted in state and maintain a subset of events in memory. <p> The default is to keep all the

Function to decide if the heartbeats is ready. @param nodeIds all the node ids from current physical plan[assignments], read from {@code ClusterState}

Checks if a specific failed {@link KafkaSpoutMessageId} is ready to be retried, i.e is scheduled and has retry time that is less than current time. @p

A quick check to see if scheduling is feasible. @return False if scheduling is infeasible, true otherwise.

If all the tasks are local tasks, the topology has only one worker. @return true if this worker is the single worker; false otherwise.

Check if a slot is occupied or not. @param slot the slot be to checked. @return true if the specified slot is occupied.

Decide if the assignments is synchronized from remote state-store.

Check whether the value is tombstone (deletion mark) value. @param value the value to check @return true if the value is tombstone, false otherwise

Validates blob key. @param key Key for the blob.

Modify the collection, and place unassigned ackers to the end of the list. @param orderedExecutors List of executors that are presumed to be sorted.

Compute the java.library.path that should be used for the worker. This helps it to load JNI libraries that are packaged in the uber jar. @param storm

:return: sorted list of JIRA ids present in Git pull requests

Performs inner Join with the newStream. SQL: <code>from priorStream inner join newStream on newStream.field = priorStream.field1</code> same as: <code

Kill all processes.

Return the most recent last modified time for all log files in a worker's log dir. Using stream rather than File.listFiles is to avoid large mem usage

This thread helps us to check for channel connection periodically. This is performed just to know whether the destination address is alive or attempts

start distribute supervisor.

After reserving resources for the worker (i.e. calling reserveResourcesForWorker), this function can be used to launch worker process. @param user

Invoke when gains leadership.

List keys. @return all keys that are available for reading @throws IOException on any error