Stores a key-value pair in the multimap. <p> <b>Warning:</b> This method uses {@code hashCode} and {@code equals} of the binary form of the {@code key

Sets an option value if that option is supported. @param option the option @param value the value @param <T> the type of the value @return <code>

It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t

Terminates the given Hazelcast instance. @param hz the instance to terminate

Creates a database object (table, collection, etc) with two fields: - id or {@code person-id}, depending on {@code #useQuotedNames} option - name

Creates or returns the distributed list instance with the specified name. Index based operations on the list are not supported. @param name name of t

Returns the number of entries owned by this member. @return number of entries owned by this member.

@return the {@code ClusterVersion} with the given major and minor

Applies the projection logic on all map entries and returns the result @param projection projection to transform the entries with (may return null) @

Decides if the given member will be part of an operation or not. @param member the member instance to decide upon @return true if the member should t

Registers an invocation with this object. @param address address of the sender of the operation @param callId call ID of the operation

Adds the given member to this storage. @param member the member to add. @return a new storage instance if this storage was converted to another stora

alternative implementation of {@link org.assertj.core.api.AbstractIterableAssert#containsAll(Iterable)} that does not rely on an implementation of {@l

Returns statistics related to the Near Cache. @return statistics object for the Near Cache

Gets the row metadata. @throws IllegalStateException if the result doesn't have rows, but only an update count

Gets the Server this {@link ServerConnectionManager} belongs to. @return the Server.

Creates or returns the distributed topic instance with the specified name. @param name name of the distributed topic @param <E> the type of the topic

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

Returns the key part of the CDC event. It identifies the affected record.

Returns the represented edge's ordinal.

Sets the map store implementation object @param implementation the map store implementation object to set @return this MapStoreConfig instance

@param fieldName the name of the field @return time field consisting of hour, minute, seconds and nanos parts as {@link LocalTime} @throws HazelcastSe

Removes the head of this inbox. This method throws an exception if the inbox is empty. @throws NoSuchElementException if this inbox is empty

Resets the publisher (e.g. before split-brain merge).

Enables and disables this configuration @param enabled {@code true} to enables this configuration, {@code false} to disable

Returns a new 3-tuple with the supplied values.

Returns version of the session. A session's version is incremented on each heartbeat.

Adds the cache configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be obtained i

@return the autoDetectionConfig join configuration

Returns the cluster name uniquely identifying the hazelcast cluster. This name is used in different scenarios, such as identifying cluster for WAN pub

@return the partition id associated with given data @throws com.hazelcast.spi.exception.RetryableHazelcastException if partition table is not arrived

Returns a set containing all the {@link Partition}s in the cluster. @return all partitions in the cluster

Returns the index of the partition replica. 0th index is primary replica, 1st index is 1st backup and so on. @return the index of the partition repli

Ignore certain exceptions when invoking {@link #assertNoExceptions()} @param predicate an exception to ignore @return this ExceptionRecorder

A primitive that updates the accumulator state to account for a new item. The tag argument identifies which of the contributing streams the returned f

Gets the {@link NearCache} instance associated with given {@code name}. @param name the name of the {@link NearCache} instance will be got @param <K>

Checks if this member is the master. @return {@code true} if master, {@code false} otherwise

Gracefully suspends the current execution of the job. The job's status will become {@link JobStatus#SUSPENDED}. To resume the job, call {@link #resume

Returns the value part of the CDC event. It includes fields like the timestamp, operation, and database record data. <p> For <em>sync</em>, <em>insert

Returns an immutable map of entries for the given keys. <p> <b>Warning 1:</b> <p> The returned map is <b>NOT</b> backed by the original map, so change

Returns the creation time of the entry. <p> <b>Warning:</b> This method returns {@code -1} if statistics are not enabled or not implemented. @return

Creates or returns the durable executor service for the given name. DurableExecutor service enables you to run your <code>Runnable</code>s and <code>C

Returns the field count. @return total field count

Sets the globbing mask, see {@link java.nio.file.FileSystem#getPathMatcher(String) getPathMatcher()}. The default value is {@code " "}, which means al

Checks if a message at the given level is going to be logged by this logger. @param level the log level @return true if this logger will log messages

Returns a sink that logs all the data items it receives, at the INFO level to the log category {@link com.hazelcast.jet.impl.connector.WriteLoggerP}.

Returns an aggregate operation that accumulates the items into a {@code HashSet}. <p> This sample takes a stream of people and outputs a single set of

Sets the discriminator tag of the descriptor. @param discriminatorTag The name of the discriminator tag @param discriminatorValue The value of the

Adds given addresses to candidate address list that client will use to establish initial connection @param addresses to be added to initial address l

Adds the ringbuffer configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be obtai

Creates a new type of the given type name and nullability. <p> Combines the functionality of {@link #createSqlType(SqlTypeName)} and {@link #createTyp

Disable snapshot save and restore before first item and after each {@code process()} and {@code complete()} call. @return {@code this} instance for f

Returns {@link DataConnection} with the given name and `retain` it (calls {@link DataConnection#retain()}). The caller is responsible for calling {@li

Returns unique id of the CP group.