Flink是否支持在Table API中重新分区?

zpgglvta  于 2023-08-01  发布在  Apache
关注(0)|答案(1)|浏览(137)

DataStream API允许您设置每个操作符的并行性并选择重新分区策略(重新缩放、全局、重新平衡等)。
你可以在Table API中做同样的事情吗?

7lrncoxx

7lrncoxx1#

Table API是一个声明式API,计划器和优化器在其中为您的业务逻辑生成最佳计划。你不能在那里明确地设置这些类型的策略。唯一的例外是实现的SQL查询提示,它允许您将执行计划更改为特定的设置。这些可在www.example.com找到https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/queries/hints/#query-hints

相关问题