一、Flinkx-FileSystem原理与使用
Flinkx-FileSystem设计
Finkx文件写入逻辑
FileSystem 场景
FileSystem配置
二、StreamFileSink原理与使用
StreamFileSink定义
StreamFileSink写入原理
StreamFileSink关键字
Bucket Assignment
Rolling Policy
Part File Lifecycle
三、Flinkx-FileSystem 与 StreamFilesink对比
为满足Flink的exchange-once语义,FlinkX的文件系统与Flink的StreamFIleSInk均对文件进行了状态的分类,只有在ck的时候将任务移动到数据目录下,而FlikX同时支持离线模式,可以任务结束时,将数据移动到数据目录下。
StreamFileSink在非batch模式下,如果没有ck则文件状态一直是progress 或者pending状态。
同时对于文件都有滚动策略,而StramFileSink则滚动策略更丰富,支持时间相关的配置,FlinkX仅支持文件大小的配置。
钉钉或搜索:30537511 加入技术交流群,回看直播,获取完整的课件资料。
在b站搜索“袋鼠云”回看直播视频
b站视频网址:https://www.bilibili.com/video/bv1MP4y1V7qS
我们定期会邀请技术大牛来给我们做分享,大家关注我们的下一期直播哦~