From 6c8ca905455b184f936c6a829fa0a1eeca1014da Mon Sep 17 00:00:00 2001 From: heibaiying <31504331+heibaiying@users.noreply.github.com> Date: Fri, 1 Nov 2019 17:42:05 +0800 Subject: [PATCH] Update Flink_Data_Source.md --- notes/Flink_Data_Source.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/notes/Flink_Data_Source.md b/notes/Flink_Data_Source.md index e7f2b54..59d66bd 100644 --- a/notes/Flink_Data_Source.md +++ b/notes/Flink_Data_Source.md @@ -25,7 +25,7 @@ env.readTextFile(filePath).print(); **2. readFile(fileInputFormat, path)** :按照指定格式读取文件。 -**3. readFile(inputFormat, filePath, watchType, interval, typeInformation) **:按照指定格式周期性的读取文件。其中各个参数的含义如下: +**3. readFile(inputFormat, filePath, watchType, interval, typeInformation)**:按照指定格式周期性的读取文件。其中各个参数的含义如下: + **inputFormat**:数据流的输入格式。 + **filePath**:文件路径,可以是本地文件系统上的路径,也可以是 HDFS 上的文件路径。