Generates DEPENDENCY-LICENSES in target/. The committed DEPENDENCY-LICENSES is not modified.

Generates DEPENDENCY-LICENSES in target. The committed DEPENDENCY-LICENSES is not modified.

Gets the dependencies for storm-dist/binary, plus the dependencies of storm-shaded-deps

getActiveAction. @param profileRequest profileRequest @param config config @param topologyId topologyId @return getActiveAction

getActiveProfileActions. @param client client @param id id @param component component @param config config @return getActiveProfileActions @throws TEx

Get the aggregation levels to search for.

Return a sorted set of paths that were written by workers that are now active.

Get the messages emitted per second in aggregate across all streams in the topology. @return messages per second.

Return a list of all log files from worker directories in root log directory.

Get all process handles.

Get all scheduled resources for node.

getAllTopologiesSummary. @param topologies topologies @param config config @return getAllTopologiesSummary

Gets the number of worker ports assigned to the given topology id on this supervisor. @param topologyId The topology id @return The number of worker

Used by {@link Supervisor} to fetch assignments when start up. @param conf config @param clusterState {@link IStormClusterState} @param node id of nod

Get the resources on the supervisor that are available to be scheduled. @param sd the supervisor. @return the resources available to be scheduled.

Returns the byte array at position i in the tuple. @throws ClassCastException If that field is not a byte array @throws IndexOutOfBoundsExcept

Gets the Byte array field with a specific name. @throws ClassCastException If that field is not a byte array @throws IllegalArgumentException -

Get blacklist by blacklist strategy. @param badSupervisorsToleranceSlidingWindow bad supervisors buffered in sliding window @param sendAssignmentFail

Get all of the hosts that are blacklisted. @return all of the hosts that are blacklisted

Client facing API to read the metadata information. @param key blob key name @return AtomicOutputStream returns an output stream into which data can

Gets the replication factor of the blob. @param key Key for the blob @param who Is the subject having the read privilege for the blob @return BlobRep

getBoltAggStatsMap. @param componentAggregateStats componentAggregateStats @param window window @return getBoltAggStatsMap

getBoltExecutorStats. @param topologyId topologyId @param config config @param executorAggregateStats executorAggregateStats @return getBoltExecutorSt

getBoltExecutors. @param executorSummaries executorSummaries @param stormTopology stormTopology @param sys sys @return getBoltExecutors.

getBoltInputStats. @param globalStreamId globalStreamId @param componentAggregateStats componentAggregateStats @return getBoltInputStats

getBoltOutputStats. @param streamId streamId @param componentAggregateStats componentAggregateStats @return getBoltOutputStats

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

Get the SCM branch of the build. @return the SCM branch of the build.

Get a descriptive representation of the build meant for human consumption. @return a descriptive representation of the build.

Get a descriptive representation of the build meant for human consumption. @return a descriptive representation of the build.

getBuildVisualization. @param client client @param config config @param window window @param id id @param sys sys @return getBuildVisualization @throw

Get the cgroup resources from the conf. @param conf the config to read @return the resources.

returns the total number of input checkpoint streams across all input tasks to this component.

Get parameters for the class path of the worker process. Also used by the log Writer. @param stormRoot the root dist dir for the topology @return th

Converts thrift call result into map fit for UI/api. @param clusterSummary Obtained from Nimbus. @param user User Making request @param conf Storm Con

Gets the location of the external resources for this worker on the local filesystem. These external resources typically include bolts implemented in o

Get the full command. @return the full command

Get the full command. @return the full command

Get the full command. @return the full command