[flink] branch master updated (1c044753b0f -> ed8870e602d)

[re...@apache.org]

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 1c044753b0f [FLINK-28373][network] Read a full buffer of data per file IO read request for sort-shuffle
     add ed8870e602d [FLINK-28417][table] Add interfaces for LookupCache and default implementation (#20196)

No new revisions were added by this update.

Summary of changes:
 .../flink/metrics/groups/CacheMetricGroup.java     |  54 +++
 .../metrics/groups/UnregisteredMetricsGroup.java   |  28 ++
 .../apache/flink/runtime/metrics/MetricNames.java  |   9 +
 .../metrics/groups/InternalCacheMetricGroup.java   |  91 +++++
 .../connector/source/lookup/LookupOptions.java     |  81 ++++
 .../source/lookup/cache/DefaultLookupCache.java    | 280 ++++++++++++++
 .../connector/source/lookup/cache/LookupCache.java |  76 ++++
 .../lookup/cache/DefaultLookupCacheTest.java       | 421 +++++++++++++++++++++
 8 files changed, 1040 insertions(+)
 create mode 100644 flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/groups/CacheMetricGroup.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/InternalCacheMetricGroup.java
 create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/lookup/LookupOptions.java
 create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/lookup/cache/DefaultLookupCache.java
 create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/lookup/cache/LookupCache.java
 create mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/lookup/cache/DefaultLookupCacheTest.java