使用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”，不如獲取一個查詢的結果集。
2 回答
縹緲止盈
TA貢獻2041條經驗 獲得超4個贊
與1.x中的相同，您可以傳遞有效的子查詢作為dbtable參數，例如：
...
.option("dbtable", "(SELECT foo, bar FROM schema.tablename) AS tmp")
...
添加回答
舉報
0/150
提交
取消