Merges the state of a different replica into this CRDT. The merge method should not leave the CRDT in a failed state. @param other the CRDT to merge

if hot-restart-persistence: enabled="true" and persistence: enabled="false" => enable persistence (HR) and use the config from hot-restart-persistence

Merge the two HyperLogLog structures in one. Estimations from both are taken into consideration and the unified estimate should be similar to the dist

Set the function to merge the existing value with new value. <p> If the map already contains the key, it applies the given {@code mergeFn} to resolve

Update map with a merge function

Merges the state of this progress tracker with the given {@code ProgressState} enum member.

Specifies if the Json parser should accept json records spanning multiple lines. <p> The parser handles JSON records spanning multiple lines by defaul

Creates a {@code JobBuilder} for a new Jet job with {@link DAG} definition. @since 5.5

Creates new QueryOptimizer. The exact implementation depends on {@link HazelcastProperties}.

Creates a new EntryTaskScheduler that will run all second operations in bulk. Imagine a write-behind map where dirty entries will be stored in bulk. E

Transition to next state if not already there @throws IllegalStateException if transition is not allowed @throws NullPointerException if the {@code

Idempotent next step finder. @return next step or null if there is no next step. @implSpec This implementation always throws {@code UnsupportedOperat

Strongly typed alternative of {@link Iterator#next()} not to avoid boxing. @return the next long value.

Strongly typed alternative of {@link Iterator#next()} to avoid boxing. @return the next int value.

Remaining join filters that are not equi-joins. Column references in this condition apply to the joined row.

Return the set of options that are not sensitive to be displayed by querying {@code information_schema}.

Called after receiving a new watermark. @param queueIndex index of the queue on which the WM was received. @param wmValue the watermark value, it

Broadcasts an item to all sub-collectors, if any.

Called after cluster version is changed. @param newVersion the new version at which the cluster operates.

Called when the observed {@link ICacheRecordStore} is destroyed.

Callback invoked when the fetch operation is finished.

Notifies of a received heartbeat. This method is always invoked before {@link SplitBrainProtectionFunction#apply(Collection)} so the {@code SplitBrain

Specifies that the data traveling on this edge is ordered according to the provided comparator. The edge maintains this property when merging the data

Parse Memcache key into (MapName, Key) pair.

Invoked when owner and all backups of a partition are lost for a specific cache. @param event the event object that contains the cache name and lost