Flink数据查询和过滤

对于已经在 Tableenvironment中注册的数据表，可以通过scan方法查询已经在Catalog中注册的表并转换为 Table结构，然后在 Table上使用 select操作符查询需要获取的指定字段。如以下代码所示从 Tableenvironment中查询已经注册的 Sensors表。

Table API中可以使用类似SQL中的as方法对字段进行重命名，例如将 Sensors表中的字段按照位置分别命名为a、b、c、d。

可以使用 filter或 where方法过滤字段和检索条件，将需要的数据检索出来。注意，在 Table API语法中进行相等判断时需要三个等号连接表示。