Guest User

Untitled

a guest
Jan 1st, 2018
175
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.65 KB | None | 0 0
  1. sqlContext.read.format("jdbc").options(Map(
  2. "url" -> "jdbc:mysql://localhost/foo", "dbtable" -> "foo.bar")
  3. ).select("some_column", "another_column")
  4. .write.format("jdbc").options(Map(
  5. "url" -> "jdbc:mysql://localhost/foo", "dbtable" -> "foo.bar2")
  6. ).save("foo.bar2")
  7.  
  8. java.lang.RuntimeException: org.apache.spark.sql.execution.datasources.jdbc.DefaultSource does not allow create table as select.
  9. at scala.sys.package$.error(package.scala:27)
  10. at org.apache.spark.sql.execution.datasources.ResolvedDataSource$.apply(ResolvedDataSource.scala:200)
  11.  
  12. val prop: java.util.Properties = ???
  13. df.write.jdbc("jdbc:mysql://localhost/foo", "foo.bar2", prop)
Add Comment
Please, Sign In to add comment