Read supervisor details/exclude the dead slots. @param superToDeadPorts dead ports on the supervisor @param topologies al

Reads the blob from the blob store and writes it into the output stream. @param key Key for the blob @param out Output stream @param who Is the subje

Ugly utility, maybe someone else can do this better.

Returns a Collection of files found under the given directory. @param dir a directory @return the Collection of file names

Reads a zero-compressed encoded long from input stream and returns it. @param stream Binary input stream @return deserialized long from stream.

Reads text file and extracts words from each line. @return a list of all (non-unique) words

Get worker heartbeat by workerId.

Do everything needed to recover the state in the AsyncLocalizer for a running topology. @param currentAssignment the assignment for the topology. @pa