Gets the dependencies listed in LICENSE-binary

Fills up chunks out of a collection (given a maximum amount of chunks). <p>i.e. partitionFixed(5, [1,2,3]) -> [[1,2,3]] partitionFixed(5, [1..9]) ->

Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as they are consumed from the

Populate the Storm RequestContext from an servlet request. This should be called in each handler @param request the request to populate

Populates a given context with credentials information from an HTTP request. @param req the servlet request @return the context

post aggregate component stats: 1. computes execute-latency/process-latency from execute/process latency total 2. computes windowed weight avgs 3. tra

This method will be called when nimbus initializes. @param conf the cluster config

Invoked once immediately after construction. @param type the type of connection this will process. @param topoConf Storm configuration

Called when initializing the service. @param conf the storm cluster configuration.

Invoked once immediately after construction. @param topoConf Storm configuration

Invoked once immediately after construction. @param topoConf Storm configuration

Invoked once immediately after construction. @param topoConf Storm configuration

Tells the stream grouping at runtime the tasks in the target bolt. This information should be used in chooseTasks to determine the target tasks. <p>I

This is invoked from {@code org.apache.storm.trident.planner.TridentProcessor}'s prepare method. So any initialization tasks can be done before the t

Initial function for creating backend. @param conf config

Called after the filter is instantiated. @param config A map of the properties from the 'filter' section of the reporter configuration.

Allows us to initialize the blob store. @param conf The storm configuration @param baseDir The directory path to store the blobs @param nimb

initialize data structures. @param conf storm confs

Invoked once immediately after construction. @param topoConf Storm configuration

Prepares the metric processor. @param config Storm config map @throws MetricException on error

Function to prepare the strategy. @param conf config

Called once during nimbus initialization.

Function for initialization. @param conf config

Prepare this State. @param options The KafkaProducer config.

Initialize instance variables as the first step in {@link #schedule(Cluster, TopologyDetails)}. This method may be extended by subclasses to initializ

Initialize subsystems.

Print contents of the files. Used for dumping the actual and expected DEPENDENCY-LICENSES files. :param msg: message to print about the files

Process a single non-tick tuple of input. Implementation needs to handle ack manually. More details on {@link org.apache.storm.task.IBolt#execute(Tupl

Invokes handleCheckpoint once checkpoint tuple is received on all input checkpoint streams to this component.

Process includes contained within a yaml file. @param yaml the yaml parser for parsing the include file(s) @param topologyDef the topology def

Performs the actual metric insert, and aggregates over all bucket times. @param metric Metric to store @throws MetricException if database write fa

Send worker metrics to Nimbus.

Get process PID. @return the pid of this JVM, because Java doesn't provide a real way to do this.