Advertisement
Guest User

Untitled

a guest
Jul 28th, 2017
86
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.46 KB | None | 0 0
  1. val jdbcDF = spark.read.format("jdbc").option("url","jdbc:sqlserver://192.168.1.21;username=sa;password=yishidb;database=CDRDB16").option("driver","com.microsoft.sqlserver.jdbc.SQLServerDriver").option("dbtable","TestSparkHBase").load()
  2.  
  3. jdbcDF.write.format("org.apache.hadoop.hbase.spark ").mode("overwrite")save()
  4.  
  5. jdbcDF.write.options(Map("table" -> "TestSparkHBase","zkUrl" -> "hadoop001:2181")).format("org.apache.hadoop.hbase.spark").mode("overwrite").save()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement