英文:
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
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库,让每个人都能够通过互相帮助和分享经验来进步。
评论