flink学习笔记-dataStream经常使用算子、自定义分区、自定义sink

flink当中对于实时处理,有不少的算子,咱们能够来看看经常使用的算子主要有哪些,dataStream当中的算子主要分为三大类,html Transformations:转换的算子,都是懒执行的,只有真正碰到sink的算子才会真正加载执行 partition:对数据进行从新分区等操做 Sink:数据下沉目的地 官网算子介绍:https://ci.apache.org/projects/flink/
相关文章
相关标签/搜索