20200604——flink datastream开发

flink流处理程序的一般流程 1)获取flink流处理执行环境 2)构建source 3)数据处理 4)构建sink 与批处理相比 1.运行环境不同,streamexecutionenvironment 2.有些算子不同 3.程序是一直运行的,除非我们手动停止 输入数据集data source flink中你可以使用streamexecutionenvironment.addSource(sou
相关文章
相关标签/搜索