铲斗水槽是否有可能在活动时间创建桶？

Question

该文件称Bucketer将根据当前系统时间分配给桶。

我想知道如果我可以根据事件时间分配存储桶？

Answer 1

如果您使用StreamingFileSink，这似乎很简单，我认为这只是编写一个使用事件时间来确定存储桶ID的自定义BucketAssigner。

StreamingFileSink最近被添加到Flink以解决BucketingSink的许多问题。但是如果你想出于某种原因坚持使用BucketingSink，我相信你也可以轻松实现自定义的Bucketer。