Flink Table&SQL API的简单使用

1.需求 从csv文件中读取数据并保存为数据表 执行sql语句进行查询并输出 2.分析程序运行步骤 获取flink的执行环境，咱们这里用的是批处理的执行环境 获取table的执行环境，这里也获取的是批处理的执行环境 从csv文件中读取数据，以POJO的形式接收，返回DataSet 对flink如何从csv文件读取数据不清楚的朋友能够看我这篇博客！ http://www.javashuo.com/a

>>阅读原文<<