Asserts that the given condition is {@code true}. If not, an {@link AssertionError} is thrown with the given message.

Returns the backup value for the given key. @param key key of the backup entry to get @return backup value or {@code null}

{@code Serializable} variant of @param <T> the type of the input to the predicate {@link Predicate#isEqual(Object) java.util.function.Predicate#isEqua

Asserts that the two given objects are equal, when compared using {@link Object#equals(Object)}. If they are not equal, an {@link AssertionError} is t

Adds the given entry to this result. @param entry the entry to add.

Creates new assertions object for given job.

Asserts that the given condition is {@code false}. If not, an {@link AssertionError} is thrown with the given message.

Number of existing backup entries in a given structure and replica index. @return number of backup entries

Returns the name of this job or {@code null} if no name was supplied. <p> Jobs can be named through {@link JobConfig#setName(String)} prior to submiss

Returns a read-only list representation of this queue. @return read-only list representation of this queue.

Returns a traverser that will return all the items of this traverser, plus an additional item once this one returns {@code null}. After that it contin

Utility method for building an {@link Observer} from its basic callback components.

Convenient method to execute a distributed query with the given parameter values. <p> Converts passed SQL string and parameter values into an {@link S

{@inheritDoc} <p> <b>Warning 1:</b> <p> This method returns a clone of the previous value, not the original (identically equal) value previously put i

Creates a new {@link HazelcastOSGiInstance} on the owner bundle with specified configuration. @param config Configuration for the new {@link Hazelcas

Returns a proxy for a {@link CPMap}. <b>Enterprise Only</b>. <p> If no group name is given within the {@code name} parameter, then the {@link

Builds the {@link AuditableEvent} instance. If the timestamp is not configured explicitly, then the call sets event timestamp too. @return not-{@code

Creates or returns the distributed map instance with the specified name. @param name name of the distributed map @param <K> key type @param <V> value

Returns an immutable collection clone of the values contained in this map. <p> <b>Warning:</b> <p> The collection is <b>NOT</b> backed by the map, so

Returns a stream of result rows. <p>It uses internally {@link #iterator()} method, so it cannot be called twice.</p> <p>You should still call {@link

Returns the value of the entry. @return the value of the entry

Returns <code>true</code> if this map contains no entries. @return <code>true</code> if this map contains no entries.

Equivalent to {@link #newHazelcastInstance(Config) newHazelcastInstance(null)}.

Returns the next member to route to. @return Returns the next member or null if no member is available

Returns the name of the file format. The convention is to use the well-known filename suffix or, if there is none, a short-form name of the format.

Returns a Jet service to execute distributed batch and streaming jobs. @see JetService

Total entry count. If the cache contains more than <code>Integer.MAX_VALUE</code> elements, returns <code>Integer.MAX_VALUE</code>. @return total ent

Collects the content of the MetricsRegistry. @param collector the collector that consumes the metrics collected @throws NullPointerException if colle

Returns the configuration this job was submitted with. Changes made to the returned config object will not have any effect.

Serializes an object to a {@link Data}. <p> This method can safely be called with a {@link Data} instance. In that case, that instance is returned. <p

Checks if the reference contains the value. @param value the value to check (is allowed to be {@code null}) @return {@code true} if the value is foun

Returns the best match for an item name out of a list of configuration patterns. @param configPatterns list of known configuration patterns @param

Decrements the count of the latch, releasing all waiting threads if the count reaches zero. <p> If the current count is greater than zero, then it is

Waits for the job to complete and throws an exception if the job completes with an error. Never returns for streaming (unbounded) jobs, unless they fa

Logs a message at the {@link Level#INFO} level. @param message the message to log

Checks if a next item is available, with a timeout. <p> The implementation is allowed to block until an item is available and never actually return TI

Puts an entry into this map without returning the old value (which is more efficient than {@code put()}). <p> <b>Warning 1:</b> <p> This method breaks

Attaches the supplied sink to two or more pipeline stages. Returns the {@code SinkStage} representing the sink. You need this method when you want to

Returns a traverser that will emit the results of applying {@code mapFn} to this traverser's items. If {@code mapFn} returns {@code null} for an item,

Creates and returns a Jet job based on the supplied DAG. Jet will asynchronously start executing the job.

Logs a message at the {@link Level#WARNING} level. @param message the message to log

Aggregates the hash in the HyperLogLog registers. @param hash the value to aggregate

Batch aggregation of hash values in the HyperLogLog registers. @param hashes the hash values array to aggregate

Writes a primitive int. @param fieldName name of the field @param value int value to be written @throws IOException in case of any exceptional ca

@param object object to be written @throws IOException in case of any exceptional case

@param string string to be written @throws IOException in case of any exceptional case

@return the string read @throws IOException if it reaches end of file before finish reading

@param version other version to compare to @return {@code true} if this version equals {@code version}

Returns an iterator over the entries of the map. It sequentially iterates partitions. It starts to iterate on partition 0, and it finishes the iterati

@param <T> type of the object to be read @return object array read @throws IOException if it reaches end of file before finish reading

Associates {@code key} with {@code value}. <p> See {@link CPMap#set(Object, Object)} for a more optimal solution when the previous value of @{code

Gets the service with the given name. @param serviceName the name of the service @param <T> the type of the service @return the found service

Returns a pipeline stage that represents a bounded (batch) data source. It has no upstream stages and emits the data (typically coming from an outside

Atomically increments the current value by one. @return the updated value, the current value incremented by one

Asserts that the two given objects are the same, when compared using the {@code ==} operator and if not, an {@link AssertionError} is thrown with the

Assert the contents of a given table via Hazelcast SQL engine

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

See {@link #newJob(Pipeline, JobConfig)} for details. @see #startIfAbsent()

Returns an immutable set clone of the keys contained in this map. <p> <b>Warning:</b> <p> The set is <b>NOT</b> backed by the map, so changes to the m

Returns the network configuration for this hazelcast instance. The network configuration defines how a member will interact with other members or clie

Logs to {@link #fine(String)} using a lazily evaluated {@code template} {@link String} with arguments, formatted using {@link String#format(String, Ob

Returns the MapConfig for the given name, creating one if necessary and adding it to the collection of known configurations. <p> The configuration is

Sets the value of a named property. @param name property name @param value value of the property @return this config instance @throws IllegalArgumen