北京网站设计我选刻,网站制作,东莞公司网站设计,个人或主题网站建设Flink Data Source
一、内置 Data Source
Flink Data Source 用于定义 Flink 程序的数据来源，Flink 官方提供了多种数据获取方法，用于帮助开发者简单快速地构建输入流，具体如下：
1.1 基于文件构建
1. readTextFile(path)：按照 TextInputFormat 格式读取文本文件，并将…Flink Data Source
一、内置 Data Source
Flink Data Source 用于定义 Flink 程序的数据来源，Flink 官方提供了多种数据获取方法，用于帮助开发者简单快速地构建输入流，具体如下：
1.1 基于文件构建
1. readTextFile(path)：按照 TextInputFormat 格式读取文本文件，并将其内容以字符串的形式返回。示例如下：
env.readTextFile(filePath).print();2. readFile(fileInputFormat, path) ：按照指定格式读取文件。
3. readFile(inputFormat, filePath, watchType, interval, typeInformation)
