Creates a UUID for local member @return new UUID

Creates the {@link NearCacheTestContext} with only a Near Cache instance used by the Near Cache tests. @param <K> key type of the created {@link com.

Create map from member ID to owned partitions. @param nodeEngine node engine @param localMemberVersion version of the local mem

Creates a reference to the configured data connection @param name name of the data connection configured in {@link DataConnectionConfig} @return the

Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline. @param name the name of this source, mu

Decrements the current value by 1.

Returns the depth of this pattern. @return the depth of this pattern

Deregisters an invocation. If the associated operation is inactive, takes no action and returns {@code false}. This ensures the idempotency of deregis

The <code>stop</code> method is used to stop internal services, sockets or to destroy any kind of internal state.

The <code>start</code> method is called on system startup to implement simple lifecycle management. This method is expected to call {@link DiscoverySt

Removes the currently set {@link NodeEngine} reference for this thread.

Disposes the result with the given taskId @param taskId combination of partitionId and sequence

@return a measure of the difference of this versus given {@code partitionTableView}.

Returns a predicate that can be applied as a filter to a non-parallel {@link Stream} to remove items that have duplicate key. <p> Don't use in paralle

Declares that you're creating a distributed source. On each member of the cluster Jet will create as many processors as you specify with the {@code pr

Performs expiration and evicts expired records.

Drains a batch of items from the queue at the supplied index to the supplied {@code itemHandler}. Stops draining, after the {@code itemHandler} return

Acquires and returns all permits that are available at invocation time. @return the number of permits drained

Creates an empty {@code MemberMap}. @return empty {@code MemberMap}

Retrieves POD addresses for all services in the specified {@code namespace} filtered by {@code podLabels} and {@code podLabelValues}. @param podLabel

Retrieves POD addresses for all services in the specified {@code namespace} filtered by {@code serviceLabels} and {@code serviceLabelValues}. @param

Tries to add public addresses to the endpoints. <p> If it's not possible, then returns the input parameter. <p> Assigning public IPs must meet one of

Ensures that the minimum cluster size property is satisfied (for the purpose of split brain detection) for the given operation. First checks if the sp

Returns a file path string that replaces Windows `\\` file separators with the Unix equivalent `/` if the current machine is using Windows as its Oper

Invoked upon addition of an entry. @param event the event invoked when an entry is added

Invoked upon removal of an entry. @param event the event invoked when an entry is removed

Intention to expose the entry set is to mutate it. @return set of invocations in this registry

Returns a lazy {@link Set} view of the mappings contained in this map.<br> A LazySet is optimized for querying speed (preventing eager deserialization