Hi,Friend

  • 首页
  • Scala
  • Java
  • BigData
  • 杂
  • 文章归档

使用Streaming File Sink写入hdfs时自定义分桶策略

开发的flink项目使用Streaming File Sink写入hdfs,最近接到了文件需要每五分钟分一个桶的需求,而flink默认的分桶策略无法支持这种需求,无奈之下只好自己写分桶策略。


Powered by Halo • Crafted with by LIlGG

© 2023 时雨邮箱   皖ICP备17017033号-2

时雨邮箱

Hi,Friend

  • 首页
  • Scala
  • Java
  • BigData
  • 杂
  • 文章归档

© 2023 时雨邮箱

切换主题 | SCHEME TOOL