import org.apache.flink.table.api.*; 
import static org.apache.flink.table.api.Expressions.*; 
EnvironmentSettings settings = EnvironmentSettings.newInstance().inStreamingMode().build(); 
TableEnvironment tEnv = TableEnvironment.create(env);

官方文档

百度一下，值得拥有

在这没有任何意义，就是给你演示一下。执行个算子给你看看而已。为了代表实际生产中的一些了转换