Update a subject from credentials using the IAutoCredentials. @param subject the subject to update @param autos the IAutoCredentials to cal

Value class used by implementation (e.g. Text.class, etc.).

Set the blocked changing blobs. This is an input from the outside, and should never be called by the state machine steps.

Set the new assignment for the state. This should never be called from within the state machine. It is an input from outside. @param newAssignment th

A tracked cluster can run tracked topologies. See {@link org.apache.storm.testing.TrackedTopology} for more information on tracked topologies. @param

Writes a posix shell script file to be executed in its own process. @param dir the directory under which the script is to be written @param c

Print a dictionary in a pretty format

Add an empty topology to the cache for testing purposes. @param topoId the id of the topology to add.

Add readonly bind mount location. @param sourcePath the source path @param destinationPath the destination path @param createSource if createSource is

Add version information to the given topology. @param topology the topology being submitted (MIGHT BE MODIFIED) @return topology

Associate a value into something else. @param current what to put value into, will be null if no values have been added yet. @param value what to add

Creates a thread that calls the given code repeatedly, sleeping for an interval of seconds equal to the return value of the previous call. <p>The giv

Returns an array of streams by splitting the given stream into multiple branches based on the given predicates. The predicates are applied in the give

Build a Response object representing unauthorized user, with HTML response. @param user username

Calculate the amount of shared off heap node memory on a given node with the given assignment. @param nodeId the id of the node @param td

Deletes jar files in dirLoc older than seconds. @param dirLoc the location to look in for file @param seconds how old is too old and should be delet

Get the coponenet type for a give id. @param topology the topology this is a part of. @param compId the id of the component. @return the type as a Str

compute weighted avg from a Map of stats and given avg/count keys. @param accData a Map of {win -> key -> value} @param wgtAvgKey weighted averag

Config filters. @param context Servlet context @param filtersConfs filter confs

Configures metrics store (running on Nimbus) to use the class specified in the conf. @param conf Storm config map @param metricsRegistry The Nimbus da

Create or update an existing key. @param serviceType the type of service to create a token for @param user the user the token is for @param to

Get the current unassigned executor. @return the first unassigned executor in execs list.

Declare the output fields produced by this JmsTupleProducer. @param declarer The OuputFieldsDeclarer for the spout.

Deletes the heartbeat at a given path, and any child nodes that may exist. @param path The path to delete.

Provides the <code>Destination</code> (topic or queue) from which the <code>JmsSpout</code> will receive messages.

Download a dump file. @param topologyId topology ID @param hostPort host and port of worker @param fileName dump file name @param user username @retu

Create an array that has all values 0. @return the empty array.