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
