pyspark.sql.streaming.DataStreamReader.load???
-
DataStreamReader.负载高山市 路径选择:可选性[字符串万事通=无, 格式化:可选性[字符串万事通=无, 模式化:Union[pyspark.sql.types.StructType, str, None]=无, 网际网际网际网路选项:OptionalPrimitiveType )数据Frame ??? -
从数据源加载数据流并重报
数据Frame.- 参数解析
-
- 路径选择 str可选
-
文件系统支持数据源可选字符串
- 格式化 str可选
-
可选数据源格式字符串默认为 'parquet'
-
模式化
pyspark.sql.types.StructType或字符串可选 -
可选性
pyspark.sql.types.StructType输入模式或DDL格式化字符串高山0INT系统Col1杜波尔) - **选项 插件
-
所有其他字符串选项
注解
API正在演化
实例
>>>son_sdf=点火.读Stream.格式化高山市公元前)\..模式化高山市sdf_schema)\..负载高山市时间文件.mkdtemp)>>>son_sdf.sStreaming系统真实性>>>son_sdf.模式化汉城sdf_schema真实性