Shutdowns <tt>NodeExtension</tt>. Called on <tt>Node.shutdown()</tt> right before setting the state to SHUT_DOWN.

Returns a supplier of processors for a vertex that aggregates events into session windows. Events and windows under different grouping keys are treate

Returns true if all replicas of a partition are lost

Respond to a {@link WhoisMasterOp}. @param joinMessage the {@code JoinMessage} from the request. @param connection the connection to operation calle

{@inheritDoc} @return {@code this} instance

Applies this function to the given arguments. @param t0 the first argument @param t1 the second argument @param t2 the third argument @return the fun

Applies the {@code partitionState} sent by the {@code sender} if the new state is newer than the current one and finalizes the migrations. This method

Arranges the partition layout. <p> This method does not actually change the partitions, but send back the updated layout. <p> A two-dimensional array

Represents the given {@link Number} exactly as a double value without any magnitude and precision losses; if that's not possible, fails by throwing an

Represents the given {@link Number} exactly as an int value without any magnitude and precision losses; if that's not possible, fails by throwing an e

See {@link #newLightJob(Pipeline, JobConfig)} for details.

Represents the given {@link Number} exactly as a long value without any magnitude and precision losses; if that's not possible, fails by throwing an e

Adapts a {@code Set<DeferredValue<V>>} as a {@code Set<V>}. Operations on the returned set pass through to the original {@code deferredValues} set. @

Returns set based on the given {@link Collection} of {@link MetricTarget}s and one other to include in the returned set. Set objects are returned from

Takes a generic {@link YamlNode} instance and returns it cast to the provided {@code type} if the node is an instance of that type. @param node The g