易坊好文馆

  1. 首页 > 玩科技 >

如何正确使用Flink Connector？( 四 )

  • 第一种 Flink 里面预定义了一些 source 和 sink 。

  • 第二种 Flink 内部也提供了一些 Boundled connectors 。

  • 第三种可以使用第三方 Apache Bahir 项目中提供的连接器 。

  • 第四种是通过异步 IO 方式 。

下面分别简单介绍一下这四种数据读写的方式 。

1.预定义的 source 和 sink

Flink 里预定义了一部分 source 和 sink 。 在这里分了几类 。

  • 基于文件的 source 和 sink 。

如果要从文本文件中读取数据 ， 可以直接使用：

env.readTextFile(path)

就可以以文本的形式读取该文件中的内容 。 当然也可以使用：

推荐阅读


上一篇：金瀚“狂吻”赵丽颖， 有谁看到他手放的位置， 暴露了真实人品！

下一篇：90后，养生之余，比爸妈更会精打细算