Releases promotion commit permit. @see #acquirePromotionPermit()

Returns a sink which publishes the items it receives to a distributed reliable topic with the specified name. <p> No state is saved to snapshot for th

Returns the number of items this pipe has still room for.

Returns a source that fetches entries from the Hazelcast {@code ICache} with the specified name in a remote cluster identified by the supplied {@code

Called when during establishing the initial connection, the remote side unexpectedly closes the network connection. <p> This can be triggered after an

Returns a sink equivalent to {@link #map}, but for a map in a remote Hazelcast cluster identified by the supplied {@code ClientConfig}. <p> <strong>NO

Returns a sink that puts {@code Map.Entry}s it receives into a Hazelcast {@code IMap} with the specified name in a remote cluster identified by the su

Returns a sink equivalent to {@link #mapWithEntryProcessor}, but for a map in a remote Hazelcast cluster identified by the supplied {@code ClientConfi

Returns a sink which publishes the items it receives to a distributed reliable topic with the provided name in a remote cluster identified by the supp

Removes the plan from the cache, decreasing the size. @param plan Plan.

Removes the given member from this bit set. @param member the member to remove. @return {@code true} if this storage became empty as a result of the

Removes the given member from this storage. @param member the member to remove. @return {@code null} if this storage became empty as a result of the

Removes the current {@code activeMigration} if the {@code migration} is the same and returns {@code true} if removed.

Removes all record stores from all partitions. Calls {@link #removeRecordStoresFromPartitionMatchingWith} internally and @param onShutdown

Removes a child with the given name if exists @param name The name of the child to remove

Removes the association between the given value and a record identified by the given record key. <p> Despite the name the given value acts as a key in

Removes listener from underlying IMap @param mapName underlying map name which query cache listens @param cacheId ID of the query cache @param

Removes all record stores inside the supplied partition ID matching with the supplied predicate. @param predicate only matching record-sto

Removes the registration matching the {@code topic} and {@code ID}. Returns the removed registration or {@code null} if none matched. @param topic th

Stops delivering all events to the listener with the given registration id. @return Whether the specified registration was removed @throws Unsupporte

Removes all WAN event counters for the given {@code serviceName} and {@code dataStructureName}. @param serviceName the name of the service for

Removes write-behind-queue-reservation-counters inside supplied partition from matching record-stores. @param predicate only matching record-stores

Removes write-behind-queue-reservation-counters inside supplied partition from matching record-stores.

Returns the number of items removed from this pipe since creation.

Replaces a direction in the collation trait of the rel @param rel the rel @param direction the collation @return the rel with changed collation

Some parts of the example file don't actually resolve, which needs to be post-processed before inflation

Returns the integer replica indices of {@code InternalPartition} as a stream.

ReliableTopic is built on top of RingBuffer. This method determines if 'publish' operation is actually called on ReliableTopic and reports the statist

ReliableTopic is built on top of RingBuffer. This method determines if 'read' operation is actually called on ReliableTopic and reports the statistics

Returns a tuple of: <ol> <li> a future that will be completed when the execution completes (or a completed future, if execution is not RUNNING or

Re-schedules {@link ClearExpiredRecordsTask}, if it has been scheduled at least one time before. This info is important for the methods: {@link #state