Returns a supplier of processors for a vertex that applies the provided item-to-traverser mapping function to each received item and emits all the ite

Sets the function that implements the sink's flushing behavior. If your context object is buffered, instead of relying on some automatic flushing poli

Unlock the key regardless of the owner. May return {@code true} if the key is already unlocked but has waiters/signals/expired operations. @param dat

Returns a string that identifies the {@link FileFormat} supported by this function provider.

A utility method that creates an anonymous {@link ProtobufSerializer}. @param clazz {@link GeneratedMessageV3} type of created serializer @param typ

Resolves one of the {@link UniqueKeyTransformation} values by its name. @param name the name of the {@link UniqueKeyTransformation} value to

Returns {@link QueryCacheConfigurator} for this context. @return {@link QueryCacheConfigurator} for this context. @see QueryCacheConfigurator

Generates the XML string based on some Config. @param config the configuration @return the XML string

Retrieves the mapped value of the given key using a custom {@link javax.cache.expiry.ExpiryPolicy}. If no mapping exists <code>null</code> is returned

Returns the current value of the counter. <p> The method can throw a {@link ConsistencyLostException} when the state of this CRDT is not causally rela

Retrieves the value associated with the supplied tag and throws an exception if there is none. The tag argument must not be {@code null}, but the retu

Transactional implementation of {@link IMap#get(Object)}. @throws NullPointerException if the specified key is {@code null} @see IMap#get(Object)

Returns {@link AccumulatorInfoSupplier} for this context. @return {@link AccumulatorInfoSupplier} for this context. @see AccumulatorInfoSupplier

Returns {@code PartitionAccumulatorRegistry} of a {@code QueryCache}. @see PartitionAccumulatorRegistry

Returns accumulators of a {@code QueryCache}.

Returns the list of schemas that are stored in the in-memory registry of the service.

Retrieve the anchor object which is the last value object on the previous page. <p> Note: This method will return `null` on the first page of the quer

Returns next unread event from this buffer and advances head sequence of this buffer by one. @return next unread event.

Subtracts the given value from the current value. @param delta the value to add @return the previous value @throws NoDataMemberInClusterException if

Reads same value {@link GenericRecord#getArrayOfGenericRecord(String)} (String)}, but in deserialized form. This is used in query system when the obje

Gets the number of asynchronous backups for this {@link com.hazelcast.cache.ICache}. @return the number of asynchronous backups for this {@link com.h

Returns a proxy for an {@link IAtomicReference} instance created on CP Subsystem. Hazelcast's {@link IAtomicReference} is a distributed version of <tt

Returns the name of the attribute. @return string with the name of the attribute

Returns the {@link AzureConfig} used by the discovery mechanism for this WAN publisher.

Returns the {@link #setBackupCount(int) number of backups} used for job metadata and snapshots. @since 5.0

Returns all backup entries of an {@link MultiMap} by a given map name. <p> Note: This method returns all backups from all nodes and doesn't consider t

Creates the {@link BackupOperation} responsible for making the backup. @return the created {@link BackupOperation} responsible for making the backup.

Base directory for all Hot Restart stores. Can be an absolute or relative path to the node startup directory.

Returns the <code>boolean</code> value of the member with the specified name in this object. If this object does not contain a member with this name,

Returns the ResourceType for the given ID. @return the ResourceType found or null if not found

Returns the IndexType as an enum. @return the IndexType as an enum

Returns the WanPublisherState as an enum.

Returns the WANQueueFullBehavior as an enum. @return the WANQueueFullBehavior as an enum