aggregates bolt stream stats, returns a Map of {metric -> win -> aggregated value}.

## Repartitioning Operation. <p>Every tuple is replicated to all target partitions. This can useful during DRPC – for example, if you need to do a st

Encoded as -600 ... short(2) len ... int(4) payload ... byte[]

As the file is read into a buffer, 1/2 the buffer's size at a time, we search the buffer for matches of the substring and return a list of zero or mor

Builds a new LocalCluster. @return the LocalCluster @throws Exception on any one of many different errors. This is intended for testing so yes it is

Given a list of bolt definitions, build a map of Storm bolts with the bolt definition id as the key. Attempt to coerce the given constructor arguments

Given a topology definition, resolve and instantiate all components found and return a map keyed by the component id.

Creates a topology with device-id and count (which are whole numbers) as tuple fields in a stream and it finally generates result stream based on min

Build a Response object representing exception, with JSON response. @param ex Exception object @param callback callbackParameterName for JSONP

Given a spout definition, return a Storm spout implementation by attempting to find a matching constructor in the given spout class. Perform list to a

Builds stream definitions. @param context context @param builder builder

Build a Response object representing unauthorized user, with JSON response. @param user username @param callback callbackParameterName for JSONP

Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with values {@link TridentMinMaxO

Given a list of worker hook definitions, build a Storm worker hook implementation by attempting to find a matching constructor in the given worker hoo

Check if this topology can be added to this pool. @param td the topology @return true if it can else false

check if timer is active.

Check scheduling feasibility for a quick failure as the second step in {@link #schedule(Cluster, TopologyDetails)}. If scheduling is not possible, the

Compares the regenerated DEPENDENCY-LICENSES in target with the DEPENDENCY-LICENSES in the root, and verifies that they are identical

Cleanup any global state kept.

Deletes topologies from history older than mins minutes. @param mins the number of mins for old topologies