热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

小记hbase数据库javaAPI常用方法及案例

HBaseAdmin类:管理hbase数据库的表信息,‘创建表、删除表、列出表选项、使表有效/无效、添加或删除列簇’; 

HBaseAdmin类:管理hbase数据库的表信息,‘创建表、删除表、列出表选项、使表有效/无效、添加或删除列簇’;

 小记--------hbase数据库java API 常用方法及案例 - 文章图片

 

 

Eg:
//使用工厂模式创建connection
val conn: COnnection= ConnectionFactory.createConnection(config)
//实例化hbase的管理者实例
val admin: Admin = conn.getAdmin
//删除表
admin.deleteTable(TableName.valueOf("t1"))

 

HbaseConfiguration类继承自Configuration类:将hbase配置文件添加到配置中

 小记--------hbase数据库java API 常用方法及案例 - 文章图片

//配置hbase资源配置
val config: COnfiguration=HBaseConfiguration.create()
config.set("hbase.zookeeper.quorum" , "df1:2181,df2:2181,df3:2181")
config.set("hbase.master" , "df1:60000")
config.set("hbase.zookeeper.property.clientPort" , "2181")

 

Table类:用于和hbase表直接通信;

在0.94版本之后就不推荐使用

val HTable = new HTable(conf, Bytes.toBytes(tablename))

而是使用

val table = Connection.getTable(TableName.valueOf(driver_info))

 小记--------hbase数据库java API 常用方法及案例 - 文章图片

 

 

Eg:
/**
* 0.94之前使用new HTable 之后使用Connection.getTable(TableName tablename);
* 用来与hbase表直接通信
*/
def tableoperation(): Unit = {
//获取表的实例
val tab = conn.getTable(TableName.valueOf("citycode"))
//查看rowkey的值为99手否在表中存在
val q: Boolean = tab.exists(new Get(Bytes.toBytes("99")))
//检查row/family/qualifier是否与数据库匹配。如果是,则提交put操作到服务端
val sss = tab.checkAndPut(Bytes.toBytes("99") , Bytes.toBytes("MM") , Bytes.toBytes("citycode") , Bytes.toBytes("3213") , put())
//释放所有资源或挂起内部缓冲区的更新
tab.close()
// 获取rowkey的列族MM的列名id的value值
val get = new Get(Bytes.toBytes("rowKey"))
val result: Result = tab.get(get)
val bytes = result.getValue(Bytes.toBytes("MM"),Bytes.toBytes("id"))
println(Bytes.toString(bytes))
//获取MM的scanner实例
val scanner:ResultScanner = tab.getScanner(Bytes.toBytes("MM"))
// 获取该表的HTableDescriptor实例
val tableDescriptor: HTableDescriptor = tab.getTableDescriptor()
//将put实例中的数据放入表中
tab.put(put())
}

 

HTableDescriptor类:hbase表的详细信息

 小记--------hbase数据库java API 常用方法及案例 - 文章图片

 

 

Eg:
//创建HTableDescriptor table表描述
val tabledescriptor = new HTableDescriptor(TableName.valueOf("order_info"))
//给表添加列簇
tabledescriptor.addFamily(new HColumnDescriptor("CC"))
//删除CC 列簇
tabledescriptor.removeFamily(Bytes.toBytes("CC"))
//获取表名
val tablename = tabledescriptor.getTableName

 

HColumnDescriptor类:列簇描述

 小记--------hbase数据库java API 常用方法及案例 - 文章图片

 

 

Eg:
val columndescriptor = new HColumnDescriptor(Bytes.toBytes("MM"))
val columnName = columndescriptor.getName()
val c = columndescriptor.getValue("id")

 

Put类:对单行执行put操作

 小记--------hbase数据库java API 常用方法及案例 - 文章图片

 

 

Eg:
val put = new Put(Bytes.toBytes("rowkey"))
//添加列id和值123 到MM列簇
put.addColumn(Bytes.toBytes("MM"),Bytes.toBytes("id"),Bytes.toBytes("123"))
val rowname = put.getRow()
val time = put.getTimeStamp()
val s:Boolean = put.isEmpty()

 

 

Get类:用于对单行执行get操作

 小记--------hbase数据库java API 常用方法及案例 - 文章图片

 

 

 

Scan类:用于执行扫描操作;通过不同的构造方法扫描整张表、整个列簇、整个列、一段时间戳范围内的数据

Eg:
val table: Table = conn.getTable(TableName.valueOf("driver_info"))
// scan 全表
val scan = new Scan()
//给scan加条件获取列簇MM中的列id
scan.addColumn(Bytes.toBytes("MM"),Bytes.toBytes("id"))
//获取列簇MM中所有的列
scan.addFamily(Bytes.toBytes("MM"))
// 获取时间戳在11111-22222之间的所有数据
scan.setTimeRange(11111,22222)
//scan从rowkey20190101 开始到结束
val scan1 = new Scan(Bytes.toBytes("20190101"))
//scan从rowkey20190101开始到20200101结束
val scan2 = new Scan(Bytes.toBytes("20190101"),Bytes.toBytes("20200101"))
//通过扫描器scan控制查询到的结果
val rs: ResultScanner = table.getScanner(scan)

 

Filter配合Scan工作

