实时计算Flink版：Window TVF

新增、删除、修改非Distinct的统计指标（Aggregate Function）。

• 对于新增统计指标，属于部分兼容，从当前作业启动时开始累计。

• 对于删除统计指标，属于完全兼容变更。删除的统计指标对应的状态数据会被丢弃。

• 对于既有新增又有删除统计指标，则属于部分兼容变更。新增的统计指标从当前作业启动时开始累计，删除的统计指标对应的状态数据会被丢弃。

• 对于修改统计指标，被视为删除和新增两个操作，属于部分兼容变更。新增的统计指标从当前作业启动时开始累计，删除的统计指标对应的状态数据会被丢弃。

-- 原始SQL。
select a, sum(b), max(c)
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
group by a, window_start, window_end;

-- 新增统计指标：count(c)，属于部分兼容变更。
-- sum(b)、max(c)的计算结果不受影响，count(c)的值在作业启动时从0开始累计。
select a, sum(b), max(c), count(c)
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
group by a, window_start, window_end;

-- 删除统计指标：sum(b)，属于完全兼容变更。
-- max(c)的计算结果不受影响。
select a, max(c)
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
group by a, window_start, window_end;

-- 修改统计指标：max(c) -> min(c)，属于部分兼容变更。
-- sum(b)的计算结果不受影响。max(c)被认为删除，其对应的状态数据会被丢弃。
-- min(c)被认为是新增指标，其值在作业启动时开始计算。
select a, sum(b), min(c)
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
group by a, window_start, window_end;

调整非Distinct的统计指标位置，该修改属于完全兼容变更。

-- 原始SQL。
select a, sum(b), max(c)
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
group by a, window_start, window_end;

-- 调整统计指标位置：sum(b)、max(c)，属于完全兼容变更。
-- sum(b)、max(c) 的计算结果不受影响。
select a, max(c), sum(b)
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
group by a, window_start, window_end;

当非Distinct的统计指标涉及的字段有计算逻辑变化时，该统计指标被认为做了修改操作，该修改属于部分兼容变更。

-- 原始SQL。
select a, sum(b), max(c)
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
group by a, window_start, window_end;

-- 修改统计指标：max(c) -> max(substring(c, 1, 5))，属于部分兼容变更。
-- sum(b)的计算结果不受影响。max(c)被认为删除，其对应的状态数据会被丢弃。
-- max(substring(c, 1, 5)) 被认为新增指标，其值在作业启动时开始计算。
create temporary view MyView select a, b, substring(c, 1, 5) as c, ts from MyTable;
select a, sum(b), max(c)
from table (tumble(table MyView, descriptor(ts), interval '1' minute))
group by a, window_start, window_end;

新增、删除window属性字段，该修改属于完全兼容变更。

-- 原始SQL。
select a,
  sum(b),
  max(c),
  window_start
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
  group by a, window_start, window_end;

-- 新增window end属性，该修改属于完全兼容变更。
select a,
  sum(b),
  max(c),
  window_start,
  window_end
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
  group by a, window_start, window_end;

-- 删除window start属性，该修改属于完全兼容变更。
select a,
  sum(b),
  max(c)
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
  group by a, window_start, window_end;

修改window相关属性（window的类型，window的大小，时间相关属性），该修改属于不兼容变更。

--原始SQL。
select a,
  sum(b),
  max(c),
  window_start
from table (tumble(table MyTable, descriptor(ts), interval '1' minute))
  group by a, window_start, window_end;

-- 修改window类型：tumble -> hop，该修改属于不兼容修改。
select a,
  sum(b),
  max(c),
  hop_start(ts, interval '1' minute, interval '2' minute) as window_start
from MyTable
  group by a, hop(ts, interval '1' minute, interval '2' minute);

-- 修改window大小：'1' minute -> '2' minute，该修改属于不兼容修改。
select a,
  sum(b),
  max(c),
  tumble_start(ts, interval '2' minute) as window_start
from MyTable
  group by a, tumble(ts, interval '2' minute);

-- 修改时间相关属性：ts -> proctime，该修改属于不兼容修改。
select a,
  sum(b),
  max(c),
  tumble_start(ts, interval '1' minute) as window_start
from MyTable
  group by a, tumble(proctime, interval '1' minute);

新增、删除、修改统计维度（group key）或者统计维度涉及字段的计算逻辑发生变化，该修改属于不兼容变更。

-- 原始SQL。
select a,
  sum(b),
  max(c),
  tumble_start(ts, interval '1' minute) as window_start
from MyTable
  group by a, tumble(ts, interval '1' minute);

-- 新增统计维度：d，该修改属于不兼容修改。
select a,
  sum(b),
  max(c),
  tumble_start(ts, interval '1' minute) as window_start
from MyTable
  group by a, d, tumble(ts, interval '1' minute);

-- 其他示例可参考Group Aggregate修改group key示例。

新增、删除、修改Distinct统计指标（distinct aggregate function）或者Distinct统计指标涉及字段的计算逻辑发生变化，该修改属于不兼容变更。

-- 原始SQL。
select a,
  sum(b),
  count(distinct b),
  max(c),
  count(distinct c),
  tumble_start(ts, interval '1' minute) as window_start
from MyTable
  group by a, tumble(ts, interval '1' minute);

-- 新增Distinct统计指标：count(distinct b)，该修改属于不兼容修改。
select a,
  sum(b),
  max(c),
  count(distinct c),
  tumble_start(ts, interval '1' minute) as window_start
from MyTable
  group by a, tumble(ts, interval '1' minute);

-- 其他示例可参考Group Aggregate修改Distinct统计指标示例。

删除了所有统计指标，该修改属于不兼容变更。（所有统计指标的状态数据都被丢弃，没有状态复用。）

-- 原始SQL。
select a,
  sum(b),
  count(distinct b),
  max(c),
  count(distinct c),
  tumble_start(ts, interval '1' minute) as window_start
from MyTable
  group by a, tumble(ts, interval '1' minute);

-- 删除所有统计指标：sum(b), max(c)，该修改属于不兼容修改。
select a,
  tumble_start(ts, interval '1' minute) as window_start
from MyTable
  group by a, tumble(ts, interval '1' minute);