Registers the {@link AggregateOperation3#accumulateFn2() accumulate} primitive for stream-2, returning the arity-3 variant of the builder. @param acc

Only Clients that can pass through filter are allowed to connect to cluster. Only one selector can be active at a time. Applying new one will override

Sequentially search through an array, return the index of first {@code needle} element in {@code haystack} or -1, if not found.

Converts client-config xml string to {@link ClientConfig} using {@link XmlClientConfigBuilder}.

Returns this JSON value as a <code>double</code> value, assuming that this value represents a JSON number. If this is not the case, an exception is th

@return a read only iterator. @throws UnsupportedOperationException

Assert that the attribute value for an MBean in the local platform server equals the expected value at least once in a series of query retries. We per

Checks if a HazelcastInstance created with config2, can be added to a HazelcastInstance created with config 1. <p> This method expects that an Illegal

Asserts the number of Near Cache invalidation requests (triggered invalidation events and local invalidations). @param context the given

Checks if objects in database matches listed rows.

Asserts that a text protocol client call to given {@link TestUrl} returns an expected response.

Uses the supplied ID to look up a file you attached to the current Jet job. Creates a temporary file with the same contents on the local cluster membe

Returns the attribute map. <p> Attribute map can be used to store data into a socket. For example to find the Connection for a Channel, one can store

Sets the base directory where the Python files reside. When you set this, also set the name of the {@link #handlerModule handler module} to identify t

Returns either a local Hazelcast instance or a "bootstrapped" Hazelcast client for a remote Hazelcast cluster, depending on the context. The main goal

Converts given time in millisecond of unix epoch to BsonTimestamp.

Returns the initial hash map capacity needed for the expected map size. To avoid resizing the map, the initial capacity should be different from the e

Calls the passed {@link Callable} within the {@link ClassLoader} context of the passed {@link Object}'s own {@link ClassLoader} as defined by {@code O

Rethrow exception of the fist future that completed with an exception @throws Exception

Check if the sequence can be read from the ringbuffer or if the sequence is of the next item to be added into the ringbuffer. This method also allows

Check should be used during the optimized IMapByKey plan construction. It throws {@link QueryException} of query is analyzed for optimized IMapByKey p

Checks the merge policy configuration aligns with {@link MapConfig}. @param mapConfig the {@link MapConfig} @param mergePolicyClassName cl

Throws an {@link MutationDisallowedException} if this CRDT has been migrated.

Checks if the vector clock of this PN counter state is causally before the given {@code lastReadVectorClock}. @param lastReadVectorClock vector clock