Prepare for a new assignment by downloading new required blobs, or going to empty if there is nothing to download. PRECONDITION: The slot should be em

Record a specific latency. @param latency what we are recording

Performs a reduction on the values for each key of this stream by repeatedly applying the reducer. @param reducer the reducer @return the new stream

Reload and return the configs. @return reloaded configs. It can't be null.

The {@link RemovalListener} to be invoked when entries are evicted. @param listener the listener @return the builder

request ID of this request.

Send supervisor worker heartbeats for a specific supervisor @param heartbeats

Set the aggLevel.

Sets password. @param password password, if any @return Builder itself

client address.

Set the timestamp field name for event time based processing. @param fieldName the timestamp field name

setTopologyProfilingAction. @param client client @param id id @param hostPort hostPort @param timestamp timestamp @param config config @param profileA

Specifies whether the spout should require Storm to track emitted tuples when using a {@link ProcessingGuarantee} other than {@link ProcessingGuarante

@see HBServerMessageType

This method is called right before a worker shuts down.

Returns the number of fields in this collection.

Get size. @return the number (size) of ranked objects this instance is currently holding

Get IDs stored in blob store. @return a set of all of the topology ids with special data stored in the blob store.

Get the list of streams this translator will handle. @return the list of streams that this will handle.

Submit a tracked topology to be run in local mode. @param topologyName the name of the topology to use @param conf the config for the topolog

Go through all executors and time them out if needed. @param topoId the id of the topology to look at. @param taskTimeoutSecs the timeout to

Convert to a map that is used by configuration and the UI. @return a map with the key as the resource name and the value the resource amount.

Get a lock on file if not already locked. @param dir the dir on which to get a lock @return The lock object if it the lock was acquired. Returns nul

Unpin an entry from the cache so that it can be a candidate for eviction. @param key the key @return true if the entry was unpinned, false otherwise

Validate topology blobstore map. @param topoConf Topology configuration

Validates topology name. @param name the topology name @throws IllegalArgumentException if the topology name is not valid

Utility method to help verify that no tuples were passed through the RedisFilterBolt.

Utility method to help verify that a tuple passed throught hte RedisFilterBolt properly. @param expectedTuple The tuple we expected to pass through th

Add the resources in other to this. @param other the other Request to add to this.