码农知识堂 - 1000bd
  •   Python
  •   PHP
  •   JS/TS
  •   JAVA
  •   C/C++
  •   C#
  •   GO
  •   Kotlin
  •   Swift
  • hudi系列-文件归档(archive)


    1. 简介

    hudi会不断生成commit、deltacommit、clean等类型的Instant从而形成活跃时间轴(ActiveTimeline),随着时间增长,时间轴变长,.hoodie元数据目录下的文件不断累积,为了限制元数据文件数量,需要对一些比较久远的元数据文件进行归档,保存到.hoodie/archived目录下,可以称之为归档时间轴(ArchivedTimeline)。

    1.1 环境

    • flink 1.13.6
    • hudi 0.11.0
    • merge on read表

    1.2 逻辑结构

    在这里插入图片描述

    2. 归档流程

    2.1 每次commit触发归档

    每次数据提交结束后都会触发archive操作HoodieFlinkWriteClient#postCommit,前提是开启了自动归档配置hoodie.archive.automatic

    protected void autoArchiveOnCommit(
    • 相关阅读:
      Python Tkinter Multiple Windows 教程
      ThinkPHP 配置跨域请求,使用TP的内置跨域类配置,小程序和web网页跨域请求的区别及格式说明
      Pytorch 的数据处理 学习笔记
      ASP.Net MVC 登录页面实现RSA非对称加密
      mac切换本地node版本
      spring01
      【面试题】volatile关键字
      【数据结构】【版本1.3】【线性时代】——栈
      C#开发的OpenRA游戏之世界存在的属性CombatDebugOverlay(3)
      NLP-新词挖掘
    • 原文地址:https://blog.csdn.net/czmacd/article/details/126891750
    • 最新文章
    • 【FHE】我们如何实现同态加密推理(八):SiLU 的密文化——两条路径,和一个 8 字节的开关
      SQLcl 中 c/old/new 替换变量为何失效?先定位再替换
      不让模型写作文,直接从它脑子里读答案:Jev 决策在 .NET 的两条路线
      Halo插件:支持GitHub的图床附件策略
      电视投屏界的“一股清流”!SimpleTVCast 6.0.0-beta 抢先体验:无需TV端App,界面大换血!✨
      华三VXLAN集中式网关实战指南:Spine多活网关 + 双活接入(M-LAG)
      软件更好写之后口碑会更重要
      大 O、大 Omega、大 Theta 的区别,O(n) 复杂度是什么意思
      Java标签跳转:一个鲜为人知但却很实用的小技巧
      多智能体系统论文速读
    • 热门文章
    • 十款代码表白小特效 一个比一个浪漫 赶紧收藏起来吧!!!
      奉劝各位学弟学妹们,该打造你的技术影响力了!
      五年了,我在 CSDN 的两个一百万。
      Java俄罗斯方块,老程序员花了一个周末,连接中学年代!
      面试官都震惊,你这网络基础可以啊!
      你真的会用百度吗?我不信 — 那些不为人知的搜索引擎语法
      心情不好的时候,用 Python 画棵樱花树送给自己吧
      通宵一晚做出来的一款类似CS的第一人称射击游戏Demo!原来做游戏也不是很难,连憨憨学妹都学会了!
      13 万字 C 语言从入门到精通保姆级教程2021 年版
      10行代码集2000张美女图,Python爬虫120例,再上征途
    小工具 小游戏
    Copyright © 2022 侵权请联系2656653265@qq.com    京ICP备2022015340号-1

    京公网安备 11010502049817号