flink1.12.x Table API 和 SQL:Table 转换成 DataStream

说明

Table 可以转换为 DataStream 或 DataSet ,这样自定义流处理或批处理程序就可以继续在 Table API 或 SQL 查询的结果上运行了,比如:打印查询结果

  • 将 Table 转换为 DataStream 或 DataSet 时,需要 指定生成的数据类型,即:要将表的每一行转换成的数据类型
    例子:DataStream<Row> dsRes2 = stEnv.toAppendStream(res, Row.class);

  • 有些流式查询,其结果是动态更新的,如:聚合查询,select count(1) from table,来第一条数据,查询结果是1,来第二条数据,查询结果是2,应该删掉上一条结果

  • 转换有两种转换模式:追加(Append)模式和撤回(Retract)模式
    详见:flink1.12.x Table API 和 SQL:更新模式:追加Append、撤回Retract、更新插入Upsert


原文出处:/show_1IX23ZCdr2iN.html