RestHighLevelClient supplier, it is used to used as a parameter of {@link ElasticSourceBuilder#clientFn(SupplierEx)}

Returns the set of key-value pairs in the multimap. <p> <b>Warning:</b> The collection is <b>NOT</b> backed by the map, so changes to the map are <b>N

Executes an operation in the operation executor pool. @param op the operation to execute in the operation executor pool.

Runs the test and expects an exact sequence of input and output items. The output must occur in the expected order given by the {@code testEvents} par

Logs a message at the {@link Level#FINE} level. @param message the message to log

@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 gen

@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 gen

Returns size (capacity) of the native memory region.

Returns a proxy for an {@link ICountDownLatch} instance created on CP Subsystem. Hazelcast's {@link ICountDownLatch} is a distributed version of <tt>j

Returns the Persistence Encryption at Rest configuration. @return the Encryption at Rest configuration

Returns the data type used to store entries. <p> Possible values: <ul> <li>{@code BINARY}: keys and values are stored as binary data</li> <li>{@code O

Returns the configuration for tracking use of this Hazelcast instance.

@return read only set of all labels of this client. @since 3.12

Returns the maximum concurrent invocations supported. Integer.MAX_VALUE means there is no max. @return the maximum concurrent invocation.

Returns initialized {@link MemcacheProtocolConfig} for the node.

Gets the list of message listeners (listens for when messages are added or removed) for this topic. @return the list of message listeners for this to

@return number of misses of Near Cache entries owned by this member

Returns the name of the task. The name will be used to uniquely identify the task in the scheduler service, if a duplicate is detected a {@link Duplic

@return a {@code HazelcastInstance} to drive a test; if several test drivers are configured, this method will rotate and return the next one.

Returns the outbound edges connected to the vertex with the given name.

Returns the Secure Store configuration. @return the Secure Store configuration

Returns the service name for this object. @return the service name for this object.

Gets the {@link SocketInterceptorConfig}. The value can be {@code null} if no socket interception is needed. @return the SocketInterceptorConfig @see

Returns the current value of this PN counter

A function that calculates the index (e.g. to be used in an array/list) for a given hash. The returned value will always be equal or larger than 0 and

Returns if the persistent memory is enabled. @return {@code true} if persistent memory allocation is enabled, {@code false} otherwise.

Returns the preserve order property of this pipeline @since Jet 4.4

Creates a <b>less than or equal to</b> predicate that will pass items if the value stored under the given item {@code attribute} is less than or equal

Loads all keys into the store. This is a batch load operation so that an implementation can optimize multiple loads. <p><b>Interactions with the map

Creates a new {@link AsyncServerSocketBuilder}. <p/> This method is thread-safe. @return the created AsyncSocketBuilder. @throws IllegalStateExceptio

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

Returns the type of change this record describes (insert, delete or update). Some special events, like heartbeats, don't have an operation value. @re

Returns a supplier of processors for {@link Sources#map(String)}.

Replaces the first occurrence of the oldValue by the newValue. <p> If the item is found, a new array is returned. Otherwise, the original array is ret

Called when a batch of items is received during the "restore from snapshot" operation. The type of items in the inbox is {@code Map.Entry}, key and va

Enables or disables the Tcp/Ip join mechanism. @param enabled {@code true} to enable the Tcp/Ip join mechanism, {@code false} to disable @return TcpI

Atomically sets the max value. <p> If the current value is larger than the provided value, the call is ignored. So it will not happen that a smaller v

Sets the predicate of {@code QueryCache}. @param predicateConfig config for predicate @return this {@code QueryCacheConfig} instance

Sets the execution timeout in milliseconds. <p> If the timeout is reached for a running statement, it will be cancelled forcefully. <p> Zero value mea

Submit the given {@code task} to be executed concurrently by {@code concurrency} number of threads. The given {@code task} must be thread-safe, as the

Maps the entire element to an instance of the specified class. <p> Parsing is based on <a href="https://github.com/FasterXML/jackson-jr"> Jackson jr</

Transmits a packet to a certain address. <p> If the connection to the target doesn't exist yet, the system will try to make the connection. In this ca

Returns the length of the window (the size of the timestamp range it covers). It is an integer multiple of {@link #frameSize()}.