自学内容网 自学内容网

flink自定义函数如何从崩溃中恢复数据

背景

flink 提供的标准算子已经实现了可以从之前的checkpoint中恢复数据

思考

程序开发中,通常会自定义函数和计算指标,比较复杂

实现

通常情况下实现
CheckpointedFunction 这个接口即可

统计词频的小例子

public class SumTestProcessFunction extends ProcessFunction<Tuple2<String, Integer>, Tuple2<

原文地址:https://blog.csdn.net/qq_22222499/article/details/136920488

免责声明:本站文章内容转载自网络资源,如本站内容侵犯了原著者的合法权益,可联系本站删除。更多内容请关注自学内容网(zxcms.com)!