This method is called when one of the methods of the {@link com.hazelcast.core.EntryListener} is not overridden. It can be practical if you want to bu

This method is called when an one of the methods of the {@link com.hazelcast.core.EntryListener} is not overridden. It can be practical if you want to

Cancels executions that contain the leaving address as the coordinator or a job participant

Notifies the {@link ClusterTopologyIntentTracker} that Hazelcast members list has changed.

When an <code>OutOfMemoryError</code> is caught by Hazelcast threads, this method is called for ALL <code>HazelcastInstance</code>s knows by current J

Called when a new record is added to the {@link RecordStore} @param key The key of the record @param record The record with new value @param o

Calls the partition replica change interceptor for all changed replicas. @return {@code true} if partition owner change was detected, otherwise {@code

Called when a new record is added to the {@link RecordStore} due to replication @param key The key of the record @param record The r

Called when the observed {@link RecordStore} is being reset.

Sets the provided {@link ClassLoader} as this thread's {@link ThreadLocal} loader instance, to be used for Namespace aware class loading. <p> @implNot

Called before a thread stops to clean/release injected by {@link #onThreadStart(Thread)}. @param thread thread stopping

Called when a new record is updated in the observed {@link RecordStore} @param key The key of the record @param record The record with the new

@see <a href="https://github.com/kubernetes/apimachinery/blob/master/pkg/watch/watch.go"> Watch Event Specification</a>

This is a variant of {@link #operateOnKey(Data)} which is used during scan. The differences are: <ol> <li>It gets value from the scan, so does not

Tries to optimize the provided Selector. @param selector the selector to optimize @return an FastSelectionKeySet if the optimization was a success, n

Performs the order-and-limit operation on this result for the given paging predicate. @param pagingPredicate the paging predicate to perform the o

Overrides the {@link ClientMetricsConfig} in the provided {@link ClientConfig} with the metrics system properties if present. See the {@link ClientMet

Creates a ZIP-file stream from the directory tree rooted at the supplied {@code baseDir}. Copies the stream into the provided output stream, closing i

@param parameters event parameters. Must not be {@code null} @return this instance

Parses string representation of a capacity. Value may end with one of suffixes; <ul> <li>'k' or 'K' for 'kilo',</li> <li>'m' or 'M' for 'mega',</li> <

Adds an aggregate to the query, that for each document will calculate {@code document._id.getTimestamp().getTime() MOD totalParallelism == processorIn

Invoked when a primary replica of the partition is lost. Node failures that do not involve a primary replica do not lead to partition lost events. @p

Pauses WAN replication for the given {@code wanReplicationName} and {@code wanPublisherId} on this hazelcast instance. Silently skips publishers not s

Peeks in the CircularQueue. So returns the first item without removing it. If the CircularQueue is empty, null is returned. @return the first item or

After this call, {@link #currentRow} will return the next entry to emit. They are set to null, if there's no row available because we're either done o

Retrieves, but does not remove, the head of this queue, or returns {@code null} if this queue is empty. Loads the data from the queue store if the ite

Persists any dynamically changeable sub configuration to this member's declarative configuration. Preserves file format of the existing dynamic config

Returns aggregated job and execution metrics. @implNote {@linkplain JobCoordinationService#completeJob When terminal metrics are requested}, job and

The suspicion level of the accrual failure detector. If a connection does not have any records in failure detector then it is considered healthy.

Returns an aggregate operation whose result is an arbitrary item it observed, or {@code null} if it observed no items. <p> The implementation of {@lin