StreamTask

概述

所有streaming tasks的基类，StreamTask部署在TaskManagers上执行。每个StreamTask可以包含一个或多个chain在一起的StreamOperator，这些算子都在同一个线程里面执行。

.StreamTask包含一个OperatorChain。OperatorChain由一个后者多个StreamOperator组成。

能包含一个或多个operator

©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成，浏览时请结合常识与多方信息审慎甄别。
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

相关阅读更多精彩内容

  • Flink介绍和基本概念
    介绍 概述 Apache Flink是一个面向数据流处理和批量数据处理的可分布式的开源计算框架，它基于同一个Fli...
    stephen_k阅读 51,543评论 0赞 22
  • Flink学习笔记：Flink Runtime
    本文为《Flink大数据项目实战》学习笔记，想通过视频系统学习Flink这个最火爆的大数据计算框架的同学，推荐学习...
    大数据研习社阅读 7,198评论 0赞 2
  • flink架构和原理
    System Architecture 分布式系统需要解决：分配和管理在集群的计算资源、处理配合、持久和可访问的数...
    allin8116阅读 4,509评论 0赞 0
  • 迷茫的人生：怎么找到自己想做的事情？
    上周和一个朋友聊天，他现在是一家商业设计公司的项目组长。 旁人看起来会觉得还不错。但是他自己知道，这不是他真心热爱...
    今日是晴天阅读 1,792评论 0赞 0
  • 凉粉情缘
    莹说她最近在酝酿一篇名叫《凉粉西施》的文章，关于凉粉，我觉得我比她更有发言权，毕竟我曾经用凉粉征服过她。 ...
    美人瑜zy阅读 3,233评论 1赞 2

友情链接更多精彩内容