Finds oldest expired lock file (using modification timestamp), then takes ownership of the lock file. Impt: Assumes access to lockFilesDir has been ex

Like {@link #needsScheduling(TopologyDetails)} but does not take into account the number of workers requested. This is because the number of workers i

Notify the tracker upon new arrivals. @param count number of arrivals

## Repartitioning Operation.

Creates messages for the input offsets, emits the messages by calling nextTuple once per offset and returns the captured message ids @param <K> The Ka

Called to populate the credentials on the client side. @param credentials the credentials to be populated.

Read a topology. @param topoId the id of the topology to read @param who who to read it as @return the deserialized topology. @throws IOException on a

Record BP for a task. <p>This is called by transferLocalBatch() on NettyWorker thread @return true if an update was recorded, false if taskId is alr

Remove this assignment/port as blocking resources from being cleaned up. @param assignment the assignment the resources are for @param port the

Sets the retry service for the spout to use. <p>This setting only has an effect if the configured {@link ProcessingGuarantee} is {@link ProcessingGua

## Repartitioning Operation. <p>Use random round robin algorithm to evenly redistribute tuples across all target partitions.

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

Validates the image setting in the daemon conf. This will be skipped if {@link DaemonConfig#STORM_OCI_ALLOWED_IMAGES} not configured. @param conf the

In a "real" cluster (or an integration test), Storm itself would ensure that a topology's workers would only be activated once all the workers' connec

Get all of the supervisors with the ID as the key.

Build the URL. the key and value of query parameters will be encoded. @param urlPath URL except query parameter @param parameters query parameter @re