StreamTask

2019-01-23  本文已影响0人  tangyoupeng

概述

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

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

能包含一个或多个operator

上一篇下一篇

猜你喜欢

热点阅读