Flink Table流式环境创建与数据读取：示例代码及解析

//创建流处理环境
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
//创建TableEnvironment
StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);

//读取文件并注册成表
String filePath = 'data.txt';
DataStream<String> inputStream = env.readTextFile(filePath);
Table inputTable = tableEnv.fromDataStream(inputStream, 'id,name,age');

//将结果打印到控制台
tableEnv.toAppendStream(inputTable, Row.class).print();

//执行任务
env.execute();