Check to see if any of the users groups intersect with the list of groups passed in. @param user the user to check @param groupsToCheck the

Returns true if field is_include_sys is set (has been assigned a value) and false otherwise

Returns true if field is_include_sys is set (has been assigned a value) and false otherwise

Kill a specific supervisor. This is intended mostly for internal testing. @param id the id of the supervisor

Returns a new NestableFieldValidator for a List of the given Class. @param cls the Class of elements composing the list @param notNull whether or

Get the path to the log config for a topology. @param stormId the topology id. @return the path to the config.

This aggregator operation computes the maximum of tuples by the given {@code inputFieldName} and it is assumed that its value is an instance of {@code

same as clojure's (merge-with merge m1 m2).

Get ZK ACLs for a topology to have read/write access. @param topoConf the topology config. @return the ACLs.

Get all of the topologies that need scheduling. @return all of the topologies that are not fully scheduled.

Generate a random number that follows the statistical distribution. @param rand the random number generator to use @return the next number that should

Get the next state based on this checkpoint state. @param recovering if in recovering phase @return the next checkpoint state based on this state.

Called on activation of the window due to the {@link TriggerPolicy}. @param events the list of current events in the window. @param newEvents

<code>ISpout</code> implementation. <p>Connects the JMS spout to the configured JMS destination topic/queue.

The first one that is not null. @param rest all the other somethings @param <V> whatever type you want. @return the first one that is not null

Parse filter properties file. @param propertiesFile properties file for variable substitution @param resource whether or not to load properties

This is a hook for the component to perform some actions just before the framework commits its state.

Lifecycle step that will be called after instantiating with nullary constructor.

This method is invoked at the startup of messaging plugin. @param topoConf storm configuration

Create metric store instance using the configurations provided via the config map. @param config Storm config map @param metricsRegistry The Nimbus d

Process insertion of worker metrics. The implementation should be thread-safe. @param conf the supervisor config @param metrics the metrics to proce

Removes ranking entries that have a count of zero.

Pull a set of keys out of a Configuration. @param topoConf The config containing the jaas conf file. @param section The app configuration entr

put list of task id to its queue. @param taskIds task ids that received the tuples