如何在猪八戒兼职网上实现网站支付接口?
摘要:网站支付接口怎么做,猪八戒兼职网,最讨厌网站,刷抖音一天赚四五百块目录 1、前言 2、readTextFile(已过时,不推荐使用) 3、readFi
网站支付接口怎么做,猪八戒兼职网,最讨厌网站,刷抖音一天赚四五百块目录
1、前言
2、readTextFile#xff08;已过时#xff0c;不推荐使用#xff09;
3、readFile#xff08;已过时#xff0c;不推荐使用#xff09;
4、fromSource(FileSource) 推荐使用 1、前言
思考: 读取文件时可以设置哪些规则呢#xff1f; 1. 文件的格式(tx…目录
1、前言
2、readTextFile已过时不推荐使用
3、readFile已过时不推荐使用
4、fromSource(FileSource) 推荐使用 1、前言
思考: 读取文件时可以设置哪些规则呢 1. 文件的格式(txt、csv、二进制...) 2. 文件的分隔符(按\n 分割) 3. 是否需要监控文件变化(一次读取、持续读取)
基于以上规则Flink为我们提供了非常灵活的 读取文件的方法 2、readTextFile已过时不推荐使用
语法说明:
定义:def readTextFile(filePath: String): DataStream[String]def readTextFile(filePath: String, charsetName: String)功能:1.读取文本格式的文件2.按行读取(\n为分隔符)每行数据被封装为 DataStream 的一个元素3.可以指定字符集(默认为UDF-8)4.文件只会读取一次源码分析public DataStreamSourceString readTextFile(String filePath, String charsetName) {// 初始化 TextInputFormat对象TextInputFormat format new TextInputFormat(new Path(filePath)); // 指定路径过滤器(使用默认过滤器)format.setFilesFilter(FilePathFilter.createDefaultFilter()); // 指定Flink中的数据类型 TypeInformationString typeInfo BasicTypeInfo.STRING_TYPE_INFO; // 指定字符集format.setCharsetName(charsetName); // 调用 readFile 方法return readFile(format, filePath, FileProcessingMode.PROCESS_ONCE, -1, typeInfo); }
代码示例: public static void readTextFile() throws Exception {/** TODO 功能说明* readTextFile(path) - 读取文本文件(一次读取)例如遵守 TextInputFormat 规范的文件逐行读取并将它们作为字符串返回。
