Chance Li created FLINK-13252:
---------------------------------
Summary: 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
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.
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
