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