Adds a MapPartitionLostListener. <p> The method returns a register ID. This ID is needed to remove the {@link MapPartitionLostListener} using the {@li

Gets the base offset of the array typed with given class. @param arrayClass the type of the array whose base offset is requested @return the base off

Gets the index scale of the array typed with given class. @param arrayClass the type of the array whose index scale is requested @return the index sc

Gets a child mapping node by its name @param name the name of the child node @return the child mapping node with the given name if exists, {@code nul

true if registration is removed, false otherwise.

Applies the function to the given timestamp and sequence. @param timestamp the current timestamp @param sequence the current sequence @return the fun

Returns the blacklist filter. If not set, it sets and returns an empty filter. @return the blacklist filter

Gets the {@code DataPersistenceConfig} for this {@code MapConfig} @return dataPersistenceConfig config

Returns the device config mapped by the provided device name. @param name the device name @return device config or {@code null} if absent

Returns the list of class names implementing the CacheWanEventFilter or MapWanEventFilter for filtering outbound WAN replication events. <p> NOTE: EE

Returns a pseudorandom, uniformly distributed int value between 0 (inclusive) and the specified value (exclusive), drawn from this random number gener

Returns the local member. <p> The returned value will never be null, but it may change when local lite member is promoted to a data member or when a d

Returns the address of the master member. @return the address of the master member (can be {@code null} if the master is not yet known)

Return the field path or {@code null}, if this object represents the whole value (the whole key or the whole entry value).

Returns a cache record store with the prefixed {@code cacheNameWithPrefix} and partition ID or {@code null} if one doesn't exist. @param cacheNameWit

Returns the service name of the wait notify object for this key. @return the service name of the wait notify object for this key

Returns a service to execute distributed SQL queries. @return SQL service @see SqlService

Returns the URL at which the resource is available. Resolved on the local machine during job submission.

Updates the members of the cluster with the latest list. @param memberListVersion The version of the member list @param memberInfos The list of member

Sets the input objects for the processor on multiple input ordinals. Items will be passed to the processor in round-robin fashion: item0 from input0,

Returns a supplier of processors for a vertex which, for each received item, emits the result of applying the given mapping function to it. If the res

Creates a new Hazelcast instance. @param config the configuration to use; if <code>null</code>, the set of defaults as specified in the

Returns the name of the node @return the name of the node or {@link #UNNAMED_NODE} if not available

A hook method that's called during graceful shutdown to provide safety for data managed by this service. Shutdown process is blocked until this method

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

Deregister member from tracking and cleanup resources related to this member. @param member member to be removed

Reset the static counters in test processors. Call before starting each test that uses them.

This rethrow the exception providing an allowed Exception in first priority, even it is a Runtime exception

Assigns the supplied call ID to the supplied operation, thereby activating it. Refer to Operation#setCallId(long) and Operation#getCallId() for detail

Gets the source of this ChannelHandler. <p> This method should only be called from the thread that owns this ChannelHandler. @return the source; coul

This method will be called periodically and only when the current batch of items in the inbox has been exhausted. It can be used to produce output in

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

@param longs long array to be written @throws IOException in case of any exceptional case

@param fieldName name of the field that will be added to this class definition @return itself for chaining @throws HazelcastSerializationException if

@return slot address of the latest assignment invocation

Adds the directory identified by the supplied URL to the list of directories that will be available to the job while it's executing in the Jet cluster

Cancel all scheduled executions with the given key. @param key the scheduled key @return the cancelled scheduled execution, in case of {@link Schedul

True if registration is removed, false otherwise.

@param <I> type of the input object. @param <R> type of the return object. @return an aggregator that calculates the distinct set of input values. Acc

Gets the item at the given index. @param index the index @return the found item. @throws IllegalArgumentException if index out of bounds.

Returns the element in this buffer which has the supplied {@code sequence}. @param sequence the sequence number of the event. @return the element wit

Returns the collection of values associated with the key. <p> <b>Warning 1:</b> This method uses {@code hashCode} and {@code equals} of the binary for

Returns the backupCount for this {@link IMap} @return the backupCount for this {@link IMap} @see #getAsyncBackupCount()

Get current value cache settings @return current value cache settings @since 3.6

Returns the {@link WanConsumerConfig WAN consumer configuration} for this WAN replication. The WAN consumer is in charge of consuming (processing) inc

Returns the number of hits (reads) of locally owned entries, including those which are no longer in the map (for example, may have been evicted). <p>

Returns the event registration ID. @return the event registration ID

Returns the ID of the resource that will be used to form the {@code IMap} key under which it will be stored in the Jet cluster.

Returns the deserialized merging key. @return the deserialized merging key

Returns the map store configuration @return the mapStoreConfig (map store configuration)

Gets the collection of members. @return The collection of members. Null will never be returned.