Calculate the average resource usage percentage with this being the total resources and used being the amounts used. Used must be a subset of the tota

Calculate the minimum resource usage percentage with this being the total resources and used being the amounts used. Used must be a subset of the tota

If who is null then we want to use the user hadoop says we are. Required for the supervisor to call these routines as its not logged in as anyone.

This function implements a custom stream grouping. It takes in as input the number of tasks in the target bolt in prepare and returns the tasks to sen

Clean up the container. It is not coming back. by default do the same thing as when restarting. @throws IOException on any error

Called when an IBolt is going to be shutdown. Storm will make a best-effort attempt to call this if the worker shutdown is orderly. The {@link Config#

Note: We do not defensively copy the object wrapped by the Rankable. It is passed as is. @return a defensive copy

Process the input tuple and optionally emit new tuples based on the input tuple. <p>All acking is managed for you. Throw a FailedException if you wan

Free the specified slot. @param slot the slot to free

Get an approximate total resources needed for this topology. ignores shared memory. @return the approximate total resources needed for this topology.

Returns the end time if set, returns the current time otherwise.

Get the hostname substituted hdfs principal. @param conf the storm Configuration @return the principal @throws UnknownHostException on UnknowHostExcep

Get the whitelist of users and groups for given file. @param fileName file name to get the whitelist

Returns the reference time that the eviction policy could use to evict the events. In the case of event time processing, this would be the watermark t

Returns the global stream id (component + stream) of this tuple.

get the priority of this topology.

@see LogLevelAction

If given path is a dir, make it a wildcard so the JVM will include all JARs in the directory.

Checks whether user is authorized to access file. Checks regardless of UI filter. @param user username @param fileName file name to access. The file

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

Get max size. @return the maximum possible number (size) of ranked objects this instance can hold

A count based tumbling window. @param count the number of tuples after which the window tumbles

The code to execute when the {@link TriggerPolicy} condition is satisfied. @return true if the window was evaluated with at least one event in the wi

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

Read a topology conf. @param topoId the id of the topology to read the conf for @param who who to read it as @return the deserialized config. @throws

Removes a reservation for this blob from a given slot and assignemnt. @param pna the slot + assignment that no longer needs this blob. @return false

Checks to see if the local blob requires update with respect to a remote blob. @param blobStore the client blobstore @param remoteBlo

Returns instance to container. @param redisCommands borrowed instance

Schedule specified number of threads. The threads are not executed in the order in which they call {@link StormTimer#schedule(int, Runnable)}. Just ch

Send worker heartbeat to local supervisor @param heartbeat