StreamTask
2019-01-23 本文已影响0人
tangyoupeng
概述
所有streaming tasks的基类,StreamTask部署在TaskManagers上执行。每个StreamTask可以包含一个或多个chain在一起的StreamOperator,这些算子都在同一个线程里面执行。
.StreamTask包含一个OperatorChain。OperatorChain由一个后者多个StreamOperator组成。
能包含一个或多个operator
所有streaming tasks的基类,StreamTask部署在TaskManagers上执行。每个StreamTask可以包含一个或多个chain在一起的StreamOperator,这些算子都在同一个线程里面执行。
.StreamTask包含一个OperatorChain。OperatorChain由一个后者多个StreamOperator组成。
能包含一个或多个operator