[
https://issues.apache.org/jira/browse/FLINK-13252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf reopened FLINK-13252:
--------------------------------------
Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206.
> Common CachedLookupFunction for All connector
> ---------------------------------------------
>
> Key: FLINK-13252
> URL: https://issues.apache.org/jira/browse/FLINK-13252
> Project: Flink
> Issue Type: New Feature
> Components: Connectors / Common, Table SQL / API
> Reporter: Chance Li
> Assignee: Chance Li
> Priority: Minor
> Labels: auto-closed, pull-request-available, stale-assigned
> Time Spent: 10m
> Remaining Estimate: 0h
>
> shortly, it's a decorator pattern:
> # A CachedLookupFunction extends TableFunction<Row>
> # when needing the cache feature, the only thing is to construct this
> CachedLookupFunction with the real LookupFunction's instance. so it's can be
> used by any connector.
> # CachedLookupFunction will send the result directly if data has been cached
> or, to invoke the real LookupFunction to get data and send it after this data
> has been cached.
> # will have more cache strategies such as All.
> should add a new module called flink-connector-common.
> we also can provide a common Async LookupFunction using this pattern instead
> of too much implementation.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
