简单看了下拼文件名的规则,你可以试试

RowFormatBuilder#withPartFilePrefix
RowFormatBuilder#withPartFileSuffix

这两个方法。应该可以将你的文件名设置成

<prefix>-<subtaskIdx>-<partCounter><suffix>

中间段是写死的。

如果你有更自定义的重命名需求,建议把你为什么需要重命名具体的说一下。

Best,
tison.


Wesley Peng <[email protected]> 于2019年10月8日周二 下午5:43写道:

> May you want to rename them in HDFS with FileSystem.rename method?
>
>
> on 2019/10/8 17:39, yanggang_it_job wrote:
> > 写入hdfs的文件都是
> > part-{parallel-task}-{count}
> > 这种格式
> >
> >
> > 如何重命名啊?
>

回复