[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Flink Query Optimizer


I am just wondering, does Flink use Apache Calcite's query optimizer to
generate an optimal logical plan, or does it have its own query optimizer?
>From what I observed so far, the Flink's query optimizer only groups
operator together without changing the order of aggregation operators
(e.g., join). Did I miss anything?

I am thinking of extending Flink to apply query optimization as in the
RDBMS by either integrating it with Calcite or implementing it as a new
Any feedback or guidelines will be highly appreciated.

Thank you,