Checks whether user is allowed to access a Logviewer file via UI. Always true when the Logviewer filter is not configured. @param fileName file name

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

Forwards the result update to downstream processors. Processors that operate on a batch of tuples, like aggregation, join etc can use this to emit the

List the contents of a directory. @param dir the driectory to list the contents of @param filter a filter to decide if it should be included or no

Create a new topology that writes random UUIDs to Kafka. @param brokerUrl Kafka broker URL @param topicName Topic to which publish sentences @return

Returns a {@link Count} of given value. @param value the count value @return the Count

## Repartitioning Operation.

Get value from the cache or load the value pinning it so that the entry will never get evicted. @param key the key @return the value

Invoked once immediately after construction. @param conf Storm configuration

Prettify uptime string. @param sec uptime in seconds. @return prettified uptime string.

Get an input stream for reading a part. @param key the key of the part to read @return the where to read the data from @throws IOException on any err

The real principal associated with the subject.

Produces a result value out of the accumulator. @param accum the accumulator @return the result

Retains all the messages whose {@link TopicPartition} belongs to the specified {@code Collection<TopicPartition>}. All messages that come from a {@lin

run the testing logic with the cluster. @param cluster the cluster which created by <code>Testing.withSimulatedTimeLocalCluster</code> and <co

Run the command, this will be called at most once.

Get the base path where secret keys are stored for a given service. @param type the service we are interested in. @return the path to that service ro

Sets port. @param port port @return Builder itself

@see ProfileAction

Creates an ephemeral node at path. Ephemeral nodes are destroyed by the store when the client disconnects. @param path The path where a node will be

For a nested map, rearrange data such that the top-level keys become the nested map's keys and vice versa. Example: {:a {:X :banana, :Y :pear}, :b {:X

This method is invoked when a worker is unloading a messaging plugin.

Updates the last updated time. This should be called when references are added or removed.

Execute cb with a configured nimbus client that will be closed once cb returns. @param cb the callback to send to nimbus. @throws Exception on any kin

Have the local nimbus actually launch a thrift server. This is intended to be used mostly for internal storm testing.

Adjust the image config for the topology. If OCI container is not supported, remove the oci image setting from the topoConf; otherwise, set it to the

aggregate a list of count maps into one map. @param countsSeq a seq of {win -> GlobalStreamId -> value}

Calculate the average percentage used. @see NormalizedResources#calculateAveragePercentageUsedBy(org.apache.storm.scheduler.resource.normalization.Nor

A stream grouped this way means that the producer of the tuple decides which task of the consumer will receive this tuple.

Encode key. @param key the value of key (K type) @return the encoded value of key (KENCODEDT type)

Check if a file exists or not. @param path the path to check @return true if it exists else false @throws IOException on any error.

Pull a the value given section and key from Configuration. @param topoConf The config containing the jaas conf file. @param section The app c

Gets the declared output fields for the specified component/stream.

Get the date/time the build happened. @return the date/time of the build.