Evaluates this expression, guaranteeing that this is a top-level call. @param row the row to evaluate this expression on @param context the expressio

Selects the best candidate to be evicted. The definition of the best depends on configured eviction policy. (LRU, LFU, custom, etc.) <p> It returns <c

Evict cache record store if eviction is required. <p>Eviction logic is handled as specified {@link com.hazelcast.config.EvictionPolicy} in {@link com.

Enables or disables the exactly-once behavior of the sink using two-phase commit of state snapshots. If enabled, the {@linkplain JobConfig#setProcessi

Enables or disables the exactly-once behavior of the sink using two-phase commit of state snapshots. If enabled, the {@linkplain JobConfig#setProcessi

Action to execute before each test scenario. @return {@code this} instance for fluent API

Name of the exported map, if the last valid snapshot was a terminal exported snapshot. Null otherwise.

Extend the lease time for an already locked key. @param key the locked key @param caller the identifier for the caller @param threadId the

Deduces the {@link AttributeType} of the given non-{@code null} attribute value. @param attributeValue the attribute value to deduce the type of. @re

Extract the excluded targets from the given {@link ProbeFunction}. @param function The {@link ProbeFunction} the excluded targets to

Finds a set for the given RelNode, and return subsets that have the physical trait. Every returned input is guaranteed to have a unique trait set. @r

@param data to extract the schema from @return schema of the given Compact Data @throws IOException @throws IllegalArgumentException if given data is

@param object to extract the schema from @return schema of the given Compact Data @throws IllegalArgumentException if given object is not compact seri

@param extractors the extractors @return this builder instance

Hash function based on Knuth's multiplicative method. This version is faster than using Murmur hash but provides acceptable behavior. @param k the in

Fetch minimally {@code size} items from the {@code pointers} position. Both the key and value are fetched on-heap. <p> NOTE: The implementation is fre

Fetch minimally {@code size} keys from the {@code pointers} position. The key is fetched on-heap. The method may return less keys if iteration has com

Convenience for {@link #filesBuilder(String, Class)} which reads all the files in the supplied directory as specific records using supplied {@code dat

Returns a sink that that writes the items it receives to Apache Avro files. Each processor will write to its own file whose name is equal to the proce

Convenience for {@link #filesBuilder} with the UTF-8 charset and with overwriting of existing files.

Returns a read-only {@link CacheSimpleConfig} configuration for the given name. <p> The name is matched by pattern to the configuration and by strippi

Returns the cache config with the given name or {@code null} if there is none. The name is matched by pattern to the configuration and by stripping th

Returns a {@link FlakeIdGeneratorConfig} configuration for the given flake ID generator name. <p> The name is matched by pattern to the configuration

finds min choosing a lower bound. @param a first number @param b second number @param notMin lower bound