@param registrationId The registrationId of the listener to be removed. @return true if successfully removed, false otherwise.

Removes a PartitionLostListener. <p> If the same PartitionLostListener is registered multiple times, it needs to be removed multiple times. <p> This m

Removes the record for a key. @param key the key to the entry. @return the removed record if one exists.

Removes all registrations for the specified topic and notifies the listeners and service of the listener deregistrations. @param topic the topic for

Atomically replaces the entry for a key only if currently mapped to some value. <p> This is equivalent to <pre><code> if (cache.containsKey(key)) {

Checks if this Transaction needs to be prepared. <p> Preparing a transaction costs time since the backup log potentially needs to be copied and each l

Reset the lastLogTime to `now` and number of occurrences since last log to 0

Resets migrating flag.

Resets the overridden number of available processors to {@link Runtime#availableProcessors()}. <p> This is to be used only for testing.

Reset the sectionLevel. A proper rendering of a plugin should always return this value to -1; but in case of an exception while rendering, the section

If clientConfig is {@code null}, the client configuration is loaded using the resolution logic as described in {@link HazelcastClient#newHazelcastClie

Returns a string where named placeholders are replaced by values from the given {@code variableValues} map. The placeholder is defined as the variable

Restore watermark value from state snapshot. <p> Method is meant to be used from {@link Processor#restoreFromSnapshot(Inbox)}. <p> See {@link #getWate

Retrieves and disposes the result with the given taskId @param taskId combination of partitionId and sequence @param <T> the type of the task's re

Convenience for {@link #s3(List, String, Charset, SupplierEx, BiFunctionEx)}. Emits lines to downstream without any transformation and uses {@link Sta

Convenience for {@link #s3(String, String, Charset, SupplierEx, FunctionEx)} Uses {@link Object#toString()} to convert the items to lines.

Configures given IMap to fail on indeterminate operation state. @param map map to configure @return the same map with applied configuration

Schedules a task to be processed by this Scheduler. @param task the task.

Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the given period. Executions wi

Sends a remote event to the {@code subscriber}. Each event segment keeps track of the published event count. On every {@link #eventSyncFrequency} the

Sends a split brain join request to the target address and checks the response to see if this node should merge to the target address.

Sets the item at the given sequence ID and updates the expiration time if TTL is configured. Unlike other methods for adding items into the ring buffe

Sets the first value.

Sets the second value.

Sets all the values in this stats to the corresponding values in the given on-demand stats. @param onDemandStats the on-demand stats to fetch the val

Sets how far to the future is the generator allowed to go to generate IDs without blocking. <p> The number of bits configured for the sequence number

It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t

It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t

It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t

It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t

It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t

It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t

It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t

Sets the average hit latency to the given value. @param averageHitLatency the average hit latency value to set.

Sets the average hit selectivity to the given value. @param averageHitSelectivity the average hit selectivity value to set.

@param azureConfig the AzureConfig join configuration to set @throws IllegalArgumentException if azureConfig is null