This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git
The following commit(s) were added to refs/heads/master by this push: new fe780cf7 [FLINK-30094] Append a left table DDL in Lookup Join character fe780cf7 is described below commit fe780cf70aea008fead49a14ac0b71cd403db97b Author: Stan <53285109+houhang1...@users.noreply.github.com> AuthorDate: Mon Nov 21 10:12:52 2022 +0800 [FLINK-30094] Append a left table DDL in Lookup Join character This closes #393 --- docs/content/docs/development/lookup-join.md | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/docs/content/docs/development/lookup-join.md b/docs/content/docs/development/lookup-join.md index abb6d156..2084f811 100644 --- a/docs/content/docs/development/lookup-join.md +++ b/docs/content/docs/development/lookup-join.md @@ -51,6 +51,20 @@ CREATE TABLE customers ( -- Launch a streaming job to update customers table INSERT INTO customers ... + +-- Create a temporary left table, like from kafka +CREATE TEMPORARY TABLE Orders ( + order_id INT, + total INT, + customer_id INT, + proc_time AS PROCTIME() +) WITH ( + 'connector' = 'kafka', + 'topic' = '...', + 'properties.bootstrap.servers' = '...', + 'format' = 'csv' + ... +); ``` Then, you can use this table in lookup join.