Flink流处理-DataStream经常使用Source及Sink

环境 flink-1.9.0java 1、须要的依赖 <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_2.11</artifactId> <version>1.9.0</version> </dependency> 2、初始化执行环境读取数据文件 数据文件wo
相关文章
相关标签/搜索