[ 
https://issues.apache.org/jira/browse/FLINK-17397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17183001#comment-17183001
 ] 

Jark Wu commented on FLINK-17397:
---------------------------------

I think this issue is to support the same feature as Hive source which can be 
used as a lookup table in "processing time temporal join". In the 
implementation, it loads all the data under the specified path into a memory 
cache, and lookup the cache for every incoming left record. 

> Filesystem support lookup table source
> ---------------------------------------
>
>                 Key: FLINK-17397
>                 URL: https://issues.apache.org/jira/browse/FLINK-17397
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Connectors / FileSystem
>            Reporter: Jingsong Lee
>            Priority: Major
>              Labels: starter
>             Fix For: 1.12.0
>
>




--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to