Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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()
- jdbcDF.write.format("org.apache.hadoop.hbase.spark ").mode("overwrite")save()
- 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