1 个回答
从mysql中提取数据创建临时试图示例如下:
session.sql(
s"""
create temporary view user
using org.apache.spark.sql.jdbc
options(
url '192.168.31.30',
dbtable 'test_user',
user 'root',
password '123456'
)
"""
)
session.sql("select * from user").show()
发布于:2年前 (2022-12-13) IP属地:四川省
我来回答
您需要 登录 后回答此问题!