官宣！阿里Blink和Flink合并计划出炉

统一的流式操作符：Blink 扩展了 Flink 的流式运行时操作符模型，支持选择性读取不同的输入源，同时保持推送模型的低延迟特性。这种对输入源的选择性读取可以更好地支持一些算法(例如相同操作符的混合散列连接)和线程模型(通过 RocksDB 的连续对称连接)。这些操作符为“侧边输入”(https://cwiki.apache.org/confluence/display/FLINK/FLIP-17+Side+Inputs+for+DataStream+API )等新功能打下了基础。

Table API 和 SQL 查询处理器：与最新的 Flink 主分支相比，SQL 查询处理器是演变得最多的一个组件：

Flink 目前将查询转换为 DataSet 或 DataStream 程序(取决于输入的特性)，而 Blink 会将查询转换为上述流式操作符的数据流。

Blink 为常见的 SQL 操作添加了更多的运行时操作符，如半连接(semi-join)、反连接(anti-join)等。

查询规划器(优化器)仍然是基于 Apache Calcite，但提供了更多的优化规则(包括连接重排序)，并且使用了适当的成本模型。

更加积极的流式操作符链接。

扩展通用数据结构(分类器、哈希表)和序列化器，在操作二进制数据上更进一步，并减小了序列化开销。代码生成被用于行序列化器。

（编辑：核心网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!