水桶水槽是否有可能在事件时间创建水桶

Question

文档说的桶将根据当前系统时间分配给存储桶。

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

Answer 1

，如果您使用streamingfilesink，我认为这只是编写自定义的桶形设施者的问题，该问题是使用事件时间来确定存储桶ID的问题。

流媒体Filesink最近被添加到Flink中，以解决BucketingSink的许多问题。但是，如果您出于某种原因要坚持使用BucketingSink，我相信您也可以轻松地实现一个自定义扣子。