@param source the source object. @return the current value of the source object. @throws Exception if something fails while getting the value.

<p> Creates and returns a cluster wide iterator to iterate on all entries owned by this cache. </p> <p> The ordering of iteration over entries is unde

The returned stream stage emits all the items from the supplied list of integers. It uses the integer as both timestamp and data. <p> When it exhausts

Parses {@code hazelcast-runtime.properties} for {@code BuildInfo}; also checks for overrides in System.properties. Never cache result of this method i

Creates or returns the distributed Ringbuffer instance with the specified name. @param name name of the distributed Ringbuffer @param <E> the type of

Sets the {@link EvictionPolicy} of this eviction configuration. @param evictionPolicy the {@link EvictionPolicy} of this eviction configuration @retu

@return the {@code long} value at the cursor's current position

Assert the contents of a given table directly via JDBC

@param <I> type of the input object. @return an aggregator that counts the input values. Accepts nulls as input values. Aggregation result type Long.

Returns the {@code EntryView} for the specified key. <p> <b>Not to misuse this method, please know these points:</b> <lu> <li>This method cannot be u

Creates a new {@code InternalCompletableFuture} that is already completed with the value given as argument as its completion value. @param result

Called to report the value of watermark observed on the queue at {@code queueIndex}. @return {@code true} if the queues were reordered by this waterm

Returns the metrics collection config.

Sets the input objects for processor. <p> The {@code input} can contain {@link Watermark}s; they will be delivered to the {@link Processor#tryProcessW

Similarly to {@link #join()}, returns the value when complete or throws an unchecked exception if completed exceptionally. Unlike {@link #join()}, che

{@inheritDoc} <p> No atomicity guarantees are given. It could be that in case of failure some of the key/value-pairs get written, while others are not

Shuts down all member {@link HazelcastInstance}s running on this JVM. It doesn't shut down all members of the cluster but just the ones running on thi

Creates a byte array from a string. @param s the string. @return the byte array created from the string.

Gets the {@link EvictionConfig} instance of the eviction configuration for this {@link IMap}. @return the {@link EvictionConfig} instance of the evic

Looks up the {@link ReflectiveAttributeLookupPolicy#REFLECTIVE_ATTRIBUTE_LOOKUP_POLICY} property from the provided {@link HazelcastProperties} instanc

Changes state of the cluster to the {@link ClusterState#PASSIVE} transactionally, then triggers the shutdown process on each node. Transaction will be

@return DDL statement to create this object.

Convenience method to execute a distributed non-DQL statement (that is a statement that does not return rows) with the given parameter values. <p> Con

Parses the given input string as JSON. The input must contain a valid JSON value, optionally padded with whitespace. @param string the input

Changes state of the cluster to the given state transactionally. Transaction will be {@code TWO_PHASE} and will have 1 durability by default. If you w

Quietly attempts to close a {@link Closeable} or {@link AutoCloseable} resource, swallowing any exception. @param closeable the resource to close. If

A primitive that returns a new accumulator. If the {@code deduct} primitive is defined, the accumulator object <strong>must</strong> properly implemen

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

Sets the port of the RestConfig. @param port the new port. @return the updated RestConfig.

Advances the given iterator on this storage. @param iterator the iterator to advance. @return {@code true} if the iterator is advanced to the next me

Used for {@link com.hazelcast.security.SecurityInterceptor} Method name which called via a distributedObject for map.put, methodName will be 'put' For

@return partition ID of this store

@param version other version to compare to @return {@code true} if this version is greater than or equal to {@code version}

Creates a new SwCounter with 0 as initial value. @return the created SwCounter, set to zero.

Sets the Near Cache configuration @param nearCacheConfig the Near Cache configuration @return the updated map configuration

Writes the obj to a byte array. This call is exactly the same as calling {@link #toData(Object)} and then calling {@link Data#toByteArray()}. But it d

Add a listener object to listen for lifecycle events. @param lifecycleListener the listener object @return the listener ID

Declares that the edge is distributed. A non-distributed edge only transfers data within the same member. If the data source running on local member i

Evaluates this expression. @param row the row to evaluate this expression on @param context the expression evaluation context @return the result

Wrapper for {@link MethodHandles.Lookup#findVarHandle(Class, String, Class)} to allow easier usage when assigning to {code static} fields: <ul> <li>In

Returns the job with the given id or {@code null} if no such job could be found.

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

Ignores the given exception. @param t the exception to ignore

Scans the source object for any fields/methods that have been annotated with {@link Probe} annotation, and registers these fields/methods as static pr

Retrieves and removes the head of this queue, waiting if necessary until an element becomes available. @return the head of this queue @throws Interru

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

Returns the unified event type

Returns the state of the service about if it is active or not. @return <code>true</code> if the service is active, otherwise <code>false</code>

Returns the job ID. Job id is unique for job submission and doesn't change when the job restarts. It's also unique for all running and archived jobs.

@return the interfaces

Returns the last access time for the entry. <p> <b>Warning:</b> This method returns {@code -1} if statistics are not enabled or not implemented. @ret