1.寻找物体 1.1 寻找满足条件的子物体 1.2 寻找一组满足条件的子物体 2. 操作一组物体 2.1 对一组满足条件物体进行操作 2.2 常用扩展方法 ` ...

一、Connect DataStream,DataStream -> ConnectedStream，连接两个保持他们类型的数据流，两个数据流被Connect之后，只是被放在了同一个流中，内 ...

一、窗口流 WindowedStream 通常由 keyedStream + windowAssigner函数生成。运行时将与 KeyedStream 和窗口上的操作合并为一个操作。 aggregate 用于按字段或者按位置（元组）对流聚合/分组 private def ...

内置水印生成器 1.有序生成 只需提取事件时间的时间戳作为水印即可。 java DataStream<MyEvent> stream = ... DataStream< ...

Flink读写mysql 如果是mvn项目的话，需要预先导入相应的包： <dependency> <groupId>org.apache.flink</groupId> < ...

前言 在前面 Flink 的文章 《Flink学习》—— Apache Flink 入门介绍 中就说过 Flink 程序的结构 Flink 应用程序结构就是如上图所示： 1、Source: 数据源，Flink 在流处理和批处理 ...

Window是无限数据流处理的核心，Window将一个无限的stream拆分成有限大小的”buckets”桶，我们可以在这些桶上做计算操作。本文主要聚焦于在Flink中如何进行窗口操作，以及程序员如何从window提供的功能中获得最大的收益。 　　窗口化的Flink程序的一般结构如下，第一个 ...

一、前述 今天分享一篇SparkStreaming常用的算子transform和updateStateByKey。 可以通过transform算子，对Dstream做RDD到RDD的任意操作。其实就是DStream的类型转换。 算子内，拿到的RDD算子外 ...