Returns a new stream where the values that arrive within a window having the same key will be reduced by repeatedly applying the reducer. @param redu

Prepare the emitter to handle the input partitions.

It may be helpful to register these meters up front, so they are output even if their values are zero. @param registry The metrics registry.

Register a process' handle.

Restart the processes in this container. PREREQUISITE: cleanUpForRestart has run and passed @throws IOException on any error

Decide when/if to release blacklisted hosts. @param cluster the current state of the cluster. @param blacklistedNodeIds the current set of blacklisted

Get the assignment based on storm id from remote state store, eg: ZK. @param stormId topology id @param callback callback function @return {@link As

Remove all of the worker keys for a given topology. Used to clean up after a topology finishes. This is expected to only ever be called from nimbus a

Remove backpressure. Note: In Storm 2.0. Retained for enabling transition from 1.x. Will be removed soon.

Add --rm option. @return the self

Remove all keys for the given topology that have expired. The number of keys should be small enough that doing an exhaustive scan of them all is accep

supervisor or port never exits once in tolerance time will be removed from cache.

Renames files with .inprogress suffix. @return path of renamed file @throws if operation fails

report the node id to this strategy to help to decide {@code isReady}. @param nodeId the node id from reported SupervisorWorkerHeartbeats

This function should be used prior to starting the worker to reserve resources for the worker. @param workerId worker id of the worker to start @para

Resets the singleton instance to the default. This is helpful to reset the class to its original functionality when mocking is no longer desired.

Resets the singleton instance to the default. This is helpful to reset the class to its original functionality when mocking is no longer desired.

Resets the singleton instance to the default. This is helpful to reset the class to its original functionality when mocking is no longer desired.

Resolve dependencies and return downloaded information of artifacts. @param dependencies the list of dependency @return downloaded information of art

Used by SaslTokenMessage::processToken() to respond to server SASL tokens. @param token Server's SASL token @return token to send back to the server.

resume supervisors form blacklist. Blacklist is just a temporary list for supervisors, or there will be less and less available resources. This will b

Retrieves all values of all static fields of {@link Config} which represent all available configuration keys through reflection. The method assumes th

Retrieves values from Redis that each value is corresponding to each key. @param state State for handling query @param keys keys having state values

Retrieves values from Redis that each value is corresponding to each key. @param keys keys having state values @return values which are corresponding