全部产品
Search
文档中心

实时计算Flink版:Temporal Sort

更新时间:May 29, 2024

本文为您介绍Temporal Sort修改的可兼容性和不可兼容性详情。

可兼容的修改

  • 当仅基于proctime进行升序排序时(order by proctime asc),可变更select字段,属于完全兼容变更。

    -- 原始SQL。
    select a, b, c from MyTable order by proctime asc;
    
    -- 新增输入字段:d,该修改属于完全兼容修改。
    select a, b, c, d from MyTable order by proctime asc;
  • 在select中增删order by key字段,属于完全兼容变更。

    // 原始query
    select a, b, ts from MyTable order by ts asc;
    // 完全兼容
    select a, b from MyTable order by ts asc;

不兼容的修改

  • 当基于rowtime进行order by时,不支持变更select字段,属于不兼容变更。

    -- 原始SQL。
    select a, b, c from MyTable order by ts asc;
    
    -- 新增输入字段:d,该修改属于不兼容修改。
    select a, b, c, d from MyTable order by ts asc;
  • 变更order by相关属性(排序字段和方向),属于不兼容变更。

    -- 原始SQL。
    select a, b, c from MyTable order by ts asc;
    
    -- 新增order by字段:a,该修改属于不兼容修改。
    select a, b, c from MyTable order by ts asc, a desc;