大数据_Flink_Java版_TableAPI和FlinkSQL(3)_表环境配置Flink工作笔记0083

然后我们再来看,我们创建一个例子

TableTest2_CommonApi来看一下,要使用table api 和flink sql

首先要创建哪些环境,可以看到,首先还是写上

获取环境的代码

然后设置,并行度是1,然后

这里再用StreamTableEnvironment.create(env);

这里获取StreamTableEnvironment,获取这个

这里我们去看看

这里cr