@param <I> type of the input object. @return an aggregator that calculates the min of the input values. Accepts null input values and null extracted v

Returns a projection that converts the {@link EventJournalMapEvent} to a {@link java.util.Map.Entry} using the event's new value as a value. @see Sou

Returns a supplier of processors for a vertex that performs a stateful mapping of its input. {@code createFn} returns the object that holds the state.

Returns a sink that uses the supplied key-extracting and value-updating functions to update a Hazelcast {@code IMap}. For each item it receives, it ap

{@code Serializable} variant of {@link BinaryOperator#maxBy(Comparator) java.util.function.BinaryOperator#maxBy(Comparator)}. @param <T> the type of t

Returns the index of the member among all the members that run this job: it's a unique cluster-wide index. <p> The value is in the range {@code [0...m

Returns the minimum ProbeLevel this MetricsRegistry is recording.

@return Returns a human-readable identifier of the configuration source.

Returns the name of the associated metric.

Creates new instance of {@link KafkaConsumer} based on the DataConnection configuration. Always creates a new instance of the consumer because {@link

Start the new Hazelcast instance. @param awaitAssignment whether to wait for a partition assignment to a new member @return created instance

See {@link ClassLoaderUtil#newInstance(ClassLoader, String)}. Exceptions are sneakily thrown.

Creates a {@link LoggerFactory logger factory} instance of the given preferred type. <p> The type of the created logger factory doesn't necessarily ma

Returns a {@code VectorValues} object suitable for supplying a single vector to a {@code VectorCollection} configured with one vector index. @param v

Notify the producer about an error. @param error Error.

Called when an execution is completed with an error. @param t the exception that is thrown

Called when a record is loaded into the observed {@link RecordStore} @param key The key of the record @param record The record @param backup {@cod

Invoked when a message is received for the topic. Note that the topic guarantees message ordering. Therefore, there is only one thread invoking onMess

Observes the next event from the {@link Observable} it is registered with. <p> Although the {@code Observable} respects the order of events published

@return a packed integer representation of this Version

Returns the parent of the given node @return the parent node if exists, <code>null</code> otherwise

Returns a file format for Parquet files. <p> <strong>NOTE:</strong> this format is supported only through the Hadoop connector.

Returns list of Partitioning Attribute names if the corresponding map uses AttributePartitioningStrategy, otherwise returns an empty list. Note that a

Add an element to the beginning of an iterator. @param prepend element to add. @param iterator the iterator to which an element will be added. A null

Returns the slice of partitions for this processor. It distributes {@link #memberPartitions()} according to the {@link #localParallelism()} and {@link

Publish the given metric with a double value.

Writes the boolean value as volatile to given object by its offset. @param address address to access @param x the boolean value to be written

Writes the byte value as volatile to given object by its offset. @param address address to access @param x the byte value to be written

Puts the given int value as ordered to the CPU write buffer based in the given object at the given offset. @param address address to access @param x

Puts the given long value as ordered to the CPU write buffer based in the given object at the given offset. @param address address to access @param

Extends Pipeline stage with ability to call Python user-defined functions @return extension implementation

Reads one item from the ringbuffer. This method is not destructive unlike e.g. a {@code queue.take}. So the same item can be read by multiple readers,

Reads an array of 16-bit two's complement signed integers. <p> This method can also read an array of nullable int16s, as long as it does not contain {

Reads a nullable array of nullable 16-bit two's complement signed integers. <p> This method can also read array of non-nullable int16s. @param fieldN