Writes a message to this AsyncSocket and flushes it. Flushing causes the AsyncSocket to be scheduled in the {@link Reactor}. <p> This is the same as

Writes an array of 32-bit IEEE 754 floating point numbers. @param fieldName name of the field. @param value to be written.

Writes an array of 64-bit IEEE 754 floating point numbers. @param fieldName name of the field. @param value to be written.

Writes an array of 32-bit two's complement signed integers. @param fieldName name of the field. @param value to be written.

Writes an array of 8-bit two's complement signed integers. @param fieldName name of the field. @param value to be written.

Writes an array of UTF-8 encoded strings. @param fieldName name of the field. @param value to be written.

Writes a nested compact object. @param fieldName name of the field. @param value to be written.

Writes a nullable 32-bit IEEE 754 floating point number. @param fieldName name of the field. @param value to be written.

Writes a nullable 64-bit IEEE 754 floating point number. @param fieldName name of the field. @param value to be written.

Writes a nullable 64-bit two's complement signed integer. @param fieldName name of the field. @param value to be written.

Writes a nullable 8-bit two's complement signed integer. @param fieldName name of the field. @param value to be written.

A map entry @param keyPartA for the key @param keyPartB for the key @param value for the entry

A primitive that updates the accumulator state to account for a new item coming from stream-0. <p> The consumer must be stateless and {@linkplain Proc

Returns a supplier of processors for a vertex that performs the accumulation step of the provided aggregate operation on all the items it receives. Af

@param result result to be added to this MultiResult

Adds the given member to this bit set. @param member the member to add.

Adds the CachePartitionLostListenerConfig to partitionLostListenerConfigs. @param listenerConfig CachePartitionLostListenerConfig to be added

Adds a new child node to the mapping with the provided name @param name The name of the new child @param node The child node

Adds a remove callable to be called when endpoint is destroyed Note: removeDestroyAction should be called when there is no need to destroy action anym

Notifies {@link com.hazelcast.map.QueryCache} subscribers directly, without publishing an event to other map listeners. This is necessary in certain c

Adds a PartitionLostListener. <p> The addPartitionLostListener returns a registration ID. This ID is needed to remove the PartitionLostListener using

@param fieldName name of the field that will be added to this class definition @return itself for chaining @throws HazelcastSerializationException if

Creates new {@linkplain TopicConfig topic configurations} for every provided topic from the list and saves them in the map.

Adjust the cost of a CPU-related operation (project, filter) located inside a scan. This allows the optimizer to prefer filters and projects inlined i

Advances to the next {@code long} element. It is illegal to call this method after a previous call returned {@code false}. An {@code AssertionError} m

Advances to the next map entry. It is illegal to call this method after a previous call returned {@code false}. An {@code AssertionError} may be throw

For sinks and inner vertices, call from {@link Processor#complete()}. For batch sources call after the source emitted everything. Never call it for st

Is executed after {@link #run()} even if the operation failed. <p> Runs after backups, before wait-notify.

Marks a task as completed. @throws IllegalStateException if the migration task count was reduced below 0

Returns {@code true} if the number of indexed partitions is equal to {@code ownedPartitionCount}, {@code false} otherwise. <p> The method is used to c

Allocates a new {@link ByteBuffer}. @param direct if the ByteBuffer should be a direct ByteBuffer. @param capacity the capacity of the ByteBuffer to

@throws UnsupportedOperationException @throws ClassCastException @throws NullPointerException @implSpec The default implementation is equivalent to th

Mutates the partition state and applies the migration.

Returns a storage with all the elements and makes this instance unusable.

Converts current configuration to a {@link ICredentialsFactory} instance. @param cl class loader to be used if the credentials factory class has to b

Returns this JSON value as a <code>float</code> value, assuming that this value represents a JSON number. If this is not the case, an exception is thr