Sets the {@link ClientConfig} with configuration for a Hazelcast client to use for remote Map sink. <p> Only one of {@link #dataConnectionRef} and {@l

Creates a new DataConnection with the given config. <p> Such DataConnection is considered persistent and can't be removed. The DataConnection is close

Creates a mock with the given default {@link Answer} and the class of the given delegate instance in the target classloader. <p> Can be used if the ta

Creates the operation. @return the created operation.

Returns default codec registry used by the connector, which includes {@linkplain MongoClientSettings#getDefaultCodecRegistry} and {@link PojoCodecProv

Deletes multiple entries from the store. @param keys keys of the entries to delete.

Deregisters a listener with the given registration ID. @param serviceName service name @param topic topic name @param id registration

Destroy is equivalent to below operations in the given order: <ul> <li>clear all.</li> <li>close resources.</li> <li>unregister all listeners.</li> </

Give this method a job, and it will ensure it's no longer running. It will ignore if it's not running. If the cancellation fails, it will retry.

@param <I> type of the input object. @return an aggregator that calculates the max of the input values. Accepts null input values and null extracted v

{@inheritDoc}

Estimates the cardinality of the aggregation so far. If it was previously estimated and never invalidated, then a cached version is used. @return a c

Asserts that the {@code job} is eventually SUSPENDED and waits until the suspension cause is set.

Returns if a {@link DataConnection} with given name exists, created by SQL. @param name name of the DataConnection @return true if a {@link DataConne

Creates an {@code IntervalFunction} which starts from the specified wait interval, on the first attempt, and for each subsequent attempt uses a longer

Filters this queue according to supplied predicate. @param predicate used to filter this queue @param collection filtered entries will be added to t

Finds existing Executor config. @param name name of the config @return Executor config or {@code null} when requested Executor configuration does not

Finds existing FlakeIdGeneratorConfig config. @param name name of the config @return FlakeIdGenerator config or {@code null} when requested FlakeIdGe

Finds existing List config. @param name name of the config @return List config or {@code null} when requested List configuration does not exist