欢迎来到天天文库
浏览记录
ID:62984878
大小:939.71 KB
页数:14页
时间:2021-07-23
《最新educoder平台hbase开发:-java-api-表.docx》由会员上传分享,免费在线阅读,更多相关内容在教育资源-天天文库。
1、精品资料educoder平台HBase开发:-Java-API-管理表........................................精品资料第1关:JavaAPI获取表的列表packagestep1;importjava.util.ArrayList;importjava.util.List;importorg.apache.hadoop.conf.*;importorg.apache.hadoop.hbase.*;importorg.apache.hadoop.hbase.client.*;importorg.apache.hadoop.hbase.util.*;publi
2、cclassTask{publicvoidshowTableList()throwsException{/*********Begin*********/Configurationconf=HBaseConfiguration.create();Connectionconnection=ConnectionFactory.createConnection(conf);Adminadmin=connection.getAdmin();try{ListtableDescriptors=admin.listTableDescriptors();...........
3、.............................精品资料for(TableDescriptortableDescriptor:tableDescriptors){TableNametableName=tableDescriptor.getTableName();System.out.println("Table:"+tableName);System.out.println("texists:"+admin.tableExists(tableName));System.out.println("tenabled:"+admin.isTableEnabled(tableName))
4、;}}finally{admin.close();}/*********End*********/}}------------------------------------------------------------------第2关:修改表........................................精品资料packagestep2;importjava.io.IOException;importorg.apache.hadoop.conf.*;importorg.apache.hadoop.hbase.*;importorg.apache.hadoop.hbase.
5、client.*;importorg.apache.hadoop.hbase.io.compress.Compression;importorg.apache.hadoop.hbase.util.*;publicclassTask{publicvoidupdateTables()throwsException{/*********Begin*********/Configurationconfig=newConfiguration();Connectionconn=ConnectionFactory.createConnection(config);Adminadmin=conn.getAdm
6、in();String[]tableNames={"t_emp2","t_dept2"};//获取表的描述对象........................................精品资料for(inti=0;i7、es.toBytes("data"));//构建Builder对象buildFamily.setBlockCacheEnabled(false);buildFamily.setBlocksize(1024*1024*1);buildFamily.setCompressionType(Compression.Algorithm.GZ);ColumnFamilyDescriptorfamily=bui
7、es.toBytes("data"));//构建Builder对象buildFamily.setBlockCacheEnabled(false);buildFamily.setBlocksize(1024*1024*1);buildFamily.setCompressionType(Compression.Algorithm.GZ);ColumnFamilyDescriptorfamily=bui
此文档下载收益归作者所有