[
https://issues.apache.org/jira/browse/FLINK-17397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17183227#comment-17183227
]
Kurt Young commented on FLINK-17397:
------------------------------------
{quote}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.
{quote}
I don't think this can make filesystem connector a LookupTableSource. This
should be treated as support a ScanTableSource in processing time temporal
join. Processing temporal join and lookup source are two separate things, not
all tables which we want to support processing time temporal join should be
forced to have lookup capability.
> FileSystemTableFactory supports LookupableTableSource
> ------------------------------------------------------
>
> 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)
