@@ -11,12 +11,12 @@ AS SELECT id, name, age FROM source_table WHERE mod(id, 10) = 0;
1111ALTER TABLE MyTable ADD category_id STRING COMMENT 'identifier of the category';
1212
1313-- add columns, constraint, and watermark
14- -- ALTER TABLE MyTable ADD (
15- -- log_ts STRING COMMENT 'log timestamp string' FIRST,
16- -- ts AS TO_TIMESTAMP(log_ts) AFTER log_ts,
17- -- PRIMARY KEY (id) NOT ENFORCED,
18- -- WATERMARK FOR ts AS ts - INTERVAL '3' SECOND
19- -- );
14+ ALTER TABLE MyTable ADD (
15+ log_ts STRING COMMENT 'log timestamp string' FIRST,
16+ ts AS TO_TIMESTAMP(log_ts) AFTER log_ts,
17+ PRIMARY KEY (id) NOT ENFORCED,
18+ WATERMARK FOR ts AS ts - INTERVAL '3' SECOND
19+ );
2020
2121-- add a new partition
2222ALTER TABLE MyTable ADD PARTITION (p1=1,p2='a') with ('k1'='v1');
@@ -29,12 +29,12 @@ ALTER TABLE MyTable MODIFY measurement double COMMENT 'unit is bytes per second'
2929
3030-- modify definition of column log_ts and ts, primary key, watermark. They must exist in table schema
3131
32- -- ALTER TABLE MyTable MODIFY (
33- -- log_ts STRING COMMENT 'log timestamp string' AFTER `id`, -- reorder columns
34- -- ts AS TO_TIMESTAMP(log_ts) AFTER log_ts,
35- -- PRIMARY KEY (id) NOT ENFORCED,
36- -- WATERMARK FOR ts AS ts -- modify watermark strategy
37- -- );
32+ ALTER TABLE MyTable MODIFY (
33+ log_ts STRING COMMENT 'log timestamp string' AFTER `id`, -- reorder columns
34+ ts AS TO_TIMESTAMP(log_ts) AFTER log_ts,
35+ PRIMARY KEY (id) NOT ENFORCED,
36+ WATERMARK FOR ts AS ts -- modify watermark
37+ );
3838
3939-- drop a column
4040ALTER TABLE MyTable DROP measurement;
0 commit comments