Adds a ZIP file with JARs whose contents will be accessible to all the code attached to the underlying pipeline or DAG, but not to any other code. (An

@since 3.7

Returns all instances (except for the client).

Name of the object

Resumes a {@linkplain #suspend suspended} job. The job will resume from the last known successful snapshot, if there is one. Not supported for light j

Returns an aggregate operation that computes the sum of the {@code long} values it obtains by applying {@code getLongValueFn} to each item. <p> This s

Convert the original value of the parameter to the value of the target type @param value original value @return converted value

Returns array index if the current item is array and not "any". @return -1 if the current item is "any" or non-array.

Returns the local Endpoint which this HazelcastInstance belongs to. <p> Returned endpoint will be a {@link Member} instance for cluster nodes and a {@

Gets the member for the given address. @param address the address of the member to lookup @return the found member, or {@code null} if not found (if

Gets the index of the partition replica that current member will own after migration is committed. This index will be -1 if partition replica will be

Returns the private address of the discovered node. The private address <b>must not be</b> null. @return the private address of the discovered node

Return the index of partition replica for this partition. @param replica partition replica @return the replica index or -1 if the replica is null or

Notifies this failure detector about received heartbeat message from the tracked member. @param timestamp timestamp of heartbeat message in milliseco

Copies all of the mappings from the specified map to this map without loading non-existing elements from map store (which is more efficient than {@cod

Submits a task to given members and returns map of Member-Future pairs representing pending completion of the task on each member @param task the

With the {@link NearCacheTestContext#dataAdapter} we have to set {@link NearCacheConfig#setInvalidateOnChange(boolean)}. With the {@link NearCacheTest

Adds all the items of a collection to the tail of the Ringbuffer. <p> An addAll is likely to outperform multiple calls to {@link #add(Object)} due to

Adds an item listener for this collection. The listener will be notified of all collection add/remove events. <p> Listeners are non-destructive: They

Returns a traverser that always returns {@code null}.

Creates and returns a new event time policy. To get a policy that results in no timestamping, call {@link #noEventTime()}. @param timestampFn functio

@return a map of server socket {@link Address}es per {@link EndpointQualifier} of this member @since 3.12

Returns the configuration of this DataConnection.

Returns the default value of the property. @return the default value or <code>null</code> if none is defined

@since Jet 3.0 @deprecated Use {@link HazelcastInstance#getReliableTopic(String)} instead.

@return true if the current item is "any"

@return int array read @throws IOException if it reaches end of file before finish reading

Accumulate a value from a single row into this instance.

@return current base address of this flyweight

@implSpec The default implementation is equivalent to performing the following steps for this {@code map}, then returning the current value or {@code

Removes all endpoints. Nothing is done on the endpoints themselves; they are just removed from this ClientEndpointManager. Can safely be called when

A primitive that accepts two accumulators and updates the state of the left-hand one by deducting the state of the right-hand one from it. The right-h

{@inheritDoc} <p> Once it has emitted all the data, the function must call {@link SourceBuffer#close}.

Returns the batch size, which will be used to determine the number of entries to be sent in a merge operation. @return the batch size

Gets the capacity of the ringbuffer. <p> The capacity is the total number of items in the ringbuffer. The items will remain in the ringbuffer, but the

Returns the item queue on the partition owner. This method will also move the items from the backup map if this member has been promoted from a backup

Returns the maximum number of seconds for each entry to stay idle in the map. @return the maximum number of seconds for each entry to stay idle in th

Returns a public address to be advertised to other cluster members and clients. @return {@link Address} another members can use to connect to this me

Returns the number of put operations @return number of put operations