Returns the last emitted watermark.

Returns a supplier of processors for the second-stage vertex in a two-stage group-and-aggregate setup. Each processor applies the {@link AggregateOper

Compares the given {@link EntryView} instances and returns the result. <p> The result should be one of: <ul> <li>-1: first entry has higher priority

Compares if the queue contains the items in the dataList and removes them according to the retain parameter. If the retain parameter is true, it will

{@code Serializable} variant of {@link Comparator#comparingLong(ToLongFunction) java.util.Comparator#comparingLong(ToLongFunction)}. @param <T> the t

Called after the edge input with the supplied {@code ordinal} is exhausted. If it returns {@code false}, it will be called again before proceeding to

Completes and cleans up execution of the given job

Sets the function that will be called after all the upstream stages have completed and all the items were received. <p> This function is optional. @p

Returns config to configure a SINGLE_MEMBER routing client that connects to the given instance only.

Triggered when an {@code IOException} is thrown during establishing network connection to a member address. This can happen due to a closed port or wh

Constructs the path of the node with the provided {@code parent} node and {@code nodeName}. @param parent The parent node @param childName The nam

Matches a {@link Measurement} which contain the specified tag. @param tag the tag of interest @return a filtering predicate

Returns a supplier of processors for a source that the user can create using the {@link SourceBuilder}. This variant creates a source that emits items

Converts a JsonValue object to its corresponding Java object. Type mappings are as shown below <ul> <li>{@link com.hazelcast.internal.json.JsonStr

Convert a literal taking into account the type that we assigned to it during validation. Otherwise Apache Calcite will try to deduce literal type agai

Copies the clientMessage efficiently with correlation id Only initialFrame is duplicated, rest of the frames are shared @param correlationId new id @

Creates the task. @param partitionId the partitionId of the partition this task is going to run on @return the created task. The r

Uses the Hazelcast ServiceLoader to discover all registered {@link NodeExtension} classes and identify the one to instantiate and use as the provided

Simulates creation of a mapping for class that was later unloaded.

Creates an implementation of the {@link ClientEngine} depending on Hazelcast edition. @return a new {@link ClientEngine} instance for this member

From the postponeTimeMap create the equivalent condition for the join processor. <p> For example, this join condition (`l` has `time1` and `time2` col

Creates a {@link DefaultCacheEntryView} instance. @param key the key to be wrapped @param value the value to be wrapped @param record {@

Creates a distributed object on the local member only (when {@code local} is {@code true}), else cluster-wide. @param objectName the name for the cre

In graceful shutdown, we are flushing all unsent events in an {@code Accumulator}. This event will be the last event of an {@code Accumulator} upon fl

Creates additional extension services, which will be registered by service manager during start-up. <p> By default, returned map will be empty. @retu

Creates an operation for fetching a segment of a entries from a single partition. @see com.hazelcast.map.impl.proxy.MapProxyImpl#iterator(int, int, b

Creates an operation for fetching a segment of a query result from a single partition. @see com.hazelcast.map.impl.proxy.MapProxyImpl#iterator(int, i

Given a list of input field names and a list of output field names creates a projection to map between these. <p> For example, if input names are {@co

Creates an OperationRunner to execute generic Operations. @return the created OperationRunner