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 <[email protected]>
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.
