[ https://issues.apache.org/jira/browse/FLINK-13252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321491#comment-17321491 ]
Flink Jira Bot commented on FLINK-13252: ---------------------------------------- This issue and all of its Sub-Tasks have not been updated for 180 days. So, it has been labeled "stale-minor". If you are still affected by this bug or are still interested in this issue, please give an update and remove the label. In 7 days the issue will be closed automatically. > 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: pull-request-available, stale-minor > 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)