convert a thrift worker heartbeat into a java HashMap.

Creates a (defensive) copy of itself.

Must be able to copy the rotation policy.

Copy a directory. @param fromDir from where @param toDir to where @throws IOException on any error

Is there any possibility that exec could ever fit on this node. @param exec the executor to schedule @param td the topology the executor is a part of

Is there any possibility that a resource request could ever fit on this. @param minWorkerCpu the configured minimum worker CPU @param requestedResourc

Utility method for creating a template for Bolt stats. @return Empty template map for Bolt statistics.

The user interface to create an IConfigLoader instance. It iterates all the implementations of IConfigLoaderFactory and finds the one which supports t

Creates a reader that reads from beginning of file. @param file file to read

Create a new worker ID for this process and store in in this object and in the local state. Never call this if a worker is currently up and running.

Compute HMAC of the identifier using the secret key and return the output as password. @param identifier the bytes of the identifier @param key

Create an array of TopologyDetails by reading serialized files for topology and configuration in the resource path. Skip topologies with no executors/

Path will be appended with a monotonically increasing integer, a new node will be created there, and data will be put at that node. @param path The p

This method compares Resource Maps while considering any resources are NULL to be 0.0 @param firstMap Resource Map A @param secondMap Resource Map B

declare what are the fields that this code will output. @param declarer OutputFieldsDeclarer

Decode key. @param encodedKey the value of key (KRAW type) @return the decoded value of key (K type)

If totalSize of files exceeds the either the per-worker quota or global quota, Logviewer deletes oldest inactive log files in a worker directory or in

Allows us to delete the znodes within /storm/blobstore/key_name whose znodes start with the corresponding nimbusHostPortInfo. @param path

Add -d option. @return the self

Sanity check if everything the topology needs is there for it to run. @param conf the config of the supervisor @param topologyId the ID of the

Checks authorization for the log file and download. @param host host address @param fileName file to download @param user username @param isDaemon tr

Drop all of the changingBlobs and pendingChangingBlobs. <p>PRECONDITION: container is null @param dynamicState current state. @return the next state

Drop the first N elements and create a new list. @param list the list @param count element count to drop @return newly created sublist that drops the