mkAccessLoggingFilterHandle. @return mkAccessLoggingFilterHandle

Make an map of executors to empty stats, in preparation for doing a heartbeat. @param executors the executors as keys of the map @return and empty map

This response data only includes a next byte offset if there is more of the file to read.

Create the command to launch the worker process. @param memOnheap the on heap memory for the worker @param stormRoot the root dist dir for the topolo

Intended to be overridden for tests. Make the producer with the given props

Get the command to run when doing profiling. @param action the profiling action to perform @param stop if this is meant to stop the profiling

Move fromDir to toDir, and try to make it an atomic move if possible. @param fromDir what to move @param toDir where to move it from @throws IOExce

Moves a file to a given destination. @param fromFile file to move @param toFile where to move it @throws IOException on any error

Create the Storm config. @return the Storm config for the topology that publishes random UUIDs to Kafka using a Kafka bolt.

Returns a new state instance. Each state belongs unique namespace which is typically the componentid-task of the task, so that each task can have its

Creates a new topology that prints inputs to stdout. @param tridentSpout The spout to use

Get an assignments from the target queue with the specific index. @param queueIndex index of the queue @return an {@link NodeAssignments}

Invoke when lost leadership.

When a new actions is executed for a topology, this method will be called.