第一种方式是HBase自身提供的比较原始的高效操作方式而第二、第三则分别是Spark、Flink集成HBase的方式,最后一种是第三方插件Phoenix集成的JDBC方式Phoenix集成的JDBC操作方式也能在Spark、Flink中调用。
这里我們使用HBase2.1.2版本以下代码都是基于该版本开发的。
这里我们采用静态方式连接HBase不同于2.1.2之前的版本,无需创建HBase线程池HBase2.1.2提供的代码已经封装恏,只需创建调用即可:
* 创建只有一个列簇的表
* 添加数据(多个rowKey多个列族)
* 根据rowKey删除一行数据、或者删除某一行的某个列簇,或者某一荇某个列簇某列 //①根据rowKey删除一行数据 //②删除某一行的某一个列簇内容 //③删除某一行某个列簇某列的值
使用Put api直接替换掉即可
//下列参数分别为列族列名,比较符号值