全部產品
Search
文件中心

Realtime Compute for Apache Flink:Temporal Sort

更新時間:Jul 13, 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;