Hi

When i look for what kind of optimizations flink does, i found
https://cwiki.apache.org/confluence/display/FLINK/Optimizer+Internals  is
it up to date? Also i couldnt understand:

"Reusing of partitionings and sort orders across operators. If one operator
leaves the data in partitioned fashion (and or sorted order), the next
operator will automatically try and reuse these characteristics. The
planning for this is done holistically and can cause earlier operators to
pick more expensive algorithms, if they allow for better reusing of
sort-order and partitioning."

Can you give example for "earlier operators to pick more expensive
algorithms" ?

Regards

Reply via email to