七、删除数据—跟据行键删除一行数据

与前面类似，删除操作中先创建一个Delete对象将行键传入，然后通过addColumn()方法将改行键对应的列族和列添加上，并从表中进行删除

public static void deleteRow(String tableName,String row,String cf,String col)throws IOException{
Configuration cfg = HBaseConfiguration.create();
cfg.set("hbase.zookeeper.quorum", "centos01");
cfg.set("hbase.zookeeper.property.clientPort", "2181");
Connection conn = ConnectionFactory.createConnection(cfg);
HBaseAdmin admin = (HBaseAdmin)conn.getAdmin();
if(admin.tableExists(tableName)){Table table = conn.getTable(TableName.valueOf(tableName));    Delete d = new Delete(Bytes.toBytes(row));d.addColumn(Bytes.toBytes(cf),Bytes.toBytes(col));           table.delete(d);table.close();conn.close();         System.out.println("删除成功");
}
}

主函数：

public static void main(String[] args) throws IOException{deleteRow("t4","6666","cf1","name");}

实验结果：

命令行查询：

可知删除成功。

八、扫描Scan

Scan是对整个表进行的扫描，给定起始和终止的行键后，将该范围内的表中的内容扫描出来。

public static void scanRow(String tableName,String rk1,String rk2,String cf)throws IOException{
Configuration cfg = HBaseConfiguration.create();
cfg.set("hbase.zookeeper.quorum", "centos01");
cfg.set("hbase.zookeeper.property.clientPort", "2181");
Connection conn = ConnectionFactory.createConnection(cfg);
HBaseAdmin admin = (HBaseAdmin)conn.getAdmin();
if(admin.tableExists(tableName)){Table table = conn.getTable(TableName.valueOf(tableName));Scan s = new Scan();//传入扫描行键的起始位置s.setStartRow(Bytes.toBytes(rk1));s.setStopRow(Bytes.toBytes(rk2));//从表中拿到该行键范围内的数据ResultScanner rs = table.getScanner(s);//使用迭代器出Iterator<Result> it = rs.iterator();while(it.hasNext()){Result r = it.next();Cell[] cells = r.rawCells();for(Cell c:cells){System.out.println("cell="+Bytes.toString(CellUtil.cloneRow(c)));System.out.println("Family="+Bytes.toString(CellUtil.cloneFamily(c)));System.out.println("Qualifier="+Bytes.toString(CellUtil.cloneQualifier(c)));System.out.println("Value="+Bytes.toString(CellUtil.cloneValue(c)));}}
}
}

主函数：

public static void main(String[] args)throws IOException{
scanRow("t4","4444","5555","cf1");
}

实验结果;

使用Java对HBase进行操作（三）相关推荐

用Java API实现HDFS操作（三）问题汇总
说明:整理博主用Java API实现HDFS操作时遇到的问题问题为搭建分布式操作环境–在ubuntu16中安装IDEA2021.tomcat9.0.hadoop2.7,建议分配磁盘空间30G及以上 ...
java web 数据库操作_Java Web----Java Web的数据库操作(三)
Java Web的数据库操作前面介绍了JDBC技术和JDBC API及API的使用示例,下面详细介绍JDBC在Web中的应用. 四.JDBC在Java Web中的应用通常情况下,Web程序操作数据 ...
HBase 学习（三） JavaAPI的使用
一,前言二,HBaseDDL 三,HBaseDML 正文一,前言一般情况下不会直接在Shell对Hbase进行操作,而是通过提高的API,我们先对Java的API进行介绍. 二,HBaseDDL ...
Hbase具体操作(图文并茂且超超全~~~)
目的: (1)理解 HBase 在 Hadoop 体系结构中的角色. (2)熟练使用 HBase 操作常用的 Shell 命令. 目标: (1)熟悉hbase相关操作,掌握建表.修改表.查表.删除表等 ...
Java高并发秒杀API(三)之Web层
Java高并发秒杀API(三)之Web层 1. 设计前的分析 Web层内容相关前端交互设计 Restful规范 SpringMVC Bootstrap + jQuery 前端页面流程详情页流程逻辑 ...
Java IO流学习总结三：缓冲流-BufferedInputStream、BufferedOutputStream
Java IO流学习总结三:缓冲流-BufferedInputStream.BufferedOutputStream 转载请标明出处:http://blog.csdn.net/zhaoyanjun6/ ...
java大文件读写操作，java nio 之MappedByteBuffer，高效文件/内存映射
http://langgufu.iteye.com/blog/2107023 java处理大文件,一般用BufferedReader,BufferedInputStream这类带缓冲的Io类,不过如果 ...
java大文件读写操作
转载自:http://blog.csdn.net/akon_vm/article/details/7429245 RandomAccessFile RandomAccessFile是用来访问那些保存数 ...
我的面试标准：第一能干活，第二Java基础要好，第三最好熟悉些分布式框架！...
点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试资料作者:hsm_computer www.cnblogs.com/J ...

使用Java对HBase进行操作（三）

七、删除数据—跟据行键删除一行数据

八、扫描Scan

使用Java对HBase进行操作（三）相关推荐

最新文章

热门文章

使用Java对HBase进行操作（三）

七、删除数据—跟据行键删除一行数据

八、 扫描Scan

使用Java对HBase进行操作（三）相关推荐

最新文章

热门文章

八、扫描Scan