我正在嘗試從 pyspark 連接到 teradata。請你能告訴我我該怎么做嗎?我嘗試在網上查找,但找不到任何東西。
我有以下罐子:
tdgssconfig-15.10.00.14.jar teradata-connector-1.4.1.jar
uj5u.com熱心網友回復:
您需要 jdbc 連接器 JAR(您可以為要連接的 teradata 版本獲取它。然后使用類似這樣的東西:
sc.addJar("yourDriver.jar")
val jdbcDF = sqlContext.load("jdbc", Map(
"url" -> "jdbc:teradata://<server_name>, TMODE=TERA, user=my_user, password=*****",
"dbtable" -> "schema.table_name",
"driver" -> "com.teradata.jdbc.TeraDriver"))
uj5u.com熱心網友回復:
第 1 步:為您使用的 teradata 版本找到合適的 jdbc 驅動程式: https ://downloads.teradata.com/download/connectivity/jdbc-driver
第 2 步:在此處完成教程
https://spark.apache.org/docs/latest/sql-data-sources-jdbc.html
示例代碼:
val jdbcDF = spark.read
.format("jdbc")
.option("url", "<jdbc_connection_string>")
.option("dbtable", "schema.tablename")
.option("user", "username")
.option("password", "password")
.load()
轉載請註明出處,本文鏈接:https://www.uj5u.com/yidong/421901.html
標籤:
上一篇:該表回傳列號而不是計數
