You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Chance Li (JIRA)" <ji...@apache.org> on 2019/07/14 16:44:00 UTC

[jira] [Created] (FLINK-13252) Common CachedLookupFunction for All connector

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)