概述 StreamGraph 代表最原始的topology，没有 chain 优化， 没有并行度概念，只有 StreamNode和StreamE...

概述 所有streaming tasks的基类，StreamTask部署在TaskManagers上执行。每个StreamTask可以包含一个或...