Returns a {@link Duration} corresponding to the the given value in seconds. @param seconds the number of seconds @return the Duration

Seek the consumer to offset corresponding to startTimeStamp.

Send load metrics to all downstream connections. @param taskToLoad a map from the task id to the load for that task.

Send sampled data to the eventlogger if the global or component level debug flag is set (via nimbus api).

Start the server. @param port the port it shuld listen on, or null/<= 0 to pick a free ephemeral port.

Mark the assignments as synced successfully, see {@link IStormClusterState#isAssignmentsBackendSynchronized()}.

Client facing API to set a nimbus client. @param conf storm conf @param client NimbusClient @return indicates where the client connection has been

Turn on/off debug for this component. @param debug true for debug on false for debug off @return this for chaining

Sets expire (time to live) if needed. @param expireIntervalSec time to live in seconds

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

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

Set permission of log file so that logviewer can serve the file. @param fileName log file

Sets list of node. @param nodes list of node @return Builder itself

Set extra commands and args. It can override the existing commands. @param overrideCommandWithArgs the extra commands and args @return the self

Setter of proxy if needed. @param proxyParam proxy object