聊下 DataStream 与 TableEnvironment 创建

创建 StreamTableEnvironment

  1. public class main {
  2. //创建 StreamExecutionEnvironment 
  3.     StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
  4.     //创建 StreamTableEnvironment
  5.     StreamTableEnvironment tenv = StreamTableEnvironment.create(env);
  6. }

创建 BatchTableEnvironment

  1. public class main {
  2.     ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
  3.     BatchTableEnvironment tenv = BatchTableEnvironment.create(env);
  4. }


DataStream转Table实例

  1. public class main {
  2. //创建 StreamExecutionEnvironment 
  3.     StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
  4.     //创建 StreamTableEnvironment
  5.     StreamTableEnvironment tenv = StreamTableEnvironment.create(env);
  6.     DataStream<Tuple2<String,String>> = ...;
  7.     // DataStream 转 Table
  8.     Table table1 = tableEnv.fromDataStream(stream);
  10.     // DataStream 转 Table 并带上字段
  11.     Table table1 = tableEnv.fromDataStream(stream，"string1,string2");
  12. }

Table 转 DataStream 实例

  1. public class main {
  2. //创建 StreamExecutionEnvironment 
  3.     StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
  4.         //创建 StreamTableEnvironment
  5.     StreamTableEnvironment tenv = StreamTableEnvironment.create(env);
  7. }

```