28 9 月 Flink, 大数据 Posted by 蓝染君 flink-19 窗口 窗口:将无限数据切割成有限的”数据块“进行处理 使用水桶接水的比喻,水桶就是窗口 在flink中,窗口其实并不是一个”框“,应该把窗口理解成一个”桶“,在flink中,窗口可以把流切割成有限大小的多个”存储桶“(bucket),每个数据都会分发到对应... Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-15 物理分区算子 常见的物理分区策略有:随机分配(Random)、轮询分配(Round-Robin)、重缩放(Rescale)和广播(Broadcast) Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-14 用户自定义函数UDF 方式一:匿名实现类 方式二:lambda表达式 方式三:定义一个类来实现MapFunction 建议单独一个类文件 定义类的同时 指定初始化参数 Continue reading