Ich musste den driver
hinzufügen -Option bei Verwendung von sparkSession
read
Funktion.
.option("driver", "org.postgresql.Driver")
var jdbcDF - sparkSession.read
.option("driver", "org.postgresql.Driver")
.option("url", "jdbc:postgresql://<host>:<port>/<DBName>")
.option("dbtable", "<tableName>")
.option("user", "<user>")
.option("password", "<password>")
.load()
Je nachdem, wie Ihre Abhängigkeiten eingerichtet sind, werden Sie Folgendes bemerken, wenn Sie etwas wie compile group: 'org.postgresql', name: 'postgresql', version: '42.2.8'
einfügen in Gradle wird dies beispielsweise die Driver-Klasse unter org/postgresql/Driver.class
enthalten , und das ist diejenige, die Sie Spark zum Laden anweisen möchten.