get the resources requirements for a executor. @param exec executor details @return a map containing the resource requirements for this exec

Gets a map from task id to component id.

Gets the declared input fields for this component. @return A map from sources to streams to fields.

Gets the declared output fields for the specified stream id for the component this task is a part of.

Gets the declared output fields for all streams for the component this task is a part of.

Gets all the task ids that are running in this worker process (including the task for this task).

Get the topics string. @return A human-readable string representing the topics that pass the filter.

Create and configure the topology.

getTopologyBoltAggStatsMap. @param componentAggregateStats componentAggregateStats @param boltId boltId @return getTopologyBoltAggStatsMap

Get topology history. @param topologyHistory from Nimbus call. @return map ready to be returned.

getTopologyLag. @param userTopology userTopology @param config config @return getTopologyLag.

getTopologyMap. @param topologySummary topologySummary @return getTopologyMap

Return topology owner from worker meta file. @param metaFile metadata file

getTopologyProfilingDump. @param client client @param id id @param hostPort hostPort @param config config @return getTopologyProfilingDump @throws TEx

getTopologyProfilingDumpHeap. @param client client @param id id @param hostPort hostport @param config config @return getTopologyProfilingDumpHeap @th

getTopologyProfilingRestartWorker. @param client client @param id id @param hostPort hostPort @param config config @return getTopologyProfilingRestart

getTopologyProfilingStart. @param client client @param id id @param hostPort hostPort @param timeout timeout @param config config @return getTopologyP

getTopologyProfilingStop. @param client client @param id id @param hostPort hostPort @param config config @return getTopologyProfilingStop @throws TEx

getTopologySpoutAggStatsMap. @param componentAggregateStats componentAggregateStats @param spoutId spoutId @return getTopologySpoutAggStatsMap

getTopologyStatsMap. @param topologyStats topologyStats @return getTopologyStatsMap

Get the max heap size for a worker used by this topology. @return the worker max heap size

getTopologyWorkers. @param topologyInfo topologyInfo @param config config @return getTopologyWorkers.

Get the total memory reserved. @param withUpdatedLimits the local assignment with shared memory @return the total memory reserved.

Get the total memory used (on and off heap).

Get the number of workers for this topology.

Try and guess at the actual number of messages emitted per second by a trident topology, not the number of batches. This does not work on an anonymize

Return {@code TridentTuple}s from given {@code tupleEvents}.

Returns a {@code TriggerPolicy} by creating with {@code triggerHandler} and {@code evictionPolicy} with the given configuration.

If the number of machines is limited, then truncate the node list to this maximum number of nodes that have no other topologies running on it. If the