This function either returns the blob in the existing cache or if it doesn't exist in the cache, it will download the blob and will block until the do

Get the port for this connection. @return The port this connection is using

Rollback a prepared transaction to the previously committed state.

Provide an instance of this class for delegates to use. To mock out delegated methods, provide an instance of a subclass that overrides the implement

Add in request for shared memory that this component will use. See {@link SharedOnHeap}, {@link SharedOffHeapWithinNode}, and {@link SharedOffHeapWith

This is intended for internal testing only. @return an internal class that holds the state of the cluster.

Returns the first value in a pair. @return the first value

Get all of the topologies. @return all of the topologies that are a part of the cluster.

Creates a new {@link Stream} of tuples from the given {@link IRichSpout}. @param spout the spout @return the new stream

Returns a subset of the tuple based on the fields selector.

send batch messages.

Set the amount of CPU load for this component. @param amount the amount of CPU @return this for chaining

URL encode the given string using the UTF-8 charset. Once Storm is baselined to Java 11, we can use URLEncoder.encode(String, Charset) instead, which

get the current assignment for the topology.

Get the set of all executors. @return the executors covered by this assignments

Get the mapping of slot to executors on that slot. @return the slot to the executors assigned to that slot.

Get a list of paths of all the child nodes which exist immediately under path. @param path The path to look under @param watch Whether or not to set

## Grouping Operation.

Parse a flux topology definition from a classpath resource.. @param resource YAML resource @param dumpYaml if true, dump the parsed YAM

Tracks the event and could use this to invoke the trigger. @param event the input event

Decide the equivalence of two local assignments, ignoring the order of executors This is different from #equal method. @param first Local assignment

Given a topology definition, return a populated `org.apache.storm.Config` instance. @param topologyDef topology definition @return a Storm Config obje

Given a topology definition, return a Storm topology that can be run either locally or remotely. @param context execution context @return A runable St

Creates sequential dummy records @param <K> The Kafka key type @param <V> The Kafka value type @param topic The topic partition to create records for

Get value for key. Error if value is null or not the expected type.

The entire stream goes to a single one of the bolt's tasks. Specifically, it goes to the task with the lowest id.

Returns true if field aze is set (has been assigned a value) and false otherwise

Returns true if field id is set (has been assigned a value) and false otherwise

Given a tuple, return the key that should be written to the sequence file.

Converts stats to be over given windows of time. @param stats the stats @param secKeyFunc transform the sub-key @param firstKeyFunc transform the main

aggregate count streams by window. @param stats a Map of value: {win -> stream -> value} @return a Map of value: {win -> value}

Deletes the node at a given path, and any child nodes that may exist. @param path The path to delete

Determine the list of racks on which topologyIds have been assigned. Note that the returned set may contain {@link DNSToSwitchMapping#DEFAULT_RACK} if

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

@see TopologyStatus

Gets the storm.local.hostname value, or tries to figure out the local hostname if it is not set in the config. @return a string representation of the

Get all of the tuples from a given component on the default stream. @param results the results of running a completed topology @param componentId the

Set the value of the node at path to data. @param path The path whose node we want to set. @param data The data to put in the node. @param acls The a

Shutdown. @deprecated use {@link #close()} instead

Return a Map of the normalized resource name to a double. This should only be used when returning thrift resource requests to the end user.

Returns a stream of aggregated results based on the given window configuration which uses inmemory windowing tuple store. @param windowConfig windo

Assign the slot to the executors for this topology. @throws RuntimeException if the specified slot is already occupied.

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

Racks are sorted by two criteria. <p>1) the number executors of the topology that needs to be scheduled is already on the rack in descending order. T

Get the total CPU on this supervisor in % CPU.