@@ -332,10 +332,6 @@ For further information how to store catalog configurations, see [Flink's Catalo
332332:: :
333333
334334# ## Create Tables
335- <Tabs groupId="lake-tabs">
336- <TabItem value="paimon" label="Paimon" default>
337-
338-
339335Running the following SQL to create Fluss tables to be used in this guide :
340336` ` ` sql title="Flink SQL"
341337CREATE TABLE fluss_order (
@@ -370,46 +366,6 @@ CREATE TABLE fluss_nation (
370366);
371367```
372368
373- </TabItem >
374-
375- <TabItem value =" iceberg " label =" Iceberg " >
376-
377-
378- Running the following SQL to create Fluss tables to be used in this guide:
379- ``` sql title="Flink SQL"
380- CREATE TABLE fluss_order (
381- ` order_key` BIGINT ,
382- ` cust_key` INT NOT NULL ,
383- ` total_price` DECIMAL (15 , 2 ),
384- ` order_date` DATE ,
385- ` order_priority` STRING,
386- ` clerk` STRING,
387- ` ptime` AS PROCTIME()
388- );
389- ```
390-
391- ``` sql title="Flink SQL"
392- CREATE TABLE fluss_customer (
393- ` cust_key` INT NOT NULL ,
394- ` name` STRING,
395- ` phone` STRING,
396- ` nation_key` INT NOT NULL ,
397- ` acctbal` DECIMAL (15 , 2 ),
398- ` mktsegment` STRING,
399- PRIMARY KEY (` cust_key` ) NOT ENFORCED
400- );
401- ```
402-
403- ``` sql title="Flink SQL"
404- CREATE TABLE fluss_nation (
405- ` nation_key` INT NOT NULL ,
406- ` name` STRING,
407- PRIMARY KEY (` nation_key` ) NOT ENFORCED
408- );
409- ```
410-
411- </TabItem >
412- </Tabs >
413369## Streaming into Fluss
414370
415371First, run the following SQL to sync data from source tables to Fluss tables:
@@ -564,10 +520,13 @@ SELECT o.order_key,
564520 c .acctbal ,
565521 c .mktsegment ,
566522 n .name
567- FROM fluss_order o
568- LEFT JOIN fluss_customer FOR SYSTEM_TIME AS OF ` o` .` ptime` AS ` c`
523+ FROM (
524+ SELECT * , PROCTIME() as ptime
525+ FROM ` default_catalog` .` default_database` .source_order
526+ ) o
527+ LEFT JOIN fluss_customer FOR SYSTEM_TIME AS OF o .ptime AS c
569528 ON o .cust_key = c .cust_key
570- LEFT JOIN fluss_nation FOR SYSTEM_TIME AS OF ` o ` . ` ptime` AS ` n `
529+ LEFT JOIN fluss_nation FOR SYSTEM_TIME AS OF o . ptime AS n
571530 ON c .nation_key = n .nation_key ;
572531```
573532
0 commit comments