If aggStats are not populated, compute common and component(spout) agg and create placeholder stat. This allow the topology page to show component spe

add task to cgroup. @param taskid task id of task to add

queue up for leadership lock. The call returns immediately and the caller must check isLeader() to perform any leadership action. This method can be c

Add a new topology config. @param topoId the id of the topology @param who who is doing it @param topoConf the topology conf itself @throws Authorizat

Add a topology to the pool. @param td the topology to add

Add a new topology. @param topoId the id of the topology @param who who is doing it @param topo the topology itself @throws AuthorizationException if

Add received batch of tuples to cache/store and add them to {@code WindowManager}.

aggregate windowed stats from a bolt executor stats with a Map of accumulated stats.

aggregate number executed and process & execute latencies.

Combines the aggregate stats of one executor with the given map, selecting the appropriate window and including system components as specified.

aggregate component executor stats. @param exec2hostPort a Map of {executor -> host+port} @param task2component a Map of {task id -> component} @par

pre-merge component page bolt stats from an executor heartbeat 1. computes component capacity 2. converts map keys of stats 3. filters streams if nece

pre-merge component page spout stats from an executor heartbeat 1. computes component capacity 2. converts map keys of stats 3. filters streams if nec

pre-merge component stats of specified bolt id. @param beat executor heartbeat data @param window specified window @param includeSys whethe

pre-merge component stats of specified spout id and returns { comp id -> comp-stats }.

aggregate windowed stats from a spout executor stats with a Map of accumulated stats.

Aggregates number acked and complete latencies.

A helper function that does the common work to aggregate stats of one executor with the given map for the topology page.

Aggregates the values in this stream using the aggregator. This does a global aggregation of values across all partitions. <p> If the stream is window

Aggregate the stats for a component over a given window of time.

aggregate spout stats. @param statsSeq a seq of ExecutorStats @param includeSys whether to include system streams @return aggregated spout stats: {

aggregate all spout streams. @param stats a Map of {metric -> win -> stream id -> value} @return a Map of {metric -> win -> aggregated value}

Create a new version of this topology with identifiable information removed. @return the anonymized version of the TopologyLoadConf.

Are any of the non cpu resources positive. @return true of any of the non cpu resources are positive. False if they are all <= 0.

Applies the `Assembly` to a given {@link org.apache.storm.trident.Stream}.

Check if worker tokens are supported by this transport. @return true if they are else false.

<p> Remove the head of unassigned ackers and attempt to assign it to a workerSlot as a bound acker. </p> @param node RasNode on which to sch

Pick out assignments for a specific host from all assignments. This could include multiple NUMA supervisors on an individual host. @param assignmentM

Pick out assignments for specific NodeId from all assignments. @param assignmentMap stormId -> assignment map @param nodeId supervisor node id

Check new assignments with existing assignments and determine difference is any. @param existingAssignments non-null map of topology-id to existing a

Backtrack to prior executor that was directly assigned. This excludes bound-ackers. @param execToComp map from executor to component. @param nodesFor

Informs the listener that a blob has changed and is ready to update and replace a localized blob that has been marked as tied to the life cycle of the

Checks if a blob exists. @param key blobstore key @param who subject @throws AuthorizationException if authorization is failed

Given the blob information returns the value of the workerRestart field, handling it being a boolean value, or if it's not specified then returns fals

Returns a list of LocalResources based on the blobstore-map passed in.