@return the value of the current entry.

Returns a lazy {@link Collection} view of the values contained in this map.<br> A LazyCollection is optimized for querying speed (preventing eager des

Join operations are not authenticated. This means that if any join operation includes node shutdown, a third party can just send that operation to any

Includes the given target for this metric. <p> Note1: This is the invert method for {@link #withExcludedTarget(MetricTarget)} Note2: The excluded targ

Enriches execution metrics with job metrics if any.

If skipped, or passed {@code null}: <ol> <li> if persistence is enabled and the member acquires an existing hot restart directory, the local memb

If exception is not JetException e.g. IOException, FileSystemException etc., wrap it with JetException

Writes the output of the provided {@code plugin} to the diagnostics output. @param plugin the plugin to log

Writes an array of nested compact objects. <p> It is not allowed to write an array containing different item types or a {@link HazelcastSerializationE

Writes an array of dates consisting of year, month, and day. @param fieldName name of the field. @param value to be written.

Writes an array of arbitrary precision and scale floating point numbers. @param fieldName name of the field. @param value to be written.

Writes an array of times consisting of hour, minute, second, and nanoseconds. @param fieldName name of the field. @param value to be written.

Writes an array of timestamps consisting of date and time. @param fieldName name of the field. @param value to be written.

Writes an array of timestamps with timezone consisting of date, time and timezone offset. @param fieldName name of the field. @param value to be

Returns a supplier of processors for {@link Sinks#filesBuilder}.

Update map with key and value functions

Writes a collection to an {@link ObjectDataOutput}. The collection's size is written to the data output, then each object in the collection is seriali

Returns the MurmurHash3_x86_32 hash of a block inside a byte array.

Returns the number of accepted sockets. @return the number of accepted sockets.

Returns a supplier of processors for the first-stage vertex in a two-stage group-and-aggregate setup. The vertex groups items by the grouping key and

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

Id of the last started snapshot, phase 2.

Aggregates the hash value in the HyperLogLog registers, and returns a hint if the operation might have affected the cardinality, it is just a hint, an

Convenience for {@code inbox.queue().addAll(collection)}

Add a new object in the estimation set. This is the method you want to use to feed objects into the estimator. <p> Objects are considered identical if

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

Adds a ChannelCloseListener. <p> This method is thread-safe. @param listener the listener to register. @throws NullPointerException if listener is nu

Adds the given element to this canonicalizing hash set. @param e the element to add.

Adds a local entry listener for this multimap. <p> The added listener will be only listening for the events (add/remove/update) of the locally owned e