[
https://issues.apache.org/jira/browse/FLINK-13252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chance Li updated FLINK-13252:
------------------------------
Description:
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.
was:
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.
> 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.
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
