极客 - 大数据 - 作业 Flink

关注

发布于: 39 分钟前

按照 SlidingWindow 统计平均值，每隔 1 分钟，求过去五分钟的窗口聚合值

public static Table report(Table transactions) {        return transactions                .window(Slide.over(lit(5).minutes()).every(lit(1).minutes()).on($("transaction_time")).as("log_ts"))                .groupBy($("log_ts"), $("account_id"))                .select(                        $("account_id"),                        $("log_ts").start().as("log_ts"),                        $("amount").avg().as("amount"));
    }

复制代码