DataStream API允许您设置每个操作符的并行性并选择重新分区策略(重新缩放、全局、重新平衡等)。你可以在Table API中做同样的事情吗?
7lrncoxx1#
Table API是一个声明式API,计划器和优化器在其中为您的业务逻辑生成最佳计划。你不能在那里明确地设置这些类型的策略。唯一的例外是实现的SQL查询提示,它允许您将执行计划更改为特定的设置。这些可在www.example.com找到https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/queries/hints/#query-hints
1条答案
按热度按时间7lrncoxx1#
Table API是一个声明式API,计划器和优化器在其中为您的业务逻辑生成最佳计划。你不能在那里明确地设置这些类型的策略。唯一的例外是实现的SQL查询提示,它允许您将执行计划更改为特定的设置。这些可在www.example.com找到https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/queries/hints/#query-hints