This is an automated email from the ASF dual-hosted git repository.
renqs pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from bc29e574105 [FLINK-28459][table-planner] Supports non-atomic CREATE
TABLE AS SELECT (#20392)
add 5405239dec0 [FLINK-28419][table] Add runtime provider interface for
full caching lookup + implement Periodic and Timed cache reload triggers
No new revisions were added by this update.
Summary of changes:
.../source/lookup/FullCachingLookupProvider.java | 68 ++++++++
.../connector/source/lookup/LookupOptions.java | 63 +++++++
.../lookup/cache/trigger/CacheReloadTrigger.java | 52 ++++++
.../cache/trigger/PeriodicCacheReloadTrigger.java | 135 +++++++++++++++
.../cache/trigger/TimedCacheReloadTrigger.java | 143 ++++++++++++++++
.../trigger/PeriodicCacheReloadTriggerTest.java | 131 +++++++++++++++
.../trigger/ScheduleStrategyExecutorService.java | 58 +++++++
.../lookup/cache/trigger/TestTriggerContext.java | 62 +++++++
.../cache/trigger/TimedCacheReloadTriggerTest.java | 185 +++++++++++++++++++++
.../apache/flink/core/testutils/ScheduledTask.java | 4 +
10 files changed, 901 insertions(+)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/lookup/FullCachingLookupProvider.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/lookup/cache/trigger/CacheReloadTrigger.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/lookup/cache/trigger/PeriodicCacheReloadTrigger.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/lookup/cache/trigger/TimedCacheReloadTrigger.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/lookup/cache/trigger/PeriodicCacheReloadTriggerTest.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/lookup/cache/trigger/ScheduleStrategyExecutorService.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/lookup/cache/trigger/TestTriggerContext.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/lookup/cache/trigger/TimedCacheReloadTriggerTest.java
