You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by re...@apache.org on 2022/08/04 14:54:39 UTC
[flink] branch master updated (bc29e574105 -> 5405239dec0)

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