Alink教程(Python版)
该文档涉及的组件

第2.8节 Schema String

Alink在进行表数据的读取和转换时,有时需要显式声明数据表的列名和列类型信息,即Schema信息。Schema String就是将此信息使用字符串的方式进行描述的,这样便于将该信息作为Java函数或者Python函数的参数输入。

其定义格式如下:

colname coltype[, colname2 coltype2[, ...]]

例如,"f0 string, f1 bigint, f2 double",表明数据表共有3列,名称分别为f0、f1和f2;其对应的类型分别为字符串类型、长整型和双精度浮点型。熟悉SQL的读者会发现,该格式与CREATE TABLE的数据列名称和类型的定义格式相同。

关于各种列类型的写法,可以参照Flink Type与Type String的对应表(见表2-3)。注意:为了适应不同用户的习惯,同一个Flink Type可能对应着多种Type String的写法。