文件名称：StreamGraph的生成-svpwm的调制及谐波分析
文件大小：4.81MB
文件格式：PDF
更新时间：2024-07-10 12:54:41
flink
2.2 StreamGraph的生成 在第一节的算子注册部分，我们可以看到，flink把每一个算子transform成一个对流的转换 （比如上文中返回的SingleOutputStreamOperator是一个DataStream的子类），并且注册 到执行环境中，用于生成StreamGraph。实际生成StreamGraph的入口 是 StreamGraphGenerator.generate(env, transformations) 其中的transformations是一 个list，里面记录的就是我们在transform方法中放进来的算子。 2.2.1 StreamTransformation类代表了流的转换 StreamTransformation代表了从一个或多个DataStream生成新DataStream的操作。顺 便，DataStream类在内部组合了一个StreamTransformation类，实际的转换操作均通过该 类完成。