第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的写法。