资源简介
本代码是java链接并对hbase进行增删改查操作的实例代码,并包括批量插入,范围查询等,并包含所需jar包.
代码片段和文件信息
/**
*
*/
package whg.hbase;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.HbaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.NamespaceDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.util.Bytes;
/**
*
* 类描述:hbase 增删改查操作
* 创建人:wanghonggang
* 创建时间:2018年11月27日 下午3:18:10
*/
public class HbaseCRUD {
//hbase 链接
static Connection conn;
// 数据库元数据操作对象
static Admin admin;
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
try {
System.out.println(“--------------- 开始! -----------------“);
setup();//初始化
createTable();//创建表
insert();//插入数据
update();//更新数据
delete();//删除数据
select();//查询数据
deleteTable();//删除表
closeConnection();//关闭连接
System.out.println(“--------------- 结束! -----------------“);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 初始化
* @throws Exception
*/
public static void setup() throws Exception{
System.out.println(“--------------- 开始初始化 -----------------“);
//取得一个数据库连接的配置参数对象
Configuration conf = HbaseConfiguration.create();
//设置连接参数:Hbase数据库所在的主机IP
conf.set(“hbase.zookeeper.quorum“ “datanode1datanode2datanode3“);
//设置连接参数:Hbase数据库使用的端口
conf.set(“hbase.zookeeper.property.clientPort“ “2181“);
// conf.set(“hbase.master“ “manager:16000“);
conf.set(“hbase.master.port“ “16000“);
conf.set(“hbase.zookeeper.useMulti“ “true“);
conf.set(“hbase.regionserver.info.port“ “16030“);
conf.set(“hbase.regionserver.port“ “16020“);
conf.set(“zookeeper.znode.parent“ “/hbase-unsecure“);
//取得一个数据库连接对象
conn=ConnectionFactory.createConnection(conf);
//取得一个数据库元数据操作对象
admin=conn.getAdmin();
System.out.println(“--------------- 初始化完成 -----------------“);
}
/**
* 创建表
* @throws Exception
*/
public static void createTable()throws Exception{
System.out.println(“---------------创建表 START-----------------“);
//创建namespace
admin.createNamespace(NamespaceDescriptor.create(“WHG“).build());
// 数据表表名
String tableName=“WHG:TB1“;
// 新建一个数据表表名对象
TableName tn = TableName.valueOf(tableName);
//判断表是否存在
if(admin.tableExists(tn)){
System.out.println(tableName+“表已经存在!“);
}else{
System.out.println(tableName+“表不存在,开始
属性 大小 日期 时间 名称
----------- --------- ---------- ----- ----
文件 8230 2018-11-27 16:05 .classpath
文件 385 2018-11-27 16:04 .project
目录 0 2018-11-27 16:04 .settings\
文件 598 2018-11-27 16:04 .settings\org.eclipse.jdt.core.prefs
目录 0 2018-11-27 16:05 bin\
目录 0 2018-11-27 16:05 bin\whg\
目录 0 2018-11-27 16:05 bin\whg\hba
文件 7757 2018-11-27 16:05 bin\whg\hba
目录 0 2018-11-27 16:05 lib\
文件 62983 2018-03-09 15:28 lib\activation-1.1.jar
文件 71717 2018-03-09 15:28 lib\antisamy-1.4.3.jar
文件 4467 2018-03-09 15:28 lib\aopalliance-1.0.jar
文件 44925 2018-03-09 15:28 lib\apacheds-i18n-2.0.0-M15.jar
文件 691479 2018-03-09 15:28 lib\apacheds-kerberos-codec-2.0.0-M15.jar
文件 16560 2018-03-09 15:28 lib\api-asn1-api-1.0.0-M20.jar
文件 79912 2018-03-09 15:28 lib\api-util-1.0.0-M20.jar
文件 43033 2018-03-09 15:28 lib\asm-3.1.jar
文件 303139 2018-03-09 15:28 lib\avro-1.7.4.jar
文件 317060 2018-03-09 15:28 lib\batik-css-1.7.jar
文件 10267 2018-03-09 15:28 lib\batik-ext-1.7.jar
文件 130304 2018-03-09 15:28 lib\batik-util-1.7.jar
文件 143992 2018-03-09 15:28 lib\bsh-core-2.0b4.jar
文件 188671 2018-03-09 15:28 lib\commons-beanutils-1.7.0.jar
文件 168760 2018-03-09 15:28 lib\commons-beanutils-core-1.7.0.jar
文件 41123 2018-03-09 15:28 lib\commons-cli-1.2.jar
文件 263965 2018-03-09 15:28 lib\commons-codec-1.9.jar
文件 588337 2018-03-09 15:28 lib\commons-collections-3.2.2.jar
文件 241367 2018-03-09 15:28 lib\commons-compress-1.4.1.jar
文件 298829 2018-03-09 15:28 lib\commons-configuration-1.6.jar
文件 24239 2018-03-09 15:28 lib\commons-daemon-1.0.13.jar
文件 143602 2018-03-09 15:28 lib\commons-digester-1.8.jar
............此处省略103个文件信息
相关资源
- 大数据hadoop,spark,hive等等面试汇总
- 用itext实现pdf导出表格数据及水印操作
- 09_尚硅谷大数据技术之Kafka.doc
-
10_尚硅谷大数据技术之Hba
se.doc - 尚硅谷1024专用全套视频打包地址
- 基于java的大数据预测系统设计可运行
- Snapde电子表格软件,一个超大数据量
- 07_尚硅谷大数据技术之Hive.doc
-
fli
nk-1.8.1-bin-scala_2.11.tgz -
java使用hba
se-1.2版本需要的最小的 -
Hba
se java DBHelper CRUD等通用方法 - Java解析大数据量Excel,可解析1048576行
- ClickHouse-大数据分析的屠龙刀
- 05_尚硅谷大数据技术之HadoopMapReduce.
- squirrel-sql-4.0.0-standard.jar
- spark-assembly-1.5.2-hadoop2.6.0jar包
-
java解决hive快速导数据到Hba
se代码 - 尚硅谷大数据技术之Kafka笔记+代码+资
- Anand.Rajaraman-大数据:互联网大规模数
- jdk-13.0.2_windows-x64_bin.exe
-
hadoop hba
se 全jar包 -
南大数据库-gba
se - java Excel数据导出,HSSH、 XSSF、SXSSF、
- 山东大学 大数据实验二 倒排索引算法
- 小牛学堂大数据全套视频+实战
- 山东大学大数据实验二:倒排索引H
- Spark最全操作完整
- poi读取大数据量excel文件,避免内存溢
- Java导出Excel(适合分页_大数据量)
-
hive-hba
se-handler-1.2.1.jar
评论
共有 条评论