Update Flink_Data_Source.md

This commit is contained in:
heibaiying 2019-11-01 17:42:05 +08:00 committed by GitHub
parent 7960d1b699
commit 6c8ca90545
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -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 上的文件路径。