柚子快报激活码778899分享：导入hbase02-spark

http://yzkb.51969.com/

导入hbase01

本文引入spark hbase插入和批量插入。

批量插入：用BulkLoad方法，具体介绍查看导入hbase01

/**   * Hbase 保存数据   *   **/ object TestHbaseDemo {

  val logger = LoggerFactory.getLogger(this.getClass)   def insert(sc:SparkContext): Unit ={

    val tableName="test"

   

    val hbaseConf=HBaseConfiguration.create()

    val jobConf=new JobConf(hbaseConf)     jobConf.set("hbase.zookeeper.property.clientPort", "2181")     jobConf.set("hbase.zookeeper.quorum", "bigdata1")     jobConf.set("zookeeper.znode.parent", "/hbase")     jobConf.setOutputFormat(classOf[TableOutputFormat])     jobConf.set(TableOutputFormat.OUTPUT_TABLE,tableName)     val pairs=sc.parallelize

柚子快报激活码778899分享：导入hbase02-spark

http://yzkb.51969.com/

参考文章

评论可见，请评论后查看内容，谢谢！！！评论后请刷新页面。