dremio

gistfile1.txt

%scala
Class.forName("com.dremio.jdbc.Driver")

val jdbcPort = 31010
val jdbcDatabase = "DREMIO"
val user = ""
val password = ""
val tbl = "postgres.public.actor"

// Create the JDBC URL without passing in the user and password parameters.
val jdbcUrl = "jdbc:dremio:direct=<HOST>:31010"

// Create a Properties() object to hold the parameters.
import java.util.Properties
val connectionProperties = new Properties()

connectionProperties.put("user", user)
connectionProperties.put("password", password)

val driverClass = "com.dremio.jdbc.Driver"
connectionProperties.setProperty("Driver", driverClass)

val employees_table = spark.read.jdbc(jdbcUrl, tbl, connectionProperties)