StreamingFileSink文件滚动策略

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

StreamingFileSink文件滚动策略

lemon
hi各位,有个问题想请教下:
    我想将数据以gz方式写到下游,使用的StreamingFileSink,通过BulkFormat,但是看官方文档里只有OnCheckpointRollingPolicy这一个文件滚动策略,如果我想按照文件大小或者时间滚动该怎么设置呢?


打扰各位。