分类： flink

在本节中，您将了解Flink为编写有状态程序提供的api。请参阅有状态流处理以了解有状态流处理背后的概念。 K… 继续阅读 Flink —— 状态

窗口操作的结果还是一个DataStream,没有保留的信息窗口的操作结果元素,没有关于窗口操作的信息被保留在结… 继续阅读 Flink 使用窗口结果

当使用事件时间窗口时，可能会出现元素到达晚的情况，也就是说，Flink用来跟踪事件时间进程的watermark… 继续阅读 Flink 窗口 —— 允许迟到

触发器决定窗口(由窗口分配器形成)何时可以由窗口函数处理。每个WindowAssigner都有一个默认的触发器… 继续阅读 Flink 窗口行为触发器

窗口是处理无限流的核心。窗口拆分将流拆为有限数量数据的bucket，这样就可以应用计算。 窗口的生命周期 当第… 继续阅读 Flink 的窗口指定者和函数

Map 输入DataStream返回DataStream。 接收一个元素，产生一个元素。下面是转换为双倍值的M… 继续阅读 Flink 的数据流算子