1.视界

2.前文回顾

AbstractStreamOperator

该抽象类为实现一个具体的operator提供基本的支持，Flink内置提供的operator全部都直接或间接继承自AbstractStreamOperator。

它内部包含了三大类的属性：

配置属性
运行时属性
键值对状态属性

大都数方法都是辅助方法，值得一提的是setup方法。从这里我们可以看到所有operator标识符的生成方式：

String operatorIdentifier = getClass().getSimpleName() + "_" + config.getVertexID() + "_" + runtimeContext.getIndexOfThisSubtask();

可以看到标识是由”_”间隔的三段拼接而成。三段分别是：类名，vertex id，以及当前subtask的索引。

然后基于此标识，创建了用于存储状态的stateBackend：

stateBackend = container.createStateBackend(operatorIdentifier, keySerializ

95-136-041-源码-Operator-AbstractStreamOperator相关推荐

【珍藏】 2012.NET开发必看资料53个+经典源码77个—下载目录
2019独角兽企业重金招聘Python工程师标准>>> .NET 是 Microsoft XML Web services 平台.XML Web services 允许应用程序通过I ...
PHP扩展编写、PHP扩展调试、VLD源码分析、基于嵌入式Embed SAPI实现opcode查看
catalogue 1. 编译PHP源码 2. 扩展结构.优缺点 3. 使用PHP原生扩展框架wizard ext_skel编写扩展 4. 编译安装VLD 5. Debug调试VLD 6. VLD源码 ...
中医病案管理系统计算机毕设源码13132
摘要随着互联网时代的到来,同时计算机网络技术高速发展,网络管理运用也变得越来越广泛.因此,建立一个B/S结构的中医病案管理系统,会使:中医病案管理系统的管理工作系统化.规范化,也会提高平台形象,提 ...
微信聊天防封亲测百分之95有效【附源码】
微信聊天防封亲测百分之95有效 [附源码] 把你想发给某一个人的"一句话改变成一张图片"" 并在文字的外围加上框,来实现防封默认快捷键AIt+Q ,可以隐藏或显示主 ...
分享136个PHP源码，总有一款适合您
PHP源码分享136个PHP源码,总有一款适合您 136个PHP源码下载链接:https://pan.baidu.com/s/1A5sR357dh_SlS7pu33lW1Q?pwd=kzgn 提取 ...
分享136个ASP源码，总有一款适合您
ASP源码分享136个ASP源码,总有一款适合您下面是文件的名字,我放了一些图片,文章里不是所有的图主要是放不下..., 136个ASP源码下载链接:https://pan.baidu.com/s ...
基于Python采集136个PHP源码
下载地址:https://pan.baidu.com/s/1jzXlbtnTTOmEe09eRnuecw?pwd=3ayf 提取码:3ayf 参数 page_count = 1 # 每个栏目开始业务 ...
Dart/Flutter地址智能识别源码，类似顺丰填写地址的智能识别，识别率95%+
smartParseAddress Dart/Flutter地址智能识别源码,类似顺丰填写地址的智能识别,识别率95%+ 站在巨人肩膀上,前排感谢:GitHub@wzc570738205 实际就是将地 ...
分享95个ASP整站程序源码，总有一款适合您
分享95个ASP整站程序源码,总有一款适合您 95个ASP整站程序源码下载链接:https://pan.baidu.com/s/1wAtkDSQxg4gSgo7Y9DiJKA?pwd=lnnt 提取 ...
谷歌BERT预训练源码解析（二）：模型构建
版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明. 本文链接:https://blog.csdn.net/weixin_39470744/arti ...

95-136-041-源码-Operator-AbstractStreamOperator

1.视界

2.前文回顾

95-136-041-源码-Operator-AbstractStreamOperator相关推荐

最新文章

热门文章