[ 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)