org.apache.flink.table.connector.source.lookup.cache

Class DefaultLookupCache.Builder

java.lang.Object

org.apache.flink.table.connector.source.lookup.cache.DefaultLookupCache.Builder

Enclosing class:

DefaultLookupCache

@PublicEvolving
public static class DefaultLookupCache.Builder
extends Object

Builder for DefaultLookupCache.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
DefaultLookupCache	build() Creates the cache.
DefaultLookupCache.Builder	cacheMissingKey(boolean cacheMissingKey) Specifies whether to cache empty value into the cache.
DefaultLookupCache.Builder	expireAfterAccess(java.time.Duration duration) Specifies the duration after an entry is last accessed that it should be automatically removed.
DefaultLookupCache.Builder	expireAfterWrite(java.time.Duration duration) Specifies the duration after an entry is created that it should be automatically removed.
DefaultLookupCache.Builder	maximumSize(long maximumSize) Specifies the maximum number of entries of the cache.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder()

Method Detail

expireAfterAccess

public DefaultLookupCache.Builder expireAfterAccess(java.time.Duration duration)

Specifies the duration after an entry is last accessed that it should be automatically removed.

expireAfterWrite

public DefaultLookupCache.Builder expireAfterWrite(java.time.Duration duration)

Specifies the duration after an entry is created that it should be automatically removed.

maximumSize

public DefaultLookupCache.Builder maximumSize(long maximumSize)

Specifies the maximum number of entries of the cache.

cacheMissingKey

public DefaultLookupCache.Builder cacheMissingKey(boolean cacheMissingKey)

Specifies whether to cache empty value into the cache.

Please note that "empty" means a collection without any rows in it instead of null. The cache will not accept any null key or value.

build

public DefaultLookupCache build()

Creates the cache.