[ https://issues.apache.org/jira/browse/FLINK-13252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jark Wu updated FLINK-13252: ---------------------------- Component/s: Table SQL / API > 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 > 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 (v7.6.14#76016)