欢迎光临散文网 会员登陆 & 注册

Data Sink:writerAsText 以文本格式输出详解

2023-07-05 11:03 作者:ingemar-  | 我要投稿

该方法是将数据以文本格式实时的写入到指定的目录中,本质上使用的是TextOutputFormat格式写入的。每输出一个元素,在该内容后面同时追加一个换行符,最终以字符的形式写入到文件中,目录中的文件名称是该Sink所在subtask的Index + 1。

该方法还有一个重载的方法,可以额外指定一个枚举类型的参数writeMode,默认是WriteMode.NO_OVERWRITE,如果指定相同输出目录下有相同的名称文件存在,就会出现异常。如果是WriteMode.OVERWRITE,会将以前的文件覆盖。


Data Sink:writerAsText 以文本格式输出详解的评论 (共 条)

分享到微博请遵守国家法律