Returns the merging value in the in-memory format of the backing data structure. @return the merging value

Returns the event type. @return the event type

Returns a source that will stream {@link EventJournalMapEvent}s of the Hazelcast {@code IMap} with the specified name. By supplying a {@code predicate

Returns a consumer that does nothing. @param <T> the consumer input type

@param fieldName name of the field @return the float value read @throws IOException in case of any exceptional case

Reads a batch of items from the Ringbuffer. If the number of available items after the first read item is smaller than the {@code maxCount}, these ite

Sets the transaction durability. <p> The durability is the number of machines that can take over if a member fails during a transaction commit or roll

Gets the HazelcastInstance reference when submitting a Runnable/Callable using Hazelcast ExecutorService. @param hazelcastInstance the HazelcastInsta

Add a configuration for a {@link javax.cache.event.CacheEntryListener}. @param cacheEntryListenerConfiguration the {@link javax.cache.configuration.C

Adds the handlers at the end of the pipeline. <p> No verification is done if the handler is already added and a handler should only be added once. <p>

Adds the given class name prefixes to this filter. @param names class name prefixes to add @return this filter

Returns a predicate that always evaluates to {@code true}. @param <T> the type of the input to the predicate

Registers the supplied function as both the {@link AggregateOperation#exportFn() export} and {@link AggregateOperation#finishFn() finish} primitive. C

@return a new constructed GenericRecord @throws HazelcastSerializationException when the GenericRecord cannot be

Removes all items from the inbox.

The cluster version indicates the operating version of the cluster. It is separate from each node's codebase version, as it may be acceptable for a no

@param serviceName name of the service @param name name of the object @param <T> type of the DistributedObject @return DistributedObjec

Gets the partition ID. @return the partition ID @see Operation#getPartitionId()

Returns the current {@link SSLConfig}. It is possible that null is returned if no SSLConfig has been set. @return the SSLConfig @throws SecurityExcep

Returns the socket address of this client. @return the socket address of this client

@param descending whether the entries should come in the descending order. {@code true} means a descending order,

Sets the count that the client iterates over the given list of alternative clusters. For each alternative cluster, the client will try to connect to t

Checks whether the given value is {@code false}. @param value the value to check. @return {@code true} if the passed value is {@code false}; {@code f

Removes the mapping for a key from this cache if it is present. <p> More formally, if this cache contains a mapping from key <tt>k</tt> to value <tt>v

@param bytes byte array to be written @throws IOException in case of any exceptional case

Returns a supplier of processors for {@link Sinks#list(String)}.

Sets the {@link DataConnectionRef} reference to a HazelcastDataConnection to use for remote Map sink. <p> Only one of {@link #dataConnectionRef} and {

Describes the job suspension cause in a human-readable form.

@param index argument index @return the query argument

Returns the average selectivity of the hits served by the index. <p> The returned value is in the range from 0.0 to 1.0. Values close to 1.0 indicate

@return the global index, if the global index is in use or null.

@return partition count

Returns the partition group configuration for this hazelcast instance. The partition group configuration defines how partitions are mapped to members.

Returns the instance encapsulating the partitioning strategy in effect on this edge.

Returns the {@link Pipeline} this stage belongs to.

Returns the predicate of {@code QueryCache}. @return the predicate of {@code QueryCache}

Returns the whitelist filter. If not set, it sets and returns an empty filter. @return the whitelist filter

Checks if the value of this node is the given type @param type the {@link Class} instance of the type to check @param <T> the type to check @return

Like a String.lastIndexOf but without MIN_SUPPLEMENTARY_CODE_POINT handling @param input to check the indexOf on @param ch character to find the

Returns a source that emits items retrieved from a Hazelcast {@code IList}. All elements are emitted on a single member &mdash; the one where the enti

Performs a phone request for {@code node} and returns the generated request parameters. If {@code pretend} is {@code true}, only returns the parameter

Reads this accumulator if it contains at least {@code maxItems}, otherwise do not read anything. If this method adds items to the supplied handler, he

Set to enable/disable per entry statistics. Its default value is {@code false}. <p> When you enable per entry stats, you can retrieve entry level stat

Returns a projection that extracts the value of the given {@code attributePath}. @param attributePath single attribute path, path must not be null or

Stores the key-value pair in the external store. <p> Invocation semantics depend on configuration: <ul> <li><b>Write-through</b> ({@code writeDelayS

Submits a task to the owner of the specified key and returns a Future representing that task. @param task task submitted to the owner of the specifie

Submits a task to the specified member and returns a Future representing that task. @param task the task submitted to the specified member @param m