pyspark.sql.DataFrameReader.load???
-
DataFrameReader.负载高山市 路径选择:Union[str、List[str=无, 格式化:可选性[字符串万事通=无, 模式化:Union[pyspark.sql.types.StructType, str, None]=无, 网际网际网际网路选项:OptionalPrimitiveType )数据Frame ??? -
从数据源加载数据并作为一个数据返回
数据Frame.- 参数解析
-
- 路径选择 str或list可选
-
可选字符串或链表文件系统支持数据源
- 格式化 str可选
-
可选数据源格式字符串默认为 'parquet'
-
模式化
pyspark.sql.types.StructType或字符串可选 -
可选性
pyspark.sql.types.StructType输入模式或DDL格式化字符串高山0INT系统Col1杜波尔) - **选项 插件
-
所有其他字符串选项
实例
>>>df=点火.读取.格式化高山市寻偶游戏).负载高山市'python/test_support/sql/parquet_partitioned',.选择1=真实性,选择2=一号,选择3=字符串)>>>df.d类型[“名”、“字符串”、“年份”、“int”)、(月”、“int”)、(日”、“int
>>>df=点火.读取.格式化高山市公元前).负载〔'python/test_support/sql/people.json',.'python/test_support/sql/people1.json')>>>df.d类型[“age”、“bigint”、“aa”、“string”、“name”、“string