- 博客(1)
- 资源 (2)
- 收藏
- 关注
原创 Apache Flink源码解析-StreamOperator接口实现
1、StreamOperator接口实现如图所示,StreamOperator的定义如下图1-StreamOperator接口StreamOperator接口主要包括如下核心方法open():定义当前Operator的初始化方法,在数据元素正式接入Operator运算之前,Task会调用StreamOperator.open()方法对该算子进行初始化,具体open()方法的定义由子类实现,常见的用法如调用RichFunction中的open()方法创建相应的状态变量。 close().
2022-01-25 13:29:27 1447
空空如也
空空如也
TA创建的收藏夹 TA关注的收藏夹
TA关注的人