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:50:00 UTC

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

     [ 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)