Flink里基于文件的source和sink是什么？
Flink里基于文件的source和sink是什么？
展开
收起
1
条回答
写回答
写回答
-
如果要从文本文件中读取数据，可以直接使用
env.readTextFile(path) 就可以以文本的形式读取该文件中的内容。当然也可以使用
env.readFile(fileInputFormat, path) 根据指定的fileInputFormat格式读取文件中的内容。
如果数据在FLink内进行了一系列的计算，想把结果写出到文件里，也可以直接使用内部预定义的一些sink，比如将结果已文本或csv格式写出到文件中，可以使用DataStream的writeAsText(path)和 writeAsCsv(path)。
2021-12-07 20:13:00赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