//1.实例化filter RowFilter 按行过滤 行键小于等于20190101的所有数据
//CompareFilter.CompareOp.LESS_OR_EQUAL 比较符 LESS_OR_EQUAL 小于等于、LESS小于、EQUAL等于、NOT_EQUAL不等于、GREATER_OR_EQUAL大于等于、GREATER大于、NO_OP 无操作
val rowfilter = new RowFilter(CompareFilter.CompareOp.LESS_OR_EQUAL,new BinaryComparator(Bytes.toBytes( "20190101")))
//实例化scan
val scan4 = new Scan()
//添加 行过滤器
scan.setFilter(rowfilter)
// 获取数据
val scanner: ResultScanner = table.getScanner(scan4)
import scala.collection.JavaConverters._
//遍历数据
for(sca <- scanner.iterator.asScala){
println(sca)
}
//2. 实例化 QualifierFilter 扫描出所有的列名为id 的列数据
val liefilter = new QualifierFilter(CompareFilter.CompareOp.EQUAL,new BinaryComparator(Bytes.toBytes("id")))
//3. 实例化FamilyFilter 扫描出所有的列簇为&#39;MM&#39;的列簇数据
val familyfilter = new FamilyFilter(CompareFilter.CompareOp.EQUAL,new BinaryComparator(Bytes.toBytes("MM")))
// 4.扫描出行键前缀为2019 的所有行数据
val prefilter = new PrefixFilter(Bytes.toBytes("2019"))
// 5.只返回每行数据的 行键-列簇-列;不返回值。
// 所以适用于 不需要值的应用场景, 减少值的传递
val keyOnlyfilter= new KeyOnlyFilter()
// 6.扫描出所有列的值为100 的 列
val valuefilter = new ValueFilter(CompareFilter.CompareOp.EQUAL, new BinaryComparator(Bytes.toBytes("100")))


推荐阅读
  • 本文介绍了如何通过C#语言调用动态链接库(DLL)中的函数来实现IC卡的基本操作,包括初始化设备、设置密码模式、获取设备状态等,并详细展示了将TextBox中的数据写入IC卡的具体实现方法。 ... [详细]
  • 在1995年,Simon Plouffe 发现了一种特殊的求和方法来表示某些常数。两年后,Bailey 和 Borwein 在他们的论文中发表了这一发现,这种方法被命名为 Bailey-Borwein-Plouffe (BBP) 公式。该问题要求计算圆周率 π 的第 n 个十六进制数字。 ... [详细]
  • spring boot使用jetty无法启动 ... [详细]
  • 使用TabActivity实现Android顶部选项卡功能
    本文介绍如何通过继承TabActivity来创建Android应用中的顶部选项卡。通过简单的步骤,您可以轻松地添加多个选项卡,并实现基本的界面切换功能。 ... [详细]
  • 本文详细介绍了 `org.apache.tinkerpop.gremlin.structure.VertexProperty` 类中的 `key()` 方法,并提供了多个实际应用的代码示例。通过这些示例,读者可以更好地理解该方法在图数据库操作中的具体用途。 ... [详细]
  • Beetl是一款先进的Java模板引擎,以其丰富的功能、直观的语法、卓越的性能和易于维护的特点著称。它不仅适用于高响应需求的大型网站,也适合功能复杂的CMS管理系统,提供了一种全新的模板开发体验。 ... [详细]
  • publicclassBindActionextendsActionSupport{privateStringproString;privateStringcitString; ... [详细]
  • JUnit下的测试和suite
    nsitionalENhttp:www.w3.orgTRxhtml1DTDxhtml1-transitional.dtd ... [详细]
  • 本文通过C++语言实现了一个递归算法,用于解析并计算数学表达式的值。该算法能够处理加法、减法、乘法和除法操作。 ... [详细]
  • CentOS下ProFTPD的安装与配置指南
    本文详细介绍在CentOS操作系统上安装和配置ProFTPD服务的方法,包括基本配置、安全设置及高级功能的启用。 ... [详细]
  • 深入理解Flink的水印机制
    本文详细探讨了Apache Flink框架中的水印机制,这是一种用于处理数据流中时间不一致问题的重要工具。通过介绍水印的工作原理及其在实际应用中的实现方式,帮助读者更好地理解和利用这一功能。 ... [详细]
  • 本文探讨了如何通过Service Locator模式来简化和优化在B/S架构中的服务命名访问,特别是对于需要频繁访问的服务,如JNDI和XMLNS。该模式通过缓存机制减少了重复查找的成本,并提供了对多种服务的统一访问接口。 ... [详细]
  • 长期从事ABAP开发工作的专业人士,在面对行业新趋势时,往往需要重新审视自己的发展方向。本文探讨了几位资深专家对ABAP未来走向的看法,以及开发者应如何调整技能以适应新的技术环境。 ... [详细]
  • 一、Advice执行顺序二、Advice在同一个Aspect中三、Advice在不同的Aspect中一、Advice执行顺序如果多个Advice和同一个JointPoint连接& ... [详细]
  • 本文介绍了SELinux的两种主要工作模式——强制模式和宽容模式,并提供了如何在CentOS 7中正确启用和配置SELinux的方法,以及在遇到登录问题时的解决策略。 ... [详细]
author-avatar
ian
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有