[
https://issues.apache.org/jira/browse/FLINK-13252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chance Li updated FLINK-13252:
------------------------------
Docs Text: coming soon. lets me know what's your opinions. Thanks. (was:
coming soon. lets me know what's your opinion. Thanks.)
> 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
> Reporter: Chance Li
> Assignee: Chance Li
> Priority: Minor
>
> 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's LookupFunction.
> # 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.
> 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)
