其他分享
首页 > 其他分享> > 第十二篇:Flink 常用的 Source 和 Connector

第十二篇:Flink 常用的 Source 和 Connector

作者:互联网

你好,欢迎来到第 12 课时,本课时我们主要介绍 Flink 中支持的 Source 和常用的 Connector。

Flink 作为实时计算领域强大的计算能力,以及与其他系统进行对接的能力都非常强大。Flink 自身实现了多种 Source 和 Connector 方法,并且还提供了多种与第三方系统进行对接的 Connector。

我们可以把这些 Source、Connector 分成以下几个大类。

预定义和自定义 Source

在前面的第 04 课时“Flink 常用的 DataSet 和 DataStream API”中提到过几种 Flink 已经实现的新建 DataStream 方法。

基于文件

我们在本地环境进行测试时可以方便地从本地文件读取数据:

readTextFile(path)
readFile(fileInputFormat, path)

可以直接在 ExecutionEnvironment 和 StreamExecutionEnvironment 类中找到 Flink 支持的读取本地文件的方法,如下图所示:在这里插入图片描述

标签:DataStream,Flink,课时,Connector,Source,path
来源: https://blog.csdn.net/u013411339/article/details/119022425