Creates an instance of the pluggable SerializationDelegate or falls back to DefaultSerializationDelegate if something goes wrong. @param topoConf The

Create the transport factory needed for serving. All subclass must implement this method. @param impersonationAllowed true if SASL impersonation sho

Get shared memory. @return the shared memory region requests

Get shared memory. @return the shared memory requests for the entire group

Gets the Short field with a specific name. @throws ClassCastException If that field is not a Short @throws IllegalArgumentException - if field

Returns the sliding count for count based windows. @return the sliding count

Scans the event queue and returns the list of event ts falling between startTs (exclusive) and endTs (inclusive) at each sliding interval counts. @pa

The sliding interval of the window. @return the sliding interval

Sort executors such that components with more constraints are first. A component is more constrained if it has a higher number of incompatible compone

Gets the declared inputs to the specified component. @return A map from subscribed component/stream to the grouping subscribed with.

getSpoutAggStatsMap. @param componentAggregateStats componentAggregateStats @param window window @return getSpoutAggStatsMap

getSpoutExecutorStats. @param topologyId topologyId @param config config @param executorAggregateStats executorAggregateStats @return getSpoutExecutor

getSpoutExecutors. @param executorSummaries executorSummaries @param stormTopology stormTopology @return getSpoutExecutors.

getSpoutOutputStats. @param streamId streamId @param componentAggregateStats componentAggregateStats @return getSpoutOutputStats

Get the checksum of the source. @return the checksum of the source.

getStatDisplayMap. @param rawDisplayMap rawDisplayMap @return getStatDisplayMap

Returns null if it was created, the value otherwise.

Get all topology scheduler statuses.

Create a map of forward edges for bolts in a topology. Note that spouts can be source but not a target in the edge. The mapping contains ids of spouts

Get instance of {@link IWorkerHeartbeatsRecoveryStrategy} with conf. @param conf strategy config @return an instance of {@link IWorkerHeartbeatsRecove

Get a set of SubSystemType objects from a comma delimited list of subsystem names.

The id used for writing metadata into ZK.

Get log link to supervisor log. @param host supervisor host name @param config storm config @return log link.

getSupervisorPageInfo. @param supervisorPageInfo supervisorPageInfo @param config config @return getSupervisorPageInfo

getSupervisorSummary. @param supervisors supervisor summary list. @param securityContext security context injected. @param config Storm config. @retur

Get a copy of the map (for diagnostics). @return a clone of the map or null for none known

Get the amount of free memory in MB. This might not be the entire box, it might be within a parent resource group. @return The amount of memory in MB