Check if this node is the owner of a partition. @param partitionId the partition ID @return {@code true} if the node owns the partition, {@code false

Checks if the ReliableMessageListener should be terminated based on an exception thrown while calling {@link #onMessage(Message)}. @param failure the

Unwraps input objects if they are arrays or lists and adds all to an output list.

Loads all the keys from the store. The returned {@link Iterable} may return the keys lazily by loading them in batches. The {@link Iterator} of this {

@param <I> type of the input object. @return an aggregator that calculates the max of the input values extracted from the given attributePath and retu

@param attributePath the attribute path @param <I> type of the input object. @return an aggregator that calculates the min of the input values extract

Generates the next unique call ID. When the implementation supports backpressure, it will not return unless the number of outstanding invocations is w

Returns the {@link AsyncSocketOptions} of this AsyncSocket. @return the AsyncSocketOptions.

Writes the given short value to given address. @param address the address where the short value will be written to @param x the short value to

Reads a list from the given {@link ObjectDataInput}. It is expected that the next int read from the data input is the list's size, then that many obje

Replicates the schema to the cluster. <p> If the schema is known to be already replicated, it returns immediately. <p> If not, it initiates the proces

Prepares an empty {@link HttpURLConnection#HTTP_OK} response.

Set true for non-blocking {@link HazelcastClient#newHazelcastClient()}. The client creation won't wait to connect to cluster. The client instance will

Sets the connection timeout. This is the maximum amount of time Hazelcast will try to connect to a well known member before giving up. Setting it to a

Sets the {@code EventJournalConfig} for this {@code MapConfig} @param eventJournalConfig event journal config @return this {@code MapConfig} instance

Configures the output for the diagnostics. The default value is {@link DiagnosticsOutputType#FILE} which is a set of files managed by the Hazelcast pr

Transactional implementation of {@link IMap#size()}. @see IMap#size()

Returns the definition of a sliding window of length {@code windowSize} that slides by {@code slideBy}. Given {@code windowSize = 4} and {@code slideB

The ID of current successful snapshot. If {@link #NO_SNAPSHOT} then no successful snapshot exists.

Returns an unbounded (event stream) source that will use the supplied function to create processor meta-suppliers as required by the Core API. Jet wil

Adds items of the collection. Faster than {@code collection.stream().mapToInt(toIntF).sum()} and equal to plain old loop in performance. Crates no GC

Factory method for providing {@link ConfigSupplier} instances for the given config class @param cls class of the config we're looking for @param <T>

Returns a file format for text files where the whole file is a single string item. It uses the UTF-8 character encoding.

Returns the total size of Data in bytes. <p> The total size is the size of a byte array to contain the full content of this data object. For example i

Create a new instance to execute a jar on the member

Writes a primitive char. @param fieldName name of the field @param value int value to be written @throws IOException in case of any exceptional c

Adds the supplied value to this accumulator, allowing integer overflow. This removes the (tiny) overhead of overflow checking.

Adds a Distributed Object listener which will be notified when a new {@link DistributedObject} will be created or destroyed. @param distributedObject

Adds an entry listener for this multimap. <p> The listener will be notified for all multimap add/remove/update events. @param listener entry list

Adds the initial offset for given partition to the configuration. @param partition the number of partition @param offset the initial offset for th

Registers the {@link AggregateOperation#exportFn() export} primitive. <p> The given function must be stateless and {@linkplain Processor#isCooperative

Registers the {@link AggregateOperation#finishFn() finish} primitive. Constructs and returns an {@link AggregateOperation1} from the current state of

@see org.assertj.core.api.AbstractLongAssert#isBetween(Long, Long)

Converts a JSON string to an object of the given type. {@link #toBean(Class)} is a more secure alternative. @see #toBean(Class)

Object name to derive CREATE MAPPING SQL for.

Executes the given query on the given target. @param query query to execute @param target target where to execute the query @param <T> Type of th

Releases the lock for the specified key regardless of the lock owner. It always successfully unlocks the key, never blocks, and returns immediately. <

Gets data and prepares for next compression cycle.