从Spark Scala连接Presto

Question

我是spark的新手。我正在尝试使用Spark Scala连接到presto实例。对于Presto服务器，SSL是真的，我有一个Presto密钥库。我的问题是如何在连接字符串中传递此信息。下面是我的代码片段

val enrdata = sqlcontext.read.format("jdbc").option("url", "jdbc:presto://hostname:1111/hive").option("query", carrier_info).option("user", "test1").option("password", "pass123").option("driver", "io.prestosql.jdbc.PrestoDriver").load()

Answer 1

您需要添加.option("SSL","true")选项。https://trino.io/docs/current/installation/jdbc.html#connection-parameters