@see AccessControlType

Write a worker heartbeat at the path. @param path The path whose node we want to set. @param data The data to put in the node. @param acls The acls t

Setup the container to run. By default this creates the needed directories/links in the local file system PREREQUISITE: All needed blobs and topology,

Returns the combined string, escaped for posix shell. @param command the list of strings to be combined @return the resulting command string

Any clean up could be handled here.

If using simulated time simulate waiting for 10 seconds. This is intended for internal testing only.

Skips over and discards N bytes of data from the input stream. <p/> FileInputStream#skip may not work the first time, so ensure it successfully skips

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

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

Prepare the spout (globally) before starting the topology.

whether this connection is available to transfer data.

This attempt committed successfully, so all state for this commit and before can be safely cleaned up. @param tx attempt object containing transactio

if the lock on the directory is stale, take ownership.

Sends the elements of this stream to a bolt. This could be used to plug in existing bolts as sinks in the stream, for e.g. a {@code RedisStoreBolt}. T

Create an Enum map with given lambda mapper. @param klass the Enum class @param mapper The mapper producing value with key (enum constant) @return An

Convert a Principal to a local user name. @param principal the principal to convert @return The local user name.

Process a JMS message object to create a Values object. @param msg - the JMS message @return the Values tuple, or null if the message couldn't be pro

Returns null if file already exists. throws if there was unexpected problem

Prettify OwnerResourceSummary. @param ownerResourceSummary ownerResourceSummary @return Map of prettified OwnerResourceSummary.

Updates the blob data. @param key Key for the blob @param who Is the subject having the write privilege for the blob @return AtomicOutputStream retur