pyspark.sql.streaming.DataStreamReader.text???
-
DataStreamReader.文本翻译高山市 路径选择:字符串, 整文本:布卢尔=虚伪, 线Sep:可选性[字符串万事通=无, 路径GlobFilter:Union[bool,str,None]=无, recursiveFileLookup:Union[bool,str,None]=无 )数据Frame ??? -
加载文本文件流并返回
数据Frame其模式从字符串列开始命名为“值”,并继之以分治列(如果有的话)。文本文件必须编码为UTF-8默认时文本文件内的每一行都是生成DataFrame新列
- 参数解析
-
- 路径选择 字符串或链表
-
字符串或链表输入路径
- 其它参数
-
- 附加选项
-
额外选项参考数据源选项版本使用
注解
API正在演化
实例
>>>text_sdf=点火.读Stream.文本翻译高山市时间文件.mkdtemp)>>>text_sdf.sStreaming系统真实性>>>维值内字符串高山市text_sdf.模式化)真实性