I'm testing the Vertica Spark Connector 0.2.0 with Vertica 7.2.1 and HDP 2.4.0 (Spark 1.6).
I'm going through the examples from the user guide and they seem to work fine only when the tables from which I'm extracting the data are in the default schema.
However, if the table is not in the default schema and I add the parameter "dbschema" to the options, I get the following exception:
java.sql.SQLSyntaxErrorException: [Vertica][VJDBC](3737) ERROR: Invalid projection name category_b0
The examples in the User guide somehow never provide the dbschema parameter, so I'm wondering if this behavior is intentional.
Here's the code I'm using:
val hostName = "..."
val db = "dsa"
val tableName1 = "category"
val part = "12";
val dbschema = "ga_master"
val opt = Map("host" -> hostName, "table" -> tableName1, "db" -> db, "numPartitions" -> part, "user" -> "...", "password" -> "...", "dbschema" -> dbschema)
val df = sqlContext.read.format("com.vertica.spark.datasource.DefaultSource").options(opt).load()
