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