一种Flink框架的顺序写方法、装置及电子设备
授权
摘要
本发明实施例提供了一种Flink框架的顺序写方法、装置及电子设备。其中，方法包括：将待写入目标节点的数据分批次缓存至目标节点对应的Flink State中，目标节点为多个待写入节点中除终端节点以外的任一节点，终端节点为多个待写入节点中按照预设顺序位于末位的待写入节点；依次针对目标节点对应的Flink State中缓存的每批数据，将该批数据通过flush函数刷新到目标节点；在成功将该批数据刷新到目标节点后，将该批数据作为目标节点的下游节点的待写入数据，通过collector上下文缓存至下游节点对应的Flink State中，下游节点为多个待写入节点中按照预设顺序位于目标节点下一位的待写入节点。以实现Flink框架能够将数据按照顺序写入多个待写入节点。
基本信息
专利标题 ：
一种Flink框架的顺序写方法、装置及电子设备
专利标题（英）：
暂无
公开（公告）号 ：
CN112965994A
申请号 ：
CN202110350818.6
公开（公告）日 ：
2021-06-15
申请日 ：
2021-03-31
授权号 ：
CN112965994B
授权日 ：
2022-05-03
发明人 ：
陈小龙
申请人 ：
杭州海康威视数字技术股份有限公司
申请人地址 ：
浙江省杭州市滨江区阡陌路555号
代理机构 ：
北京柏杉松知识产权代理事务所(普通合伙)
代理人 ：
孟维娜
优先权 ：
CN202110350818.6
主分类号 ：
G06F16/242
IPC分类号 ：
G06F16/242 G06F16/2455 G06F16/23 G06F16/25
IPC结构图谱
G
G部——物理
G06
计算；推算或计数
G06F
电数字数据处理
G06F16/242
•••查询公式
法律状态
2022-05-03 ：
授权
2021-07-02 ：
实质审查的生效
IPC(主分类) : G06F 16/242
申请日 : 20210331
申请日 : 20210331
2021-06-15 ：
公开
注：本法律状态信息仅供参考，即时准确的法律状态信息须到国家知识产权局办理专利登记簿副本。
文件下载
暂无PDF文件可下载
