Flink-Table StreamTableEnvironment实践编程(四)上

在上一篇文章中掌握了StreamTableEnvironment的基本概念,下面就进入代码实战环节:java 1、实例中采用socket链接方式,获取数据流信息,使用 nc -l 端口号方式,开启端口监控,用来数据数据信息,实例中使用9999做为端口,命令行中输入:nc -l 9999 2、本实例主要功能是完成根据学生姓名实现分数统计 3、具体依赖实体类以下:     @Data     publ
相关文章
相关标签/搜索