-
面试官问：Flink内部数据在算子链内外如何交换？Flink为何能高效处理数据？你该怎么回答呢？
Task正式处理数据前，会创建OperatorChain。这个过程会为当前Task上所有的算子创建output。
output就是我们平时写Flink代码时用到的“output.collect(...）”代码。
算子链中只有1个算子
比如算子链中只有一个map算子。
以这样一个Flink任务为例说明算子链外的数据交换：Source(p=1)->map(p=2)->Sink(p=1)。每个算子都是独立的算子链。
首先会创建map算子的输出是mainOperatorOutput=RecordWriterOutput。
算子中output.collect()的output是如何来的？
StreamConfig
-
相关阅读:
TX2训练yolov4 自己的训练集
CSDN21天学习挑战赛——计划导航
Goland踩坑系列——Goland的go mod配置不生效的问题
力扣大厂热门面试算法题 21-23
C++学习第二十九天----引用变量和c语言之register关键字
docker事件event查看筛选
C#中使用Bitmap 传递图到C++
【区块链 | Compound】2.剖析DeFi借贷产品之Compound：合约篇
刷题记录:牛客NC16645[NOIP2007]矩阵取数游戏
嵌入式分享合集33
- 原文地址：https://blog.csdn.net/MissWYAN/article/details/126296710