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

Interface CacheReloadTrigger

All Superinterfaces:

AutoCloseable, Serializable

All Known Implementing Classes:

PeriodicCacheReloadTrigger, TimedCacheReloadTrigger

@PublicEvolving
public interface CacheReloadTrigger
extends AutoCloseable, Serializable

Customized trigger for reloading lookup table entries.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	CacheReloadTrigger.Context Context of CacheReloadTrigger for getting information about times and triggering reload.

Method Summary

Modifier and Type	Method and Description
void	open(CacheReloadTrigger.Context context) Open the trigger.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

open

void open(CacheReloadTrigger.Context context)
   throws Exception

Open the trigger.

Throws:

Exception