Set --workdir option. @param workdir the working directory @return the self

Use cfs_period & cfs_quota to control the upper limit use of cpu core e.g. If making a process to fully use two cpu cores, set cfs_period_us to 100000

Set the number of cpus to use. @param cpus the number of cpus @return the self

Sets database index. @param database database index @return Builder itself

Set default stream outputFields, this method is called from YAML file: <p/> ``` spouts: - className: org.apache.storm.flux.wrappers.bolts.FluxShellSpo

Set default stream outputFields, this method is called from YAML file: <p/> ``` bolts: - className: org.apache.storm.flux.wrappers.bolts.FluxShellBolt

Sets dimensions to be used for reporting on the next batch of metrics. @param dimensions dimensions valid for use in the next scheduled report.

Sets the "distributed" mode of this spout. <p>If <code>true</code> multiple instances of this spout <i>may</i> be created across the cluster (dependi

Specifies if the spout should emit null tuples to the component downstream, or rather not emit and directly ack them. By default this parameter is set

set the environment for the command. @param env Mapping of environment variables

Sets the executor-level data for the given name. This data is shared amongst tasks and corresponding task hooks managed by the given executor. @param

Specifies the group id. @param groupId the group id

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 implementa

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 the JmsMessageProducer used to convert tuples into JMS messages.

Set the JmsProvider used to connect to the JMS destination topic/queue.

Set the last login time. @param time the number of milliseconds since the beginning of time

Sets leader elector (only used by LocalFsBlobStore to help sync blobs between Nimbi.

Set the login object.

Set the max task parallelism for this component. @param val the maximum parallelism @return this for chaining

Set the number of memory in MB to use. @param memoryMb the number of memory in MB @return the self

The time period that metrics data in bucketed into. @param metricsTimeBucketSizeInSecs time in seconds

Set custom named stream outputFields, this method is called from YAML file: <p/> ``` spouts: - className: org.apache.storm.flux.wrappers.bolts.FluxShe

Set custom named stream outputFields, this method is called from YAML file: <p/> ``` bolts: - className: org.apache.storm.flux.wrappers.bolts.FluxShel

Set --net option. @param type the network type @return the self

Set no-new-privileges option. @return the self

Set the pluggable sorter for Nodes. @param nodeSorter to use for sorting nodes when scheduling.

Set the parallelism of this component, and adjust the throughput so in aggregate it stays the same. @param newParallelism the new parallelism to set.

Add --read-only option. @return the self

Sets the reserved memory for the given port and topology id. @param port The worker port @param topologyId The topology id @param reservedMemoryMb Th

Set --security-opt option. @param jsonPath the path to the json file @return the self

Configure ZooKeeper Client with SSL/TLS connection. @param zkClientConfig ZooKeeper Client configuration @param x509Util The X509 utility @param sslCo

Specifies the startTimeStamp if the first poll strategy is TIMESTAMP or UNCOMMITTED_TIMESTAMP. @param startTimeStamp time in ms