Details
-
Sub-task
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
To support optimize the StreamGraph based on runtime information, we plan to introduce the StreamGraphOptimizer component. This component, upon initialization, will obtain the StreamGraphContext from the AdaptiveGraphManager. And this component will load a set of StreamGraphOptimizationStrategies. At runtime, it will pass the received OperatorsFinished and the StreamGraphContext sequentially to all StreamGraphOptimizationStrategies, attempting to optimize the StreamGraph.