Generate the next tuple from a message. <p>This method polls the queue that's being filled asynchronously by the jms connection, every {@link #POLL_I

Notify supervisors/nodes assigned assignments. @param assignments assignments map for nodes @param service {@link AssignmentDistribut

Count based sliding window configuration. @param windowLength the number of tuples in the window @param slidingInterval the number of tuples after

A static factory to create a {@link CombinerAggregator} based on initial value, accumulator and combiner. @param initialValue the initial value of th

Called when a tuple is acked. @param msgId The id of the tuple in the spout.

Called on expiry of events from the window due to {@link EvictionPolicy}. @param events the expired events

The method that is invoked when an entry is removed from the cache. @param key the key of the entry that was removed @param val the

Parses dependency parameter and build {@link Dependency} object. @param dependency string representation of dependency parameter @return Dependency o

Parse a flux topology definition. @param inputFile source YAML file @param dumpYaml if true, dump the parsed YAML to stdout @param proce

Parse a flux topology definition. @param inputStream InputStream representation of YAML file @param dumpYaml if true, dump the parsed YAML

Parse a license report file (DEPENDENCY-LICENSES format) into structured groups. Returns a list of (header_line, [entry_lines]) tuples, preservin

Tuples are passed to two hashing functions and each target task is decided based on the comparison of the state of candidate nodes. <p>See https://me

Delete the oldest files in each overloaded worker log dir.

`permit()` method is invoked for each incoming Thrift request. @param context request context includes info about @param operation operation name @

Populate a subject from credentials using the IAutoCredentials. @param subject the subject to populate or null if a new Subject should be created

filter system streams of aggregated spout/bolt stats if necessary.

Invoked once immediately after construction. @param topoConf Storm configuration

Invoked once immediately after construction. @param conf Storm configuration

Sets up the client API by parsing the configs. @param conf The storm conf containing the config details

No-op. @param topoConf Storm configuration

Allow a Hadoop Configuration to be passed for testing. If it's null then the hadoop configs must be in your classpath.

Prettified executor info. @param e from Nimbus call @return prettified executor info string

Print a help message to out. typically this should be in the form of. command arguments: description of command argument - description

Punctuation marks end of a batch which can be used to compute and pass the results of one stage in the pipeline to the next. For e.g. emit the results

put bolt message to its queue. @param boltMsg BoltMsg to pass to subprocess

putTopologyDebugActionSpct. @param client client @param id id @param action action @param spct spct @param component component @return putTopologyDebu

Returns a Collection of file names found under the given directory. @param dir a directory @return the Collection of file names

Read the image-tag-to-hash file and parse as a Map. <p>You may specify multiple tags per hash all on the same line. Comments are allowed using #. Any