Flink DataStream编程指南及使用注意事项。_datastream使用.map()函数的情况下有insert和delete数据怎么处理-CSDN博客

网站介绍:文章浏览阅读1.7k次。 Flink中的DataStream程序是对数据流进行转换的常规程序(例如,过滤,更新状态,定义窗口,聚合)。数据流的最初的源可以从各种来源(例如,消息队列,套接字流,文件)创建,并通过sink返回结果,例如可以将数据写入文件或标准输出。Flink程序以各种上下文运行,独立或嵌入其他程序中。执行可能发生在本地JVM或许多机器的集群上。一,套接字流 下面举一个例子..._datastream使用.map()函数的情况下有insert和delete数据怎么处理