pyspark.pandas.read_sql???
-
yspark.pandas读sql高山市 sql:字符串, 骗局:字符串, 索引_c:Union[str、List[str=无, 列内:Union[str、List[str=无, 网际网际网际网路选项:任选 )→ pyspark.pandas.frame.DataFrame ??? -
读入dataFrame查询或数据库表
函数为方便打包
sql表并读sqlquery后向兼容性视提供输入而定委托给特定函数SQL查询路由读sqlquery时数据库表名路由sql表.注意委托函数可能对未列功能有更具体的注解注解
某些数据库可能点击spark问题:SPARK-27596
- 参数解析
-
- sql 字符串
-
SQL查询执行或表名
- 骗局 字符串
-
JDBCURI可按st提供
注解
URI必须是JDBCURI而非ython数据库URI
- 索引_c 字符串或链列表可选性默认数:无
-
列设置索引
- 列内 列表默认:无
-
列名列表从SQL表选择
- 选项 插件
-
所有其他选项直接传递SparkJDBC数据源
- 回归
-
- 数据Frame
实例
>>>ss系统.读sql高山市表名,'jdbc:postgresql:db_name')>>>ss系统.读sql高山市select*表名,'jdbc:postgresql:db_name')