[
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.
# 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.
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.
# 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 step by step.
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.
> 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.
> # 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)
