extract a list of host port info for specified component. @param exec2hostPort {executor -> host+port} @param task2component {task id -> component}

Extract Maven coordinates from 'mvn dependency:list' output. Lines like: ' com.google.code.findbugs:jsr305:jar:3.0.2 -- module jsr305 (auto)'

Fail an unsuccessfully handled message by its {@link JmsMessageID}. <p>Failing means dropping all pending messages and queueing a recovery attempt.

Download the latest version to a temp location. This may also include unzipping some or all of the data to a temp location. PRECONDITION: this can onl

Remove topologies from local state which are older than cutOffAge.

This makes sure every message sent by the producers are received by this consumer.

Find the _Fields constant that matches fieldId, throwing an exception if it is not found.

Find the _Fields constant that matches fieldId, throwing an exception if it is not found.

Find the _Fields constant that matches fieldId, throwing an exception if it is not found.

Find the _Fields constant that matches fieldId, throwing an exception if it is not found.

Find the _Fields constant that matches fieldId, throwing an exception if it is not found.

Find the _Fields constant that matches fieldId, throwing an exception if it is not found.

Find the _Fields constant that matches fieldId, throwing an exception if it is not found.

Given a list of constructor arguments, and a target class, attempt to find a suitable constructor.

Use recursive descent to detect cycles. This is a Depth First recursion. Component Cycle is recorded when encountered. In addition, the last link in t

Given a `java.lang.Object` instance and a method name, attempt to find a method that matches the input parameter: `java.util.Map` or `org.apache.storm

Find a which topology is running on a worker slot. @return the topology using the worker slot. If worker slot is free then return null

This is triggered to signal the end of the current batch of values. Sub classes can override this to emit the result of a batch of values, for e.g. to

if(batchSz>1) : Blocking call. Does not return until at least 1 element is drained or Thread.interrupt() is received if(batchSz==1) : NO-OP. Returns

Blocking call - Does not return until at least 1 element is drained or Thread.interrupt() is received. Uses backpressure wait strategy.

Asynchronously writes the message batch to the channel. <p>If the write operation fails, then we will close the channel and trigger a reconnect.

Makes a directory, including any necessary but nonexistent parent directories. @param path the directory to create @throws IOException on any error

Free all slots on this node. This will update the Cluster too.

frees a single executor. @param exec is the executor to free @param topo the topology the executor is a part of

Free one-fifth of WorkerSlots.

Free one-fifth of WorkerSlots.

Free one-fifth of WorkerSlots.

Frees all the slots for a topology. @param topId the topology to free slots for @param cluster the cluster to update

Free the bound-ackers for the given node and workerSlot. All the bound-ackers for an executor (and only that executor) are on the same workerSlot. @p

Create an output stream from a config. @param conf the config to read from. @return the read OutputStream.

Creates a SlowExecutorPattern from a Map config. @param conf the conf to parse. @return the corresponding SlowExecutorPattern.

Create an output stream from a config. @param conf the config to read from. @return the read OutputStream.

Parse a String config value and covert it into the enum. @param conf the string config. @return the parsed grouping type or SHUFFLE if conf is null. @

Parse the TopologyLoadConf from a file in YAML format. @param file the file to read from @return the parsed conf @throws IOException if there is an is

Deserializes the given map into a TopicPartition. The map keys are expected to be those produced by {@link #toMap(org.apache.kafka.common.TopicPartiti

Generate a new random secret key. @return the new key