This method is used when we are cleaning processed instances of this class. Caring only reference equality of objects because wanting exactly remove t

Evaluates the {@code filter} using a {@link CachedQueryEntry} together with the value {@link Extractors} configured for this map. The filter must be o

Return {@link EntryEventData} created & cached by invocations to {@link #getOrCreateEventData(String, Address, Data, Object, Object, Object, int,

Evicts entries from this record-store. @param excludedKey this key has lowest priority to be selected for eviction

Check if record is reachable according to TTL or idle times. @param now current time in millis @param backup <code>true</code> if a backup

Executes a task. @param task task to execute. @throws RejectedExecutionException if this task cannot be accepted for execution.

Constructs a local execution with retry logic. The operation must not have an {@link OperationResponseHandler}, it must return a response, and it must

Executes a task on all of the known cluster members. @param command a task executed on all of the known cluster members

invoke delayed execution.

Returns if a {@link DataConnection} with given name exists in the config @param name name of the DataConnection @return true if a {@link DataConnecti

Exports a state snapshot and saves it under the given name. You can start a new job using the exported state using {@link JobConfig#setInitialSnapshot

Returns a supplier of processors for a vertex that emits the same items it receives, but only those that pass the given predicate. The predicate funct

@param types vertices of a type graph, which may be disconnected @implNote At finalization, the {@link #digest} is also computed, for which the field

Finds a {@link MigratablePipeline pipeline} to migrate @return Handler to migrate or <code>null</code> if no suitable candidate is found

Finds existing Ringbuffer config. @param name name of the config @return Ringbuffer config or {@code null} when requested Ringbuffer configuration do

Logs a message at the {@link Level#FINEST} level. @param message the message to log

Force a new transaction outside of the snapshot cycle. The next call to {@link #activeTransaction()} will return a new transaction.

Returns a supplier of processors for a vertex that performs a stateful flat-mapping of its input. {@code createFn} returns the object that holds the s

Returns a supplier of processors for a vertex that applies the provided item-to-traverser mapping function to each received item and emits all the ite

Flushes the internal buffer but does not flush the wrapped writer.

Resolves given string value to one of values of this enum.

Fsyncs a directory on Linux and MacOSX. On Windows, this method does nothing. <p> @param dir the directory to fsync. @throws IOException if an I/O err

@see IMap#get(Object)

@param uuid UUID of the member to get connection of @return connection if available, null otherwise