欢迎来到天天文库
浏览记录
ID:40554838
大小:44.00 KB
页数:5页
时间:2019-08-04
《Hbase开源分布式数据库编程》由会员上传分享,免费在线阅读,更多相关内容在教育资源-天天文库。
1、Hbase开源分布式数据库编程小组成员:曹孝飞(226);刘旭文(211);罗长青(217)使用Java语言,可以进行HBase客户端编程,包含建立表、删除表、插入记录、删除记录、各种方式下的查询操作等。1.准备工作(1)下载后安装jdk包(这里使用的是jdk-6u10-rc2-bin-b32-windows-i586-p-12_sep_2008);(2)下载eclipse,解压到本地(这里使用的是eclipse-java-helios-SR2-win32);(3)下载HBase包,解压安装包到本地(这里使用的是hbase-0.90.2)。2.搭建开发环
2、境(1)运行Eclipse,创建一个新的Java工程“HBaseClient”,右键项目根目录,选择“Properties”->“JavaBuildPath”->“Library”->“AddExternalJARs”,将HBase解压后根目录下的hbase-0.90.2.jar、hbase-0.90.2-tests.jar和lib子目录下所有jar包添加到本工程的Classpath下。(2)按照步骤1中的操作,将自己所连接的HBase的配置文件hbase-site.xml添加到本工程的Classpath中,如下所示为配置文件的一个示例:13、uration>23hbase.rootdir4hdfs://hostname:9000/hbase567hbase.cluster.distributed8true91011hbase.zookeeper.quorum12*.*.*.*,*.*.*.*,*.*.*.*134、rty>1415hbase.defaults.for.version160.90.21718(3)下面可以在Eclipse环境下进行HBase编程了。3.HBase基本操作代码示例(1)初始化配置1privatestaticConfigurationconf=null;2/**3 *初始化配置4 */5static{6 conf=HBaseConfiguration.create();5、7}(2)创建表1/**2 *创建表操作3 *@throwsIOException4 */5publicvoidcreateTable(Stringtablename,String[]cfs)throwsIOException{6 HBaseAdminadmin=newHBaseAdmin(conf);7 if(admin.tableExists(tablename)){8 System.out.println("表已经存在!");9 }10 else{11 HTableDescriptortab6、leDesc=newHTableDescriptor(tablename);12 for(inti=0;i7、 *@throwsIOException5 */6publicvoiddeleteTable(Stringtablename)throwsIOException{7 try{8 HBaseAdminadmin=newHBaseAdmin(conf);9 admin.disableTable(tablename);10 admin.deleteTable(tablename);11 System.out.println("表删除成功!");12 }catch(MasterNotRunni8、ngExceptione){13 e.printStackTrac
3、uration>23hbase.rootdir4hdfs://hostname:9000/hbase567hbase.cluster.distributed8true91011hbase.zookeeper.quorum12*.*.*.*,*.*.*.*,*.*.*.*134、rty>1415hbase.defaults.for.version160.90.21718(3)下面可以在Eclipse环境下进行HBase编程了。3.HBase基本操作代码示例(1)初始化配置1privatestaticConfigurationconf=null;2/**3 *初始化配置4 */5static{6 conf=HBaseConfiguration.create();
4、rty>1415hbase.defaults.for.version160.90.217
5、7}(2)创建表1/**2 *创建表操作3 *@throwsIOException4 */5publicvoidcreateTable(Stringtablename,String[]cfs)throwsIOException{6 HBaseAdminadmin=newHBaseAdmin(conf);7 if(admin.tableExists(tablename)){8 System.out.println("表已经存在!");9 }10 else{11 HTableDescriptortab
6、leDesc=newHTableDescriptor(tablename);12 for(inti=0;i7、 *@throwsIOException5 */6publicvoiddeleteTable(Stringtablename)throwsIOException{7 try{8 HBaseAdminadmin=newHBaseAdmin(conf);9 admin.disableTable(tablename);10 admin.deleteTable(tablename);11 System.out.println("表删除成功!");12 }catch(MasterNotRunni8、ngExceptione){13 e.printStackTrac
7、 *@throwsIOException5 */6publicvoiddeleteTable(Stringtablename)throwsIOException{7 try{8 HBaseAdminadmin=newHBaseAdmin(conf);9 admin.disableTable(tablename);10 admin.deleteTable(tablename);11 System.out.println("表删除成功!");12 }catch(MasterNotRunni
8、ngExceptione){13 e.printStackTrac
此文档下载收益归作者所有