Returns true if field jsonConf is set (has been assigned a value) and false otherwise

Returns true if field location is set (has been assigned a value) and false otherwise

Returns true if field meta is set (has been assigned a value) and false otherwise

Returns true if field named_logger_level is set (has been assigned a value) and false otherwise

Returns true if field shared_memory is set (has been assigned a value) and false otherwise

Returns true if field stats is set (has been assigned a value) and false otherwise

Returns true if field storm_version is set (has been assigned a value) and false otherwise

Returns true if field topology is set (has been assigned a value) and false otherwise

Returns true if field topology_version is set (has been assigned a value) and false otherwise

Returns true if field uploadedJarLocation is set (has been assigned a value) and false otherwise

Returns true if field window is set (has been assigned a value) and false otherwise

Returns true if field worker_hooks is set (has been assigned a value) and false otherwise

If the target bolt has one or more tasks in the same worker process, tuples will be shuffled to just those in-process tasks. Otherwise, this acts like

The maximum cache size. After this limit, entries are evicted from the cache. @param size the size @return the Builder

Normalizes a supervisor resource map or topology details map's keys to universal resource names. @param resourceMap resource map of either Supervisor

Called when a task for this component is initialized within a worker on the cluster. It provides the spout with the environment in which the spout exe

Called during the initialization of the kafka spout. @param conf The storm configuration. @param context The {@link TopologyContext}

Construct a new topology structure after adding system components and streams. WARNING: while changing the existing code to add or remove streams for

Convert a Principal to a local user name. @param principal the principal to convert @return The local user name.

Helper function to add a constraint specifying two components that cannot co-exist. Note that it is redundant to specify the converse. @param comp1 f

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

Called when a spout has been deactivated. nextTuple will not be called while a spout is deactivated. The spout may or may not be reactivated in the fu

Gets the properties that will be passed to the KafkaConsumer. @return The Kafka properties map

Get the slot to resource mapping. @return The slot to resource mapping

Get the total amount of cpu. @return the amount of cpu.

Get how long this topology has been executing.

Returns true if field debug_options is set (has been assigned a value) and false otherwise

Returns true if field dependency_artifacts is set (has been assigned a value) and false otherwise

Returns true if field dependency_jars is set (has been assigned a value) and false otherwise

Returns true if field principal is set (has been assigned a value) and false otherwise

Returns true if field resources is set (has been assigned a value) and false otherwise

Returns true if field storm_version is set (has been assigned a value) and false otherwise

Filters out fields from a stream, resulting in a Stream containing only the fields specified by `keepFields`. <p>For example, if you had a Stream `my

Release lock on dir by deleting the lock file.

Start the policy. Useful in case of policies like timed rotation where the timer can be started.

Set the number of slots/ports each supervisor should have.

Release Container.

Run a topology to completion capturing all of the messages that are emitted. This only works when all of the spouts are instances of {@link org.apach

Creates the blob. @param key Key for the blob @param meta Metadata which contains the acls information @param who Is the subject creating the blob

Execute a {@link Callable} as the given {@link Subject}, equivalent to {@code Subject.callAs(subject, callable)} on Java 18+ or {@code Subject.doAs(su

Returns the task ids that received the tuples.

Returns defined additional key. @return additional key

Construct a JAAS configuration object per storm configuration file. @param topoConf Storm configuration @return JAAS configuration object

Reference to metrics registry. @return The metrics registry for the local cluster.

The returned defensive copy is only "somewhat" defensive. We do, for instance, return a defensive copy of the enclosing List instance, and we do try

Gets the index of this task id in getComponentTasks(getThisComponentId()). An example use case for this method is determining which task accesses whic