flink 1.10.1 java版本table api和flink sql Demo

本文的基础环境可以参考flink 1.10.1 java版本wordcount演示 (nc + socket)
本案例只是对table api的简单测试，对table api和sql有一个最基本的了解。sql语句执行时针对的是每次接受到的一个数据，在实际业务环境中，不会这样操作的。
1. 添加依赖

org.apache.flink
flink-table-planner_2.11
1.10.1

不同版本，这里可能需要添加到包不同
2. 程序代码
package com.demo.sql;

import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.stream

flink 1.10.1 java版本table api和flink sql Demo最先出现在Python成神之路。