阅读背景:

Flink Task的输入和输出源码分析_METON的博客

来源:互联网 

Task的输入和输出

Task的输出

        Task产出的每一个ResultPartition都有一个关联的ResultPartitionWriter,同时也都有一个独立的LocalBufferPool负责提供写入数据所需的buffer。ResultPartion实现了ResultPartitionWriter接口:        Task产出的每一个Result




你的当前访问异常,请进行认证后继续阅读剩余内容。

分享到: