如何正确使用Flink Connector？( 五 )
env.readFile(fileInputFormat path)
根据指定的 fileInputFormat 格式读取文件中的内容 。
如果数据在 Flink 内进行了一系列的计算 ， 想把结果写出到文件里 ， 也可以直接使用内部预定义的一些 sink ， 比如将结果已文本或 csv 格式写出到文件中 ， 可以使用 DataStream 的 writeAsText(path) 和 writeAsCsv(path) 。
-
基于 Socket 的 Source 和 Sink
提供 Socket 的 host name 及 port ， 可以直接用 StreamExecutionEnvironment 预定的接口 socketTextStream 创建基于 Socket 的 source ， 从该 socket 中以文本的形式读取数据 。 当然如果想把结果写出到另外一个 Socket ， 也可以直接调用 DataStream writeToSocket 。
-
基于内存 Collections、Iterators 的 Source
可以直接基于内存中的集合或者迭代器 ， 调用 StreamExecutionEnvironment fromCollection、fromElements 构建相应的 source 。 结果数据也可以直接 print、printToError 的方式写出到标准输出或标准错误 。
推荐阅读
- 小鱼人|如何在新赛季稳定上分？善于抓失误的小鱼人，值得认真练上一波
- 阴阳师|阴阳师SR川猿强度如何 是否值得抽卡 改变斗技环境 大佬的新玩具
- 手机游戏|梦幻西游手游：活力如何换金币 一切都已给出 就看你的选择
- 华佗|三国杀：两位\奶爸\，朱治与华佗比，强度如何呢？
- 亲朋上分|《亲朋上分》266391亲朋下分亲朋上下分永劫无间崔三娘技能介绍 崔三娘如何获得更多技能
- 金铲铲之战|金铲铲之战新赛季最强阵容：学院名流永恩，低分段玩家谨慎使用
- 激战2|MMORPG集体放大招？魔兽、FF14、激战2均使用End迎来主线剧情终章！
- s6|金铲铲之战：S6双城传说如何才能快速上手？基础知识很关键
- |冰雪传奇：平民玩家四转后如何打金
- 穿越火线|CF：传说武器再度上新，那王者、炫金该如何发展？