其他函数
数组函数
函数 |
返回值类型 |
描述 |
---|---|---|
CARDINALITY(ARRAY) |
INT |
返回数组的元素个数。 |
ELEMENT(ARRAY) |
- |
使用单个元素返回数组的唯一元素。 如果数组为空,则返回null。如果数组有多个元素,则抛出异常。 |
示例:
返回数组的元素个数为3。
insert into temp select CARDINALITY(ARRAY[TRUE, TRUE, FALSE]) from source_stream;
返回'HELLO WORLD'。
insert into temp select ELEMENT(ARRAY['HELLO WORLD']) from source_stream;
属性访问函数
函数 |
返回值类型 |
描述 |
---|---|---|
tableName.compositeType.field |
- |
选择单个字段,通过名称访问Apache Flink复合类型(如Tuple,POJO等)的字段并返回其值。 |
tableName.compositeType.* |
- |
选择所有字段,将Apache Flink复合类型(如Tuple,POJO等)和其所有直接子类型转换为简单表示,其中每个子类型都是单独的字段。 |