编写一个自定义类来扩展DateTimeBucketAssigner并覆盖getBucketId方法中的路径生成逻辑
下面是一个示例-保存到一个带有前缀的路径作为POJO类名：

public class DateTimeWithClassPrefixBucketAssigner<IN> extends DateTimeBucketAssigner {
....
    @Override
    public String getBucketId(Object element, Context context) {
        if (dateTimeFormatter == null) {
            dateTimeFormatter = DateTimeFormatter.ofPattern(formatString).withZone(zoneId);
        }
        String prefix = element.getClass().getSimpleName();
        return prefix + "/" + dateTimeFormatter.format(Instant.ofEpochMilli(context.currentProcessingTime()));
    }
}

结束转换数据格式

import java.text.SimpleDateFormat;
...
    String input = "2022-01-31--10";
    String output = new SimpleDateFormat("{year}/{month}/{day}/{hour}/part-xxx.json").format(
            new SimpleDateFormat("yyyy-MM-dd--HH").parse(input)