Convert the given input into physical input. @param rel Original input. @return Logical input.

Returns the JSON string for this value in its minimal form, without any additional whitespace. The result is guaranteed to be a valid input for the me

Acquires a permit if one is available, and returns {@code true} immediately. If no permit is available, returns {@code false} immediately. @return {@

Updates the locally observed CRDT vector clock atomically. This method is thread safe and can be called concurrently. The method will only update the

Waits default timeout ({@value #DEFAULT_TIMEOUT_MILLIS} ms) for closed connection. If the timeout is reached, the program run continues without except

Cannot be used in combination with {@link #withNodeContextDelegator}.

Writes a 16-bit two's complement signed integer. @param fieldName name of the field. @param value to be written.

Adds event to this accumulator. @param event event to add.

Id of the last started snapshot, phase 1.

Adds an event to this buffer and sets tail to the sequence of given event. @param event the event to be added.

Adds the {@link CPMapConfig} configuration. Name of the {@link CPMapConfig} could optionally contain a {@link CPGroup} name, like "myMap@group1". @si

Adds the cardinality estimator configuration. The configuration is saved under the config name, which may be a pattern with which the configuration wi

Adds an interface to the member group. Duplicate elements are ignored. @param ip the IP address of the interface @return the updated MemberGroupConfi

Adds a user-defined listener to a query-cache. This listener is registered as a local listener on subscriber side. @param mapName underlying IMap na

Adds a {@link MemberGroupConfig}. Duplicate elements are not filtered. @param memberGroupConfig the MemberGroupConfig to add @return the updated Part

Convenience method for adding {@code Namespace}s directly using a {@link UserCodeNamespaceConfig} instance. <p> This method will add the {@code Namesp

Adds a CachePartitionLostListener. <p> The addPartitionLostListener returns a registration ID. This ID is needed to remove the CachePartitionLostListe

@param fieldName name of the field that will be added to this class definition @param classDefinition class definition of the nested portable th

Adds the {@linkplain TopicConfig topic configuration}. The configuration is saved under the topic name.

Selects a member when all of the selectors succeed @param selectors {@link MemberSelector} instances to iterate @return a {@link MemberSelector} that

Determines for each processor instance the partition IDs it will be in charge of. The method is called separately for each edge, defined by {@code loc

Supports multiple nodes on the same host. Shards are distributed evenly across hosts (not nodes).

Decorate any {@link Runnable} with a {@link AutoDisposableTask} to destroy automatically after execution @param runnable The runnable task to be disp

Returns the current number of permits currently available in this semaphore. <p> This method is typically used for debugging and testing purposes. @r

Waits until the client is connected to cluster or the timeout expires. Does not wait if the client is already shutting down or shutdown. @param timeo

Generates combinations of parameters and outputs them in the horrible JUnit format

@param <I> type of the input object. @return an aggregator that calculates the sum of the input values. Does NOT accept null input values. Accepts onl

The maximum value that can be placed in a bucket.

The minimum value that can be placed in a bucket.

Builds and returns the {@link AggregateOperation}. Its result type is {@link ItemsByTag} containing all the tags you got from the {@link #add} method.

Returns a source that will stream the {@link EventJournalCacheEvent} events of a Hazelcast {@code ICache} with the specified name. By supplying a {@co

Returns a predicate for {@link Sources#cacheJournal} and {@link Sources#remoteCacheJournal} that passes only {@link CacheEventType#CREATED CREATED} an

Canonicalizes the given {@link Number} value for the purpose of a hash-based lookup. <p> The method accepts a {@link Comparable} instance and returns

Computes capacity delta for sorted int arrays.