Skip to content

Instantly share code, notes, and snippets.

@r-wheeler
Created October 5, 2015 19:48
Show Gist options
  • Save r-wheeler/2f2296390929b3be5cce to your computer and use it in GitHub Desktop.
Save r-wheeler/2f2296390929b3be5cce to your computer and use it in GitHub Desktop.
vertica scala fail
import org.apache.spark.rdd.JdbcRDD
import java.sql.{Connection, DriverManager, ResultSet}
classOf[com.vertica.jdbc.Driver]
println("com.vertica.jdbc.Driver loaded successfully ")
val conn_str = "jdbc:vertica://172.16.251.171:5433/analyticsdb?user=dbadmin&password=analytics"
// val conn = DriverManager.getConnection(conn_str)
println("Connection with vertica established ")
val myRDD = new JdbcRDD( sc, () =>
DriverManager.getConnection(conn_str),
"select ROLE_NAME from ROLE_TB WHERE ROLE_ID > ? AND ROLE_ID",
0, 10, 2, r => r.getString("ROLE_NAME"))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment