Updates the accumulator by applying the current accumulator with the value. @param accumulator the current accumulator @param value the value @

Applies this function to the given argument. @param input the input to the function @return the function result

Translate the ConsumerRecord into a list of objects that can be emitted. @param record the record to translate @return the objects in the tuple. Retu

Applies an `Assembly` to this `Stream`. @see org.apache.storm.trident.operation.Assembly

Check if all the processes are dead. @param user the user that the processes are running as @param workerId the id of the worker to kill @return true

The container terminates if any process inside the container dies. So we only need to check if the initial process is alive or not. @param user the us

Currently it only checks if the container is alive. If the worker process inside the container dies, the container will exit. So we only need to check

Add a named argument. @param name the name of the argument. @return a builder to be used to continue creating the command line.

List all the storm runtime ids of local assignments. @return a list of storm ids

Get all the local assignments of local state. @return mapping of storm-id -> assignment

{@inheritDoc}

Parameters: - key

Parameters: - key

{@inheritDoc}

{@inheritDoc}