...
These tests e2e dag optimization, including query parsing, validation, optimization, and checking the results. In these e2e optimization tests my prototype was 15-20% faster than existing Flink optimization structure . with the "cost" of simplifying the codebase
Code complexity
As a result of the above specified optimization process, the code complexity increases. For example, isUpdateBeforeRequired
is included in StreamOptimizeContext
and propagated through the whole optimization process.
...