Creates a new {@link WanPublisher} by the given name. If the name already exists, returns the previous instance. @param name name of the WAN replicat

Sets the filter that decides which document in the collection is equal to processed document. @param fieldName field name in the collection, that will

@param <I> type of the input object. @return an aggregator that calculates the max of the input values. Accepts null input values. Accepts only Intege

Invokes the {@code operation}, blocks and returns the result of the invocation. If the member on which this method is invoked is a lite member, the op

Client instance creation won't block on {@link HazelcastClient#newHazelcastClient()} if this value is true @return if client connects to cluster asyn

Checks if the MultiMap is in binary (serialized) form. @return {@code true} if the MultiMap is in binary (serialized) form, {@code false} otherwise

@param client to check if allowed through current ClientSelector. <p> Note: Management Center clients ({@lin

Returns {@code true} if the client is not yet connected or the connection was already closed.

Returns whether the default serialization filters are disabled. @return {@code true} if defaults are disabled, {@code false} otherwise

Returns {@code true} if native memory allocation is enabled, {@code false} otherwise.

Signals to the query engine that this predicate is able to utilize the indexes available while executing the query in the given query context. @param

Returns true if CP ISemaphore is compatible with its JDK counterpart

Queries and returns if this member in a safe state or not. <p> This method just checks for a safe state, it doesn't force this member to be in a safe

Returns {@code true} when grant permissions should take precedence over deny ones. Default value is {@code false}. @since 5.4

@return if {@link #types} are all {@link Class#isPrimitive()}

@param itemId the item ID @return true if itemId is greater than 0

Checks if the option is supported. @param option the option @return true if supported, false otherwise @throws NullPointerException if option is <cod

If {@code true}, this cache entry listener implementation will be called in a synchronous manner. @return {@code true} if this cache entry listener i

@param version other version to compare to @return {@code true} if this version is unknown or if this version is greater than or equal to {@code versi

Regular regex rules are applied. see String.matches @param labelMask of the clients that will be selected @return client selector according to label

Returns the last heartbeat timestamp for the tracked member. @return heartbeat timestamp in milliseconds

Sets the event {@link Level}. The default value is {@link Level#INFO}. @return this instance

Returns list of {@link DataConnectionResource}s accessible via this DataConnection. <p> It is not strictly required that the data connection lists all

@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

Looks up the User Code Namespace name associated with the specified cache name. This is done by checking the Node's config tree directly. @param engi

Returns a supplier of processors for a vertex which, for each received item, emits the result of applying the given mapping function to it. The mappin

Returns the maximum number of records that can be accumulated by any single {@link Processor}. The returned value is strictly positive (>=1).

Returns the number of members running this job. <p> Note that the value might be lower than current member count if members were added after the job s

Creates a new partition predicate that restricts the execution of the target predicate to a subset of partitions. @param partitionKeys the partition

Column name. This is the name that is seen in SQL queries.

Creates a plain transaction object which can be used while cluster state is {@link ClusterState#PASSIVE}, without wrapping it inside a TransactionCont

Creates a new {@code InternalCompletableFuture} that delegates to the given {@code future} and deserializes its completion value of type {@link Data}.

Returns the next possible capacity, counting from the current buffers' size.

Offers an item to this collector. If the collector cannot complete the operation, the call must be retried later.

{@inheritDoc}

Called synchronously when partition state (partition assignments, version etc.) changes

Called when an execution is completed successfully. @param response the result of the successful execution

Parks the Operation until it is unparked by a {@link #unpark(Notifier)} call or by a timeout specified by the {@link BlockingOperation#getWaitTimeout(

Returns a meta-supplier that wraps the provided one and adds a logging layer to each processor it creates. For each item the wrapped processor adds to

Adds the serialization configuration for the used {@link Portable} domain object to the given {@link SerializationConfig}. @param serializationConfig