如何使用GENERATE_SERIES函數 - Realtime Compute for Apache Flink

使用GENERATE_SERIES函數，產生一個連續的整型區間資料。

文法

GENERATE_SERIES(BIGINT from, BIGINT to)

入參

參數	資料類型
from	BIGINT類型，指定下界，包含下界值。
to	BIGINT類型，指定上界，包含上界值。

樣本

測試資料
s(BIGINT NOT NULL)
e(BIGINT NOT NULL)
1
3
-2
1

測試語句

CREATE TEMPORARY TABLE input_table(
  s BIGINT NOT NULL, 
  e BIGINT NOT NULL
) WITH (
  'connector' = 'datagen'
);

CREATE TEMPORARY TABLE output_table(
  s BIGINT NOT NULL, 
  e BIGINT NOT NULL, 
  v BIGINT NOT NULL
) WITH (
  'connector' = 'print'
);

insert into output_table
SELECT s, e, v FROM input_table, lateral table(GENERATE_SERIES(s, e))
as t(v);

測試結果
s(BIGINT)
e(BIGINT)
v(BIGINT)
1
3
1
1
3
2
1
3
3
-2
1
-2
-2
1
-1
-2
1
0
-2
1
1

s(BIGINT)	e(BIGINT)	v(BIGINT)
1	3	1
1	3	2
1	3	3
-2	1	-2
-2	1	-1
-2	1	0
-2	1	1

s(BIGINT NOT NULL)	e(BIGINT NOT NULL)
1	3
-2	1