[
https://issues.apache.org/jira/browse/HUDI-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Chen updated HUDI-6563:
-----------------------------
Sprint: Sprint 2023-04-26
> Supports flink lookup join
> ---------------------------
>
> Key: HUDI-6563
> URL: https://issues.apache.org/jira/browse/HUDI-6563
> Project: Apache Hudi
> Issue Type: New Feature
> Components: flink
> Reporter: waywtdcc
> Priority: Major
> Labels: pull-request-available
>
> Supports flink lookup join
>
> {code:java}
> CREATE TABLE `datagen_source`(
> id int,
> name STRING,
> proctime as PROCTIME()
> ) WITH (
> 'connector' = 'datagen',
> 'rows-per-second'='1',
> 'number-of-rows' = '2',
> 'fields.id.kind'='sequence',
> 'fields.id.start'='1',
> 'fields.id.end'='2'
> );select o.id,o.name,b.id as id2
> from datagen_source AS o
> join hudi_table/*+ OPTIONS('lookup.join.cache.ttl'= '2 day') */ FOR
> SYSTEM_TIME AS OF o.proctime AS b on o.id = b.id; {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
