Package io.github.flink.gcp.connector.spanner.table

Class SpannerLookupConfig

java.lang.Object

io.github.flink.gcp.connector.spanner.table.SpannerLookupConfig

All Implemented Interfaces:

Serializable

@Internal
public final class SpannerLookupConfig
extends Object
implements Serializable

Lookup options owned by the Spanner table source.

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
org.apache.flink.table.connector.source.lookup.cache.DefaultLookupCache	createPartialCache()
boolean	equals(Object other)
static SpannerLookupConfig	from(org.apache.flink.configuration.ReadableConfig config)
org.apache.flink.table.connector.source.lookup.LookupOptions.LookupCacheType	getCacheType()
int	getMaxRetries()
int	hashCode()
boolean	isAsync()

Methods inherited from class java.lang.Object

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

Method Details

from

public static SpannerLookupConfig from(org.apache.flink.configuration.ReadableConfig config)

isAsync

public boolean isAsync()

getCacheType

public org.apache.flink.table.connector.source.lookup.LookupOptions.LookupCacheType getCacheType()

getMaxRetries

public int getMaxRetries()

createPartialCache

public org.apache.flink.table.connector.source.lookup.cache.DefaultLookupCache createPartialCache()

equals

public boolean equals(Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object