使用pyspark：from pyspark.sql import SparkSessionspark = SparkSession\ .builder\ .appName("spark play")\ .getOrCreate() df = spark.read\ .format("jdbc")\ .option("url", "jdbc:mysql://localhost:port")\ .option("dbtable", "schema.tablename")\ .option("user", "username")\ .option("password", "password")\ .load()與其獲取“ schema.tablename”，不如獲取一個(gè)查詢的結(jié)果集。
2 回答
縹緲止盈
TA貢獻(xiàn)2041條經(jīng)驗(yàn) 獲得超4個(gè)贊
與1.x中的相同，您可以傳遞有效的子查詢作為dbtable參數(shù)，例如：
...
.option("dbtable", "(SELECT foo, bar FROM schema.tablename) AS tmp")
...
添加回答
舉報(bào)
0/150
提交
取消