Returns {@code true} if the same instance can be reused in different job executions or in different vertices. In that case, {@link #init}, {@link #get

SO_REUSEADDR socket option. @return true if enabled

@return {@code true} when compatibility tests are to be executed on a mixed version cluster

Check whether the security is enabled. @return {@code true} if security is enabled

Checks if the {@link com.hazelcast.map.QueryCache} key is stored in serialized format or by-reference. @return {@code true} if the key is stored in

Returns, if the inbox we are currently on is the snapshot restoring inbox.

Checks if statistics are enabled for this {@link com.hazelcast.cache.ICache}. @return {@code true} if statistics are enabled, {@code false} otherwise

Checks if statistics are enabled for this PN counter @return {@code true} if enabled, {@code false} otherwise

Check if statistics are enabled for this queue. @return {@code true} if statistics are enabled, {@code false} otherwise

Returns whether metrics should be stored in the cluster after the job completes successfully. Needs both {@link MetricsConfig#isEnabled()} and {@link

Detects whether this value represents a JSON string. @return <code>true</code> if this value represents a JSON string

Tells whether this definition describes a tumbling window. Tumbling window is a special case of sliding window whose sliding step is equal to its size

Checks if deduplication is enabled. @return True if deduplication is enabled, false otherwise.

Starts iteration on this storage using the given iterator. <p> Always succeeds since we never keep empty storages. @param iterator the iterator to it

Returns iterator that will iterate contained IDs (boxing the as {@code Long}). {@code remove()} is not supported.

Returns an iterator over the items in this accumulator in proper sequence. Also this methods advances head of this accumulator. @return an iterator o

Returns a builder to build a sink that connects to a JDBC database, prepares an SQL statement and executes it for each item. On the returned builder y

@deprecated see {@linkplain #jmsQueue(String, SupplierEx)}.

Returns a builder object that offers a step-by-step fluent API to build a custom JMS queue sink for the Pipeline API. See javadoc for {@link JmsSinkBu

Returns a builder object that offers a step-by-step fluent API to build a custom JMS {@link StreamSource} for the Pipeline API. See javadoc on {@link

Converts {@link Job} to a string. Used for comparing two Job instances.

@return the key of the current slot. @throws IllegalStateException if the cursor is invalid.

@return key part 1 of current slot. @throws IllegalStateException if the cursor is invalid.

@return key part 2 of current slot. @throws IllegalStateException if the cursor is invalid.

@return kind size on bytes for compact format which is sometimes different than {@link FieldType#getTypeSize()}

Converts a JSON string to a {@link List} of given type.

Returns an {@link Iterable} over all keys or an empty iterable if there is no map loader configured for this map. @see MapLoader#loadAllKeys()

Increase the failure count and log the failure. Every {@value #WARNING_LOG_FREQUENCY} log is logged with a higher log level. @param message the log m

Looks up the User Code Namespace name associated with the specified replicated map name. This is done by checking the Node's config tree directly. @p

Looks up the User Code Namespace name associated with the specified executor name. This is done by checking this service's config caches, and falling

Looks up the User Code Namespace name associated with the specified executor name. This is done by checking the Node's config tree directly. @param e

Returns a sink that applies the changes described by a Change Data Capture (CDC) stream to an {@code IMap}. The main usage is to have the {@code IMap}

Invoked when all entries are removed by {@link IMap#clear()}. <p> When a listener is registered as local-only then it will be invoked if and only if t

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

Returns a projection that converts the {@link EventJournalMapEvent} to a {@link JournalSourceEntry} using the event's new value as a value. @see Sour

This method marks current replica as expirable and also starts expiration task if necessary. <p> The expiration task runs on only primary replicas. Ex

Marks the given partition as indexed by the given indexes. @param partitionId the ID of the partition to mark as indexed. @param indexes the inde

Sets the maximum size of a batch for a single request to Python handler. @param maxBatchSize the maximum size of a batch for a single request

Invoked when a new member is added to the cluster. Should be non-blocking. @param event the event for a new member added to the cluster

Invoked when a new member is added to the cluster. @param membershipEvent membership event

Returns the partitions from {@link #partitionAssignment()} pertaining to this member. The returned list can be empty.

Invoked when an existing member leaves the cluster. Should be non-blocking. @param event the event for an existing member leaving the cluster

Invoked when an existing member leaves the cluster. @param membershipEvent membership event when an existing member leaves the cluster

Merges the given {@link ReplicatedMapMergeTypes} via the given {@link SplitBrainMergePolicy}. @param mergingEntry the {@link ReplicatedMapMergeTypes}