Only used for testing purposes. <p> Sets {@link SubscriberContext} implementation used by this query-cache context. @param subscriberContext the supp

Sets the System properties for JSR related tests including the JCache provider type. @param providerType "server" or "client" according to your test

Sets the time to live in seconds which is the maximum number of seconds for each item to stay in the ringbuffer before being removed. <p> Entries that

Sets the URI string, which is the global identifier of the {@link com.hazelcast.cache.ICache}. @param uriString the URI string to set for this {@link

Sets the list of {@link VectorIndexConfig} instances for this vector collection configuration. Clears the existing vector index configurations and rep

Returns {@code true} if we should keep queue item data in-memory. This is the case if the queue store is disabled, we have not yet hit the in-memory l

@return {@code true} to offload execution of {@code prepareReplicationOperation} to Hazelcast internal async executor or {@code false} to execute on p

Shuts down Networking and closes all registered channels. <p> Shutting down doesn't need to be a permanent state. It could be that for e.g. cluster me

Shutdowns {@link MemcachedClient} ignoring exceptions. Problems are just logged on FINE level. Workaround a {@link java.util.ConcurrentModificationExc

@see IMap#size()

@param statsEnabled set {@code true} if stats will be collected for the indexes, otherwise set {@code false} @return this builder

Stores the key-value pair. @param key key of the entry to store @param value value of the entry to store

Stores multiple items. Implementation of this method can optimize the store operation. <p> Exceptions thrown by this method prevents {@link com.hazelc

Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB {@link StreamSource} for the Pipeline API. <p> The created so

Returns a supplier of processors for {@link Sources#cacheJournal(String, JournalInitialPosition)}.

Returns a supplier of processors for {@link KafkaSources#kafka(Properties, FunctionEx, String...)}.

Returns a supplier of processors for {@link Sources#socket(String, int, Charset)}.

Submits a logging task to the executor that logs the connectivity of the client to the cluster. The task will log the connectivity of the client with

Subscribe to the event journal for this reader and a specific partition ID. @param adapter the adapter for a specific data structure @param parti

Returns meta-supplier with default local parallelism of 1, which will return the same items from all instances.

The {@link ResettableSingletonTraverser} is passed as a first argument to {@code callAsyncFn}, it can be used if needed.

The {@link ResettableSingletonTraverser} is passed as a first argument to {@code callAsyncFn}, it can be used if needed.

Use {@link SourceProcessors#readJdbcP}.

Returns whether the given `expression` is supported by the processors this connector returns. If it returns true, then this expression will be passed

Returns the name of the table this record is part of. @return name of the source table for the current record

Takes an item from this queue. If no item is available, the call blocks. This method should always be called by the same thread. @param priorityOnly