Flink DataStream-在窗口上执行SQL查询，执行orderBy

Question

SELECT name, age, sum(days), avg(salary)
FROM employees
WHERE age > 25
GROUP BY name, age
ORDER BY name, age

下面是目前为止我所想到的伪代码。任何帮助都将不胜感激！谢谢！

employeesStream
.filter(new FilterFunction() ....)    \\ where clause
.keyby(nameIndex, ageIndex)           \\ group by??
.timeWindow(Time.seconds(10), Time.seconds(1))
.apply(new WindowFunction() ....)     \\ calculate average (and sum?)
// order by??

我检查了Table API，但对于流，似乎不支持很多操作，例如OrderBy。

Answer 1

流式订购不是一件微不足道的事。你想如何对永无止境的东西进行排序？在您的示例中，您希望计算一个平均值或一个和值，这只是每个窗口的一个值。不能对一个值进行排序。

另一种可能是缓冲所有值，等待一个完整性指示器开始排序。由于事件时间和水印，如果您知道您看到了直到某个时间的所有值（也称为水印），就可以对流进行排序。

事件时排序是最近引入的，它将成为Flink1.4表API的一部分。请参阅此处的示例。