Returns the ordinal of the edge at the source vertex.

Return a {@link JobSuspensionCause description of the cause} that has led to the suspension of the job. Throws an {@code IllegalStateException} if the

@param fieldName the name of the field @return timestamp with timezone field consisting of year, month of the year, day of the month, offset seconds,

Returns the TPC channels associated with this connection, or {@code null}, if the client is not TPC-aware or the TPC is disabled on the server-side.

Creates a <b>case-insensitive like</b> predicate that will pass items if the given {@code pattern} matches the value stored under the given item {@cod

@param <I> type of the input object. @return an aggregator that calculates the sum of the input values. Does NOT accept null input values. Accepts onl

True if the replicated map is available for reads before the initial replication is completed, false otherwise. Default is true. If false, no Exceptio

Checks whether the cluster is in a safe state. <p> Safe state means; there are no partitions being migrated and all backups are in sync when this meth

Returns <tt>true</tt> if this accumulator contains no elements. @return <tt>true</tt> if this accumulator contains no elements

Checks if global ordering is enabled (all nodes listening to the same topic get their messages in the same order), or disabled (nodes get the messages

Returns true if the join type is an INNER join.

Flag indicating the liveness status of the Server

Checks if multithreaded processing of incoming messages is enabled or not. When disabled only one dedicated thread will handle all topic messages. Oth

@return whether the ICMP detector is set in parallel mode, or in legacy (flag value = <code>false</code>).

Checks if entry level statistics are enabled for this map. @return {@code true} if entry level statistics are enabled, {@code false} otherwise @since

@return true if the client is started.

Returns whether the WAN connection manager should connect to the endpoint on the private address returned by the discovery SPI. By default, this prope

A shortcut for: <pre>{@code Sinks.<T>jdbcBuilder() .updateQuery(updateQuery) .dataSourceSupplier(dataSourceSupplier)

@param <I> type of the input object. @return an aggregator that calculates the sum of the input values. Does NOT accept null input values. Accepts onl

Returns a builder object that offers a step-by-step fluent API to build a custom file sink for the Pipeline API. See javadoc of methods in {@link MapS

if hot-restart: enabled="true" and data-persistence: enabled="false" => enable persistence and use the config from hot-restart. Does not break current

Returns the name of the metric denoted by this instance. @return the name

Regular regex rules are applied. see String.matches @param nameMask of the clients that will be selected @return client selector according to name

Creates and returns a Jet job based on the supplied DAG and job configuration. Jet will asynchronously start executing the job. <p> If the name in the

Offers the given key and value pair to the processor's snapshot storage. <p> The type of the offered key determines which processors receive the key a

Retrieves and removes the head of this queue, or returns <code>null</code> if this queue is empty. @return the head of this queue, or <code>null</cod

returns the number of priority operations pending. This method is thread safe. This method returns a best effort value and should only be used for m

Create a test event with a processor assertion. The assertion must not be followed by an output item event. @return the new test event @see #expectEx

Core put method for all variants of puts/updates. @return old value if this is an update operation, otherwise returns null

Raises all the flags raised in the argument. Does not lower any flags. @param flagsToRaise the flags to raise @return {@code this} (for fluent interf

Stores the processor's state to a state snapshot by adding items to the outbox's {@linkplain Outbox#offerToSnapshot(Object, Object) snapshot bucket}.

Returns the segment that should be used for key with given hash @param hash the hash code for the key @return the segment

Sets the number of asynchronous backups for this {@link com.hazelcast.cache.ICache}. @param asyncBackupCount the number of asynchronous backups to se

True if the replicated map is available for reads before the initial replication is completed, false otherwise. Default is true. If false, no Exceptio

Sets whether Jet will scale the job up or down when a member is added or removed from the cluster. Enabled by default. Ignored for {@linkplain JetServ

Configure de-serialized value caching. Default: {@link CacheDeserializedValues#INDEX_ONLY} @return this {@code MapConfig} instance @see CacheDeserial

Sets the head sequence. The head sequence cannot be larger than {@code tailSequence() + 1} @param sequence the new head sequence @throws IllegalArgum

Sets the name of this {@link com.hazelcast.cache.ICache}. @param name the name to set for this {@link com.hazelcast.cache.ICache} @return the current