Setup the permissions for the storm code dir. @param user the owner of the topology @param path the directory to set the permissions on @throws IOExc

Setup the permissions for the worker artifacts dirs. @param user the owner of the topology @param path the directory to set the permissions on @throw

Should we emit or not. @return the start time of the message, or null of nothing should be emitted.

Simulate both process and exec times. @param executorIndex the index of this executor. It is used to skew the latencies. @param startTimeNs when the

Sleep for specified milliseconds and return true if sleep was interrupted. @param milliSeconds number of milliseconds to sleep @return true if sleep

Read the contents of a file into a String. @param location the file to read @return the contents of the file @throws IOException on any error

Sort the supplied unique collection of ExecutorDetails in the order in which they should be scheduled. Both the input and output collections contain t

Scheduling uses {@link #sortAllNodes()} which eventually calls this method whose behavior can be altered by setting {@link #nodeSortType}. @param res

Get a string that is a comma delimited list of subsystems.

Submits a topology to run on the cluster as a particular user. A topology runs forever or until explicitly killed. @param asUser The user as which th

Takes ownership of the lock file if possible. @param lastEntry last entry in the lock file. this param is an optimization. we don

Evaluates this predicate on the given argument. @param input the input argument @return true if the input matches the predicate, false otherwise

Reads a string encrypted by another instance with a shared key

Check if resource files are available in the resource path defined by originalResourcePath. @throws Exception if there are no resource files in input

Returns temp file path corresponding to a file name.