Sets the provided {@link NodeEngine} reference as this thread's {@link ThreadLocal} instance for use in Namespace awareness. @param nodeEngine the {@

@return the components of this index.

Returns the internal jet service backend

Directly access local Cache Statistics. @return CacheStatistics instance or an empty statistics if not enabled.

Gets the partition migration endpoint. @return the partition migration endpoint

Returns the security configuration for this hazelcast instance. This includes configuration for security interceptors, permissions, etc. @return the

@return true if the current item is an array

Writes the given int value to given address. @param address the address where the int value will be written to @param x the int value to be wri

Reads one item from the Ringbuffer. <p> If the sequence is one beyond the current tail, this call blocks until an item is added. This means that the r

Registers dynamic metrics sources that collect metrics in each metrics collection cycle. @param metricsProvider The object that provides dynamic metr

Sets if uploading resources when submitting the job enabled

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

Closes this connection. <p> Pending packets on this connection are discarded <p> If the Connection is already closed, the call is ignored. So it can s

Creates a new instance of an object given the construction argument @param arg construction argument @return a new instance of an object

Flat-maps the given {@code event} by (possibly) prepending it with a watermark. Designed to use when emitting from traverser: <pre>{@code Traverse

After reaching this size, node sends buffered events to {@code QueryCache}. @return the batch size

@param fieldName the name of the field @return the value of the field @throws HazelcastSerializationException if the field name does not exist

Gets the local member instance. <p> The returned value will never be null, but it may change when local lite member is promoted to a data member via {

Returns the event old value

Returns the current member that owns this partition. <p> The returned value could be stale as soon as it is returned. <p> It can be that null is retur

Gets the {@link Address} of the other side of this Connection. @return the Address.

Returns a supplier of a processor that swallows all its normal input (if any), does nothing with it, forwards the watermarks, produces no output and c

Asynchronously associates the specified key with the given value if and only if there is not yet a mapping defined for the specified key. <p> This is

Sets the split brain protection name for operations of the data structure. @param splitBrainProtectionName the split brain protection name @return th

Transforms the pipeline into a Jet DAG, which can be submitted for execution to a Jet instance. @deprecated Jet performs this transformation on the se

Adds MembershipListener to listen for membership updates. <p> The addMembershipListener method returns a registration ID. This ID is needed to remove

Adds single event parameter to the parameters Map. @param key Must not be {@code null} @return this instance

Registers the {@link AggregateOperation1#accumulateFn()} accumulate} primitive. Also selects the fixed-arity variant of the aggregate operation. <p> T

@see org.assertj.core.api.AbstractIterableAssert#containsExactlyInAnyOrderElementsOf(Iterable)

Evicts all keys from this map except the locked ones. <p> If a {@code MapStore} is defined for this map, deleteAll is <strong>not</strong> called by t

Gets the connection for a given address. If the connection does not exist, it returns null. @param address the address of remote side of the connecti

Returns all registrations belonging to the given service and topic. @param serviceName service name @param topic topic name @return registratio

Returns extracted object type for non-generic getters. It is only applicable when extracted object type can be determined before running the getter.

{@code Serializable} variant of {@link Predicate#negate()}.

Fast method of finding the next power of 2 greater than or equal to the supplied value. <p> If the value is &lt;= 0 then 1 will be returned. <p> This

Registers a probe. If a probe for the given name exists, it will be overwritten. @param source the object that the probe function to be used with

Sets the {@link RoutingMode} for this client to use when connecting to cluster members. @param routingMode the legacy {@link RoutingMode} enumeration

@return a {@link Version} initialized with this {@code MemberVersion}'s major.minor version.

Not idempotent: must be called exactly once per invocation.

Returns whether the multimap contains the given key-value pair. <p> <b>Warning:</b> This method uses {@code hashCode} and {@code equals} of the binary

Create simple index definition with the given attributes and initialize it's name upfront. For testing purposes. @param type Index type. @param attri

Atomically sets the given value and returns the old value. @param newValue the new value @return the old value

Creates a new TransactionOptions configured with default settings. @return the created default TransactionOptions. @see #TransactionOptions()

@param selectDatabaseNameFn selects database name for each item individually @param selectCollectionNameFn selects collection name for each item indiv

Returns a streaming source that generates events of type {@link SimpleEvent} at the specified rate. <p> The source supports {@linkplain StreamSourceSt

HC specific settings, operands etc. use this method. Creates a lowercase string from the given string. @param s the given string @return a lowercase

The returned InternalGenericRecord is not thread safe. It is not meant to return to the user from our API's like IMap, IQueue etc. It will only be use

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

Asynchronously removes the given key, returning an {@link CompletionStage} on which the caller can register further computation stages to be invoked u

Number of synchronous backups. For example, if 1 is set as the backup count, then all entries of the map will be copied to another JVM for fail-safety

Serialize the event as JSON, for sending to Management Center.

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