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

Return runtime state to be checkpointed by the framework for restoring the trigger policy in case of failures. @return the state

Factory method that creates a Builder with String key/value deserializers. @param bootstrapServers The bootstrap servers for the consumer @param topi

Deletes the value mapped to the key, if there is any. @param key the key

Process a single tuple of input. The Tuple object contains metadata on it about which component/stream/task it came from. The values of the Tuple can

This aggregator operation computes the minimum of tuples in a stream by using the given {@code comparator} with {@code TridentTuple}s. @param compara

Map a supervisor to a given host. @param supervisorId the id of the supervisor @return the actual host name the supervisor is on

Validate all confs in map. @param conf map of configs

Parse a String to the type you want it to be. @param value the String to parse @return the parsed value

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

Creates nodes for path and all its parents. Path elements are separated by a "/", as in nix filesystem notation. Equivalent to mkdir -p in nix. @para

This method is called when a worker is started and can be used to do necessary prep-processing and allow initialization of shared application state.

Submit a tracked topology to be run in local mode. @param topologyName the name of the topology to use @param conf the config for the topolog

Get the set of all slots that are a part of this. @return the set of all slots.

Gets the field with a specific name. Returns object since tuples are dynamically typed. @throws IllegalArgumentException - if field does not exist

Set the base config that the daemons should use.

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

Registers a callback function that gets called when CuratorEvents happen. @param callback is a clojure IFn that accepts the type - translated to cloj

Gets the id of the stream that this tuple was emitted to.

poll() is a core feature of ShellBoltMessageQueue. It retrieves and removes the head of one queues, waiting up to the specified wait time if necessary

Close the metric store.

Takes one additional parameter numaZonesPerHost. This parameter determines how many supervisors will be created on the same host. If numaResourceMulti

Returns the String at position i in the tuple. @throws ClassCastException If that field is not a String @throws IndexOutOfBoundsException - if

@see HBServerMessageType

Get the data from the node at path @param path The path to look under @param watch Whether or not to set a watch on the path. Watched paths emit eve

Run with simulated time. @deprecated use ``` try (Time.SimulatedTime time = new Time.SimulatedTime()) { ... } ``` @param code what t

Reference to nimbus. @return Nimbus itself so you can interact with it directly, if needed.

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

Get component id. @return the component id for this task. The component id maps to a component id specified for a Spout or Bolt in the topology de

Gets the task id of this task. @return the task id

Gets all the values in this tuple.

Called after the HdfsBolt performs a sync.

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

Emits a tuple to a Stream. @param values a list of values of which the tuple will be composed

Checks if a throwable is an instance of a particular class. @param klass The class you're expecting @param throwable The throwable you expect to

The stream is partitioned by the fields specified in the grouping.

Get the nimbus configuration.

Removes a message from the list of messages scheduled for retrial. @param msgId message to remove from retrial @return true if the message was schedul