Store a new version of a private key. This is expected to only ever be called from nimbus. All ACLs however need to be setup to allow the given servi

Adds the user supplied function as a shutdown hook for cleanup. Also adds a function that sleeps for a second and then halts the runtime to avoid any

Assign a free slot on the node to the following topology and executors. This will update the cluster too. @param topId the topology to assign a free s

Add a boolean option that enables something. @param shortName the short single character name of the option (no `-` character proceeds it). @param lon

Calculate the min percentage used of the resource. @see NormalizedResources#calculateMinPercentageUsedBy(org.apache.storm.scheduler.resource.normaliza

compares to keys on a byte by byte basis. @return comparison of key byte values

Provides the JMS <code>ConnectionFactory</code>. @return the connection factory

Check contains. @return true if this contains the specified name of the field.

A simple sanity check to see if all of the resources in this would be large enough to hold the resources in other ignoring memory. It does not check m

Creates a two task assignment by selecting random tasks.

Parses exclusion parameter and build {@link Exclusion} object. @param exclusionString string representation of exclusion parameter @return Exclusion

A custom stream grouping by implementing the CustomStreamGrouping interface.

Deletes the blob data and metadata. @param key Key for the blob @param who Is the subject having write privilege for the blob

Emit a batch of tuples for a list of partitions/transactions. <p>Return the map of metadata describing this batch that will be used as lastPartitionM

Ensure the existence of a given directory. @throws IOException if it cannot be created and does not already exist

Return the tuple timestamp indicating the time when the event happened. @param tuple the tuple @return the timestamp

Extracts the given file to the given directory. Only zip entries starting with the given prefix are extracted. The prefix is stripped off entry names

Filter all of the changing blobs to just be for those compatible with the given assignment. All others will be released appropriately. @param dynamic

Rotate the buckets a set number of times for testing purposes. @param numToEclipse the number of rotations to perform.

Free all slots on this node. This will update the Cluster too. @param cluster the cluster to be updated

Returns a new NestableFieldValidator for a given class. @param cls the Class the field should be a type of @param notNull whether or not a value

return the assigment for this.

Returns bolt definitions. @return bolt definitions

Get the underlying thrift client. @return the underlying thrift client.

Get columns. @return list of columns that represents one row in a DB table.

Gets the component id for the specified task id. The component id maps to a component id specified for a Spout or Bolt in the topology definition. @p

Get connection. @return a DB connection over which the queries can be executed.

Gets the topology context associated with the tuple.

The coordinator for a TransactionalSpout runs in a single thread and indicates when batches of tuples should be emitted. The Coordinator that you prov

Returns the Double at position i in the tuple. @throws ClassCastException If that field is not a Double @throws IndexOutOfBoundsException - if

Returns the topology ID belonging to a blob key if it exists. @param key the blob key @return the topology id belonging to the key if it can be infer

getJsonResponseHeaders. @param callback callbackParameterName @param headers headers @return getJsonResponseHeaders

Extracts key from tuple. @param tuple source tuple @return key

Gets the last time a metadata string was used.

Get local assignment for a storm @param id

Returns the string matching the string Id if in the cache. @param stringId The string Id to check @return the associated string if the Id is in the