Returns a collection of the members that satisfy the given {@link MemberSelector}. @param selector {@link MemberSelector} instance to filter members

Returns the published message @return the published message object

The key that will be used by Hazelcast to specify the partition. You should give the same key for objects that you want to be in the same partition. <

Returns the address of the replica. <p> The owner has replica index 0. <p> The returned value could be {@code null} if the owner/replica has not yet b

Returns the configured value of a {@link HazelcastProperty} converted to seconds. @param property the {@link HazelcastProperty} to get the value from

@return Return SQL config.

Returns the name of the table in SQL.

Gets the {@code TieredStoreConfig} for this {@code MapConfig} @return tiered-store config

Creates a <b>in</b> predicate that will pass items if the value stored under the given item {@code attribute} is a member of the given {@code values}

@return {@code true} if this instance of {@code ClusterTopologyIntentTracker} is active and tracking cluster topology changes in a managed con

@return true if the client uses the enterprise build of Hazelcast

Acquires a lock for the specified key. <p> If the lock is not available, then the current thread becomes disabled for thread scheduling purposes and l

Looks up the User Code Namespace name associated with the specified map name. This starts by looking for an existing {@link MapContainer} and checking

A variant of {@link #nonSharedService(FunctionEx, ConsumerEx) nonSharedService(createFn, destroyFn)} with a no-op {@code destroyFn}. <p> <strong>Note:

Overrides the property with the value from the diagnostics config if it is set.

Fills a buffer from an {@link InputStream}. @param in the {@link InputStream} to read from @param buffer the buffer to fill @throws EOFException

It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t

Sets the collection type for the values of this MultiMap. @param valueCollectionType the collection type for the values of this MultiMap (SET or LIST

Create a new instance to upload and execute a local jar

Serialize this portable object using PortableWriter @param writer PortableWriter @throws IOException in case of any exceptional case

Adds a 'well known' member. <p> Each HazelcastInstance will try to connect to at least one of the members, to find all other members, and create a clu

Returns set based on the given array of {@link MetricTarget}. Set objects are returned from a preliminary warmed up cache, so this method has no memor

@see org.assertj.core.api.AbstractIterableAssert#containsExactly(Object...)

Asserts that the previous stage emitted the exact sequence of expected items and nothing else. If the assertion fails, the job will fail with an {@lin

Adds the file identified by the supplied URL as a resource that will be available to the job while it's executing in the Jet cluster. The resource's f

Registers client endpoint to endpointManager. Only authenticated endpoints should be registered here. bind can be called twice for same connection, as

Drains all elements into the provided {@link Collection}. @param target the collection to drain this object's items into @return the number of elemen

Executes a task on a randomly selected member. @param command the task that is executed on a randomly selected member @throws java.util.concur

Returns all connected clients to this member. @return all connected clients to this member

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

Returns the internal hot restart service

Returns the management center configuration for this hazelcast instance. @return the management center configuration

Returns the native memory configuration for this hazelcast instance. The native memory configuration defines how native memory is used and the limits

Retrieves the currently set {@link NodeEngine} reference for this thread, or throws an {@link IllegalStateException} if one could not be found. @retu

Gets properties of the Diagnostic Configuration. The properties are used by diagnostic plugins. <p>Note that the keys and values are not verified. Mak

Gets the name of the split brain protection associated with specified operation name. @param operationName the operation name for which the split bra

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

@return field type

Returns unit of the capacity @return unit of capacity

Says whether this edge distributes items among all members, as requested by the {@link #distributed()} method.

Detects whether this value represents the JSON literal <code>null</code>. @return <code>true</code> if this value represents the JSON literal <code>n

Returns a non-thread-safe handler for manipulating the metric with the specified name. <p> This method only works if called from a processor thread an

Sets the page value to next page.

@return false when both objects are null or they are equal, true otherwise

Converts a collection of any type to a collection of {@link Data}. @param collection the given collection @param serializationService will

Returns a sink that publishes to the {@link Observable} with the provided name. The records that are sent to the observable can be read through first

Checks if two pointers overlap or are adjacent which means that they can be combined into a single pointer. Requires that {@code left <= right} regard

Read portable fields using PortableReader @param reader PortableReader @throws IOException in case of any exceptional case