flink sql 窗口函数 first

Flink SQL中的窗口函数first用于返回在窗口内第一个满足特定条件的值。它的语法如下：

FIRST(expression) OVER (window_specification)

其中，expression是要计算的表达式，window_specification是窗口的定义。

例如，假设我们有一个订单表orders，包含订单号(order_id)和订单金额(amount)等字段。我们想要在每个窗口内找到第一个订单金额大于100的订单号，可以使用first函数：

SELECT order_id, amount,
       FIRST(order_id) OVER (ORDER BY order_id ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW) AS first_order
FROM orders
WHERE amount > 100

上述示例中，我们通过ORDER BY子句指定按订单号排序，并使用ROWS BETWEEN子句指定窗口范围为从无界到当前行。然后，在每个窗口内，first函数将返回第一个满足amount > 100条件的订单号。

需要注意的是，first函数只返回一个值，如果窗口内没有满足条件的值，则返回NULL。