{@inheritDoc}

Populate an empty result for the given query type. @param query given query @param resultLimit given resultLimit (ignored) @return Result of a

Creates a CDC source that streams change data from a PostgreSQL database to Hazelcast Jet. <p> You can configure how the source will behave if the dat

When the two separate clusters merge (resolve a split-brain), this method is called to return a {@link Runnable}, that will merge the clusters. @retu

Prepare processor classloaders for given job for current thread @param jobId id of the job

Sets the {@code partitionState} if the node is started and the state is sent by the master known by this node. @param partitionState the new partitio

Returns the total number of processed events.

Publishes event upon a change on a key in {@code QueryCache}. @param mapName the name of underlying map. @param cacheId the name of {@cod

Called on the master node to publish the current partition state to all cluster nodes. It will not publish the partition state if the partitions have

<p>Associates a given value to the specified key and replicates it to the cluster. If there is an old value, it will be replaced by the specified one

This method will group all entries per partition and send one operation per member. If there are e.g. five keys for a single member, even if they are

Puts the referenced object to given owner object as volatile by its offset. @param base the owner object where the referenced object will be writte

This method is used in replication operations. <p> Puts a data key and a record into a record-store. Used in replication operations means does not att

Associates the specified record with the specified key. This is simply a put operation on the internal map data without any CacheLoad. It also <b>DOES

Returns a stream of {@code long}s: {@code for (long i = start; i <= end; i += step) yield i;}

Reads an array of compact objects. @param fieldName name of the field. @return the value of the field. @throws HazelcastSerializationException if the

Reads an array of 32-bit IEEE 754 floating point numbers. <p> This method can also read an array of nullable float32s, as long as it does not contain

Reads an array of 64-bit IEEE 754 floating point numbers. <p> This method can also read an array of nullable float64s, as long as it does not contain

Reads an array of 8-bit two's complement signed integers. <p> This method can also read an array of nullable int8s, as long as it does not contain {@c

Reads a nullable array of nullable booleans. <p> This method can also read array of non-nullable booleans. @param fieldName name of the field. @retur

Reads a nullable array of nullable 32-bit IEEE 754 floating point numbers. <p> This method can also read array of non-nullable float32s. @param field

Reads a nullable array of nullable 64-bit IEEE 754 floating point numbers. <p> This method can also read array of non-nullable float64s. @param field

Reads a nullable array of nullable 32-bit two's complement signed integers. <p> This method can also read array of non-nullable int32s. @param fieldN

Reads a nullable array of nullable 64-bit two's complement signed integers. <p> This method can also read array of non-nullable int64s. @param fieldN

Reads a nullable array of nullable 8-bit two's complement signed integers. <p> This method can also read array of non-nullable int8s. @param fieldNam

Reads an array of UTF-8 encoded strings. @param fieldName name of the field. @return the value of the field. @throws HazelcastSerializationException

Returns a supplier of processors for {@link Sources#jdbc( SupplierEx, ToResultSetFunction, FunctionEx)}.

Reads events from the journal in batches. It will read up to the maximum number that the set can hold - see {@link ReadResultSetImpl#isMaxSizeReached(

Reads a nullable 32-bit IEEE 754 floating point number. <p> This method can also read a non-nullable float32. @param fieldName name of the field. @re

Reads a nullable 64-bit IEEE 754 floating point number. <p> This method can also read a non-nullable float64. @param fieldName name of the field. @re

Reads a nullable 32-bit two's complement signed integer. <p> This method can also read a non-nullable int32. @param fieldName name of the field. @ret

Reads a nullable 64-bit two's complement signed integer. <p> This method can also read a non-nullable int64. @param fieldName name of the field. @ret

Reads a nullable 8-bit two's complement signed integer. <p> This method can also read a non-nullable int8. @param fieldName name of the field. @retur

Registers a reflective compact serializer for the given class name. The type name will be the same with the class name.

Registers an explicit compact serializer for the given class and type name.

Releases a permit back to pool for future use

Returns the remaining capacity of the ringbuffer. If TTL is enabled, then the returned capacity is equal to the total capacity of the ringbuffer minus

Convenience for {@link #remoteMapWithMerging} with {@link Entry} as input item.

Removes the specified entry listener. <p> Returns silently if no such listener was added before. @param registrationId registration ID of listener @r

Removes a partition that will no longer have events. If we were waiting for a watermark from it, the returned traverser might contain a watermark to e

Ensures that the file described by {@code fileNow} is renamed to file described by {@code fileToBe}. First attempts to perform a direct, atomic rename

Atomically replaces the currently assigned value for the given key with the specified <code>newValue</code> if and only if the currently assigned valu