Returns an aggregate operation that finds the arithmetic mean (aka. average) of the {@code double} values it obtains by applying {@code getDoubleValue

Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB {@link BatchSource} for the Pipeline API. <p> Here's an examp

Returns number of IDs in the set.

Returns a Spring Bean {@link ServiceFactory}. The factory creates a context object which autowires the {@link ApplicationContext}. The context object

Returns an {@link Iterator} over the sequence of JSON objects parsed from given {@code reader}. Each object is converted to the given {@code type}.

Called before node attempts to join to the cluster

Called before <tt>Node.shutdown()</tt>

Called before node is started

Set the function to bind values to a {@code PreparedStatement} created with the query set with {@link #updateQuery(String)}. The function should not e

Blocks the outbox so it allows the caller only to offer the current unfinished item. If there is no unfinished item, the outbox will reject all items

@param timeoutMillis the maximum time in millis to block on join @return true is cluster has been joined, false if timed out @throws InterruptedExcept

Converts given bson timestamp to unix epoch.

Builds the Sink object that you pass to the {@link GeneralStage#writeTo(Sink)} method.

Convenience for {@link FileSourceBuilder#buildWatcher(BiFunctionEx)}.

Called by SYNC methods of {@link NearCachedClientCacheProxy}. This method first calls a remote operation then, depending on the {@link com.hazelcast.

Called by ASYNC methods of {@link NearCachedClientCacheProxy}. This method first calls a remote operation then, depending on the {@link com.hazelcast

Returns a source that fetches entries from a Hazelcast {@code ICache} with the given name and emits them as {@code Map.Entry}. It leverages data local

Returns a projection that converts the {@link EventJournalCacheEvent} to a {@link java.util.Map.Entry} using the event's new value as a value. @see S

Calculate the part buffer size finding minimum of <br/> 1. size from the properties if defined, or the default value <br/> 2. jarSize

Calculate the entry's value cost in memory @param value The entry's value @return The cost of this value in memory.

Decides how entries should be passed to handlers. It passes entries to handler's single or batch handling methods. @param delayedEntries sorted entri

@return {@code true} if this index can evaluate a predicate of the given predicate class, {@code false} otherwise.

Exports and saves a state snapshot with the given name, and then cancels the job without processing any more data after the barrier (graceful cancella

Canonicalizes the given {@link Comparable} value for the purpose of a hash-based lookup. <p> Special numeric canonicalization logic is used for {@link

Atomically sets the cached value to the given new value if the current cached value {@code ==} the expected value. @param expectedValue the expected

Checks if a {@link EvictionConfig} is valid in its context. @param evictionConfig the {@link EvictionConfig}

Checks whether current {@link Subject} has been granted specified permission or not. @param subject the current subject @param permission the specifi

Check if the current Subject has the given permission granted (or implied). @param permission Permission to be checked @throws AccessControlException

If {@link ResourceChecks#NEVER}, the database and collection will be automatically created on the first usage. Otherwise, querying for a database or c