Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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. 

...