开发者社区> 问答> 正文

Apache Flink中的old和blink的区别有哪些?

Apache Flink中的old和blink的区别有哪些?

展开
收起
游客daliwbfb2wo66 2021-12-08 21:34:47 528 0
1 条回答
写回答
取消 提交回答
  • 1.批流统一:Blink 将批处理作业,视为流式处理的特殊情况。所以,blink 不支持表和DataSet 之间的转换,批处理作业将不转换为 DataSet 应用程序,而是跟流处理一样,转换为 DataStream 程序来处理。

    2.因 为 批 流 统 一 , Blink planner 也 不 支 持 BatchTableSource , 而 使 用 有 界 的

    3.Blink planner 只支持全新的目录,不支持已弃用的 ExternalCatalog。

    4.旧 planner 和 Blink planner 的 FilterableTableSource 实现不兼容。旧的 planner 会把PlannerExpressions 下推到 filterableTableSource 中,而 blink planner 则会把 Expressions 下推。

    5.基于字符串的键值配置选项仅适用于 Blink planner。

    6.PlannerConfig 在两个 planner 中的实现不同。

    7.Blink planner 会将多个 sink 优化在一个 DAG 中(仅在 TableEnvironment 上受支持,而在 StreamTableEnvironment 上不受支持)。而旧 planner 的优化总是将每一个 sink 放在一个新的 DAG 中,其中所有 DAG 彼此独立。

    8.旧的 planner 不支持目录统计,而 Blink planner 支持。

    2021-12-08 21:35:35
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Apache Flink技术进阶 立即下载
Apache Spark: Cloud and On-Prem 立即下载
Hybrid Cloud and Apache Spark 立即下载

相关镜像