Returns the read IO thread count; @return read IO thread count

Returns the breadth-first order of the rightmost leaf in the subtree selected by {@code nodeOrder} as the root of the subtree @param nodeOrder The or

Return the name of the ScheduledExecutor this tasks is running on. @return the name of the scheduler

@return list of {@link com.hazelcast.config.SerializerConfig}s

Gets a Service by serviceName. @param serviceName the name of the service. @return the found service or null if nothing is found.

Gets the service for the given serviceName if it exists or null otherwise. @param serviceName the name of the shared service to get @param <T>

Returns a list of services matching provides service class/interface. <p> <b>Note:</b> CoreServices will be placed at the beginning of the list.

Reads the short value from given address. @param address the address where the short value will be read from @return the short value that was read

Returns the total number of specified replicas. If the context is empty, returns {@value ClusterTopologyIntentTracker#UNKNOWN}. @see StatefulSetInfo#

Returns the comma separated list of target cluster members, e.g. {@code 127.0.0.1:5701, 127.0.0.1:5702}. If you don't know the addresses of the target

Retrieves the tenant control relevant for this given object. Tenant control should already have been set up on this Hazelcast instance somehow, for in

{@inheritDoc}

Returns configured validation timeout for restart process. @return validation timeout in seconds

Get vector collection config. If no configuration is found for the given name, returns null. @return vector collection config or {@code null} @since

Retrieve configurations for all vector collections. @return a map where the key represents the name of the vector collection config and the value cor

Returns the codebase version of the node. For example, when running on hazelcast-3.8.jar, this would resolve to {@code Version.of(3,8,0)}. A node's co

Returns the write IO thread count @return write IO thread count

Increases the counter by `1`.

Inserts the given entry into this index store under the given value acting as an index key. @param value the value to insert the entry under

Invokes an {@link EntryProcessor} against the {@link javax.cache.Cache.Entry} specified by the provided key. If an {@link javax.cache.Cache.Entry} doe

Urgent messages, unlike normal messages, can go through 1. even if max allowed invocation count is reached 2. and in client disconnected state @retur

Detects whether this value represents a JSON array. If this is the case, this value is an instance of {@link JsonArray}. @return <code>true</code> if

Returns true if this Data is serialized in CompactFormat {@link com.hazelcast.config.CompactSerializationConfig} @return true if source object is ser

Returns if Management Center is allowed to access contents of Hazelcast data structures (for instance map entries) ({@code true}) or disallowed ({@cod

Returns {@code true} if any of the flags supplied in the argument are set. @param flagsToCheck the flags to check @return {@code true} if any of the

@return true if the index is global-per map, meaning there is just a single instance of this object per map. Global indexes are used in on-heap maps,

Checks if given REST endpoint group is enabled. It can return {@code true} even if the REST API itself is disabled.

Checks if the {@link Operation} is allowed to be invoked from the current thread. Invoking means that the operation can be executed on another thread,

Returns {@code true} if this instance represents a {@linkplain JetService#newLightJob(Pipeline) light job}. For a light job, many of the methods in th

@return {@code true} if a new slot had to be assigned in the last assignment invocation, {@code false} otherwise.

Checks if read-backup-data (reading local backup entries) is enabled for this map. @return {@code true} if read-backup-data is enabled, {@code false}

Convenience for {@link #kafka(Properties, FunctionEx, String...)} wrapping the output in {@code Map.Entry}.

Creates a new {@link MetricDescriptor}.

Gets the offset of given field. @param field the field whose offset is requested @return the offset of given field

Inserts the specified element into this queue if it is possible to do so immediately without violating capacity restrictions. Returns <code>true</code

Called when phase 1 of current snapshot is done in {@link StoreSnapshotTasklet} (it received barriers from all its processors and all async flush oper

Removes the oldest items or returns null of no such item exists. @return the oldest items.

Returns the local parallelism the vertex should be configured with. The default implementation returns {@link Vertex#LOCAL_PARALLELISM_USE_DEFAULT}.

Returns the represented edge's priority

Main entry point to obtain proxies for a target class loader. <p> Creates an Object valid for the Hazelcast version started with {@code targetClassLoa

Publishes an event for all event registrations belonging to the specified service name and topic. All events with the same {@code orderKey} are ordere

Performs a query on this indexes instance using the given predicate. @param predicate the predicate to evaluate. @param ownedPartitionCount

Returns a random key belonging to the partition with ID {@link #partitionId}.

Reads a collection from the given {@link ObjectDataInput}. It is expected that the next int read from the data input is the collection's size, then th

Returns the number of free spots @return number of remaining spaces.

@param key the key to be removed @param provenance origin of call to this method. @return value of removed entry or null if there is no matchin

Runs an operation in the calling thread. @param op the operation to execute in the calling thread

Sends a response. @param op the operation that got executed. @param response the response of the operation that got executed. @throws com.hazel

Keeps JSON representation compatible with IMDG 4.0 by using empty objects as values.

Sets the server socket endpoint config for {@link ProtocolType#CLIENT CLIENT} protocol. If another {@code ServerSocketEndpointConfig} was previously s