Delete a local cache of stormId which is mapped to a specific storm name. @param stormName storm name

Delete a topology conf when we are done. @param topoId the id of the topology @param who who is deleting it @throws AuthorizationException if who is n

Delete a topology when we are done. @param topoId the id of the topology @param who who is deleting it @throws AuthorizationException if who is not al

Deserialize an object stored in a string. The String is assumed to be a base64 encoded string containing the bytes to actually deserialize. @param st

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

Determines which SCM is in use (Subversion, git, or none) and captures output of the SCM command for later parsing. @return SCM in use for this build

Return true if the main process exited, else false. This is just best effort return false if unknown.

Ack the message. @param msg the message @throws JMSException the JMS exception in case of error

Fail the messages. @throws JMSException in case of error

A filter which populates the request if it is null and then passes it on to the next entity in the chain. @param request the request to populate @para

Prepare the plugin. @param topoConf the topology conf

Prepare the plugin. @param conf the storm cluster conf set via storm.yaml

Sets the cursor to the location dictated by the first poll strategy and returns the fetch offset.

Lists the clusters

Downloads a blob locally. @param blobStore the client blobstore @param remoteBlobstoreUpdateTime last modification time of remote blo

Generate a string listing the switch mapping implementation, the mapping for every known node and the number of nodes and unique switches known about

Gets the earliest retriable offsets. @return The earliest retriable offset for each TopicPartition that has offsets ready to be retried, i.e. for

Creates a tuple from the kafka record and emits it if it was never emitted or it is ready to be retried. @param record to be emitted @return true if

Encode a identifier as a base64-encoded char[] array. @param identifier as a byte array. @return identifier as a char array.

enqueue a received message.

separated from mkExecutor in order to replace executor transfer in executor data for testing.

first zip the two seqs, then do expand-average, then merge with sum. @param avgSeq list of avgs like: [{win -> GlobalStreamId -> value}, ...] @para