Flink支持在Table API中进行重分区吗?

huangapple go评论63阅读模式
英文:

Does Flink support repartitioning in the Table api?

问题

DataStream API允许您设置每个操作符的并行度并选择重新分区策略(重新缩放、全局、重新平衡等)。

在Table API中是否可以执行相同操作?

英文:

The DataStream API allows you to set parallelism of each operator and choose repartitioning strategies (rescale, global, rebalance, etc).

Can you do the same in the Table API?

答案1

得分: 1

Table API是一种声明性API,规划器和优化器会生成最适合你业务逻辑的最佳执行计划。你不能显式设置这些类型的策略。唯一的例外是实现了SQL查询提示,允许你将执行计划更改为特定设置。这些可以在https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/queries/hints/#query-hints找到。

英文:

The Table API is a declarative API, where the planner and the optimizer generate the best plan for your business logic. You can't explicitly set these type of strategies there. The only exception are implemented SQL Query Hints, which allow you to alter the execution plan to a specific setting. These can be found at https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/queries/hints/#query-hints

huangapple
  • 本文由 发表于 2023年7月3日 07:30:07
  • 转载请务必保留本文链接:https://go.coder-hub.com/76601144.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定