godfrey he created FLINK-11714:
----------------------------------
Summary: Add cost model for both batch and streaming
Key: FLINK-11714
URL:
https://issues.apache.org/jira/browse/FLINK-11714 Project: Flink
Issue Type: New Feature
Components: Table API & SQL
Reporter: godfrey he
Assignee: godfrey he
Calcite's default cost model only contains ROWS, IO and CPU, and does not take IO and CPU into account when the cost is compared.
There are two improvements:
1. Add NETWORK and MEMORY to represents distribution cost and memory usage.
2. compare CPU value first, because each operator will use CPU. compare ROWS value last, because ROWS has been counted when calculating other values. e.g. CPU of Sort = nLogN(ROWS) * number of sort keys.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)