educoder平台使用Java操作HBase

精品文档精品文档PAGEPAGE6精品文档PAGE创建表packagestep1;importjava.io.IOException;importorg.apache.hadoop.conf.Configuration;importorg.apache.hadoop.hbase.HBaseConfiguration;importorg.apache.hadoop.hbase.HColumnDescriptor;importorg.apache.hadoop.hbase.HTableDescriptor;importorg.apache.hadoop.hbase.TableName;importorg.apache.hadoop.hbase.client.Admin;importorg.apache.hadoop.hbase.client.ColumnFamilyDescriptor;importorg.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;importorg.apache.hadoop.hbase.client.Connection;importorg.apache.hadoop.hbase.client.ConnectionFactory;importorg.apache.hadoop.hbase.client.Get;importorg.apache.hadoop.hbase.client.Put;importorg.apache.hadoop.hbase.client.Result;importorg.apache.hadoop.hbase.client.ResultScanner;importorg.apache.hadoop.hbase.client.Scan;importorg.apache.hadoop.hbase.client.Table;importorg.apache.hadoop.hbase.client.TableDescriptor;importorg.apache.hadoop.hbase.client.TableDescriptorBuilder;importorg.apache.hadoop.hbase.util.Bytes;/**HBase1.0versionofExampleClientthatuses{@codeConnection},{@codeAdmin}and{@codeTable}.*/publicclassTask{publicvoidcreateTable()throwsException{/*********Begin*********/Configurationconfig=HBaseConfiguration.create();Connectionconnection=ConnectionFactory.createConnection(config);try{//CreatetableAdminadmin=connection.getAdmin();try{TableNametableName=TableName.valueOf("dept");新API构建表TableDescriptor对象通过TableDescriptorBuilder构建；TableDescriptorBuildertableDescriptorTableDescriptorBuilder.newBuilder(tableName);ColumnFamilyDescriptorfamilyColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("data")).build();//构建列族对象tableDescriptor.setColumnFamily(family);//设置列族admin.createTable(tableDescriptor.build());//创建表==精选文库TableNameemp=TableName.valueOf("emp");//新API构建表//TableDescriptor对象通过TableDescriptorBuilder构建；TableDescriptorBuilderempDescriptor=TableDescriptorBuilder.newBuilder(emp);ColumnFamilyDescriptorempfamily=ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("emp")).build();//构建列族对象empDescriptor.setColumnFamily(empfamily);//设置列族admin.createTable(empDescriptor.build());//创建表}finally{admin.close();}}finally{connection.close();}/*********End*********/}}命令行：start-dfs.sh（Hadoop启动）回车start-hbase.sh（hbase启动）测评———————————————————————————————————————添加数据packagestep2;importjava.io.IOException;importorg.apache.hadoop.conf.Configuration;importorg.apache.hadoop.hbase.HBaseConfiguration;importorg.apache.hadoop.hbase.HColumnDescriptor;importorg.apache.hadoop.hbase.HTableDescriptor;importorg.apache.hadoop.hbase.TableName;importorg.apache.hadoop.hbase.client.Admin;importorg.apache.hadoop.hbase.client.ColumnFamilyDescriptor;importorg.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;importorg.apache.hadoop.hbase.client.Connection;importorg.apache.hadoop.hbase.client.ConnectionFactory;importorg.apache.hadoop.hbase.client.Get;importorg.apache.hadoop.hbase.client.Put;importorg.apache.hadoop.hbase.client.Result;importorg.apache.hadoop.hbase.client.ResultScanner;importorg.apache.hadoop.hbase.client.Scan;importorg.apache.hadoop.hbase.client.Table;importorg.apache.hadoop.hbase.client.TableDescriptor;—2精选文库importorg.apache.hadoop.hbase.client.TableDescriptorBuilder;importorg.apache.hadoop.hbase.util.Bytes;publicclassTask{publicvoidinsertInfo()throwsException{/*********Begin*********/Configurationconfig=HBaseConfiguration.create();Connectionconnection=ConnectionFactory.createConnection(config);Adminadmin=connection.getAdmin();TableNametableName=TableName.valueOf("tb_step2");TableDescriptorBuildertableDescriptor=TableDescriptorBuilder.newBuilder(tableName);ColumnFamilyDescriptorfamily=ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("data")).build();//构建列族对象tableDescriptor.setColumnFamily(family);//设置列族admin.createTable(tableDescriptor.build());//创建表//添加数据byte[]row1=Bytes.toBytes("row1");Putput1=newPut(row1);byte[]columnFamily1=Bytes.toBytes("data");//列byte[]qualifier1=Bytes.toBytes(String.valueOf(1));//列族修饰词byte[]value1=Bytes.toBytes("张三丰");//值put1.addColumn(columnFamily1,qualifier1,value1);byte[]row2=Bytes.toBytes("row2");Putput2=newPut(row2);byte[]columnFamily2=Bytes.toBytes("data");//列byte[]qualifier2=Bytes.toBytes(String.valueOf(2));//列族修饰词byte[]value2=Bytes.toBytes("张无忌");//值put2.addColumn(columnFamily2,qualifier2,value2);Tabletable=connection.getTable(tableName);table.put(put1);table.put(put2);/*********End*********/}}测评———————————————————————————————————————获取数据packagestep3;importjava.io.IOException;importorg.apache.hadoop.conf.Configuration;importorg.apache.hadoop.hbase.HBaseConfiguration;importorg.apache.hadoop.hbase.HColumnDescriptor;importorg.apache.hadoop.hbase.HTableDescriptor;importorg.apache.hadoop.hbase.TableName;—3精选文库importorg.apache.hadoop.hbase.client.Admin;importorg.apache.hadoop.hbase.client.ColumnFamilyDescriptor;importorg.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;importorg.apache.hadoop.hbase.client.Connection;importorg.apache.hadoop.hbase.client.ConnectionFactory;importorg.apache.hadoop.hbase.client.Get;importorg.apache.hadoop.hbase.client.Put;importorg.apache.hadoop.hbase.client.Result;importorg.apache.hadoop.hbase.client.ResultScanner;importorg.apache.hadoop.hbase.client.Scan;importorg.apache.hadoop.hbase.client.Table;importorg.apache.hadoop.hbase.client.TableDescriptor;importorg.apache.hadoop.hbase.client.TableDescriptorBuilder;importorg.apache.hadoop.hbase.util.Bytes;publicclassTask{publicvoidqueryTableInfo()throwsException{/*********Begin*********/Configurationconfig=HBaseConfiguration.create();Connectionconnection=ConnectionFactory.createConnection(config);Adminadmin=connection.getAdmin();TableNametableName=TableName.valueOf("t_step3");Tabletable=connection.getTable(tableName);//获取数据Getget=newGet(Bytes.toBytes("row1"));//定义get对象Resultresult=table.get(get);//通过table对象获取数据//System.out.println("Result:"+result);很多时候我们只需要获取“值”这里表示获取data:1列族的值byte[]valueBytes=result.getValue(Bytes.toBytes("data"),Bytes.toBytes("1"));//获取到的是字节数组将字节转成字符串StringvalueStr=newString(valueBytes,"utf-8");System.out.println("value:"+valueStr);TableNametableStep3Name=TableName.valueOf("table_step3");Tablestep3Table=connection.getTable(tableStep3Name);批量查询Scanscan=newScan();ResultScannerscanner=step3Table.getScanner(scan);try{inti=0;for(ResultscannerResult:scanner){//byte[]value=scannerResult.getValue(Bytes.toBytes("data"),Bytes.toBytes(1));System.out.println("Scan:"+scannerResult);byte[]row=scannerResult.getRow();—4精选文库System.out.println("rowName:"+newString(row,"utf-8"));}}finally{scanner.close();}/*********End*********/}}测评———————————————————————————————————————删除表packagestep4;importjava.io.IOException;importorg.apache.hadoop.conf.Configuration;importorg.apache.hadoop.hbase.HBaseConfiguration;importorg.apache.hadoop.hbase.HColumnDescriptor;importorg.apache.hadoop.hbase.HTableDescriptor;importorg.apache.hadoop.hbase.TableName;importorg.apache.hadoop.hbase.client.Admin;importorg.apache.hadoop.hbase.client.ColumnFamilyDescriptor;importorg.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;importorg.apache.hadoop.hbase.client.Connection;importorg.apache.hadoop.hbase.client.ConnectionFactory;importorg.apache.hadoop.hbase.client.Get;importorg.apache.hadoop.hbase.client.Put;importorg.apache.hadoop.hbase.client.Result;importorg.apache.hadoop.hbase.client.ResultScanner;importorg.apache.hadoop.hbase.client.Scan;importorg.apache.hadoop.hbase.client.Table;importorg.apache.hadoop.hbase.client.TableDescriptor;importorg.apache.hadoop.hbase.client.TableDescriptorBuilder;importorg.apache.hadoop.hbase.util.Bytes;publicclassTask{publicvoiddeleteTable()throwsException{/*********Begin*********/Configurationconfig=HBaseConfiguration.create();Connectionconnection=ConnectionFactory.createConnection(config);Adminadmin=connection.getAdmin();TableNametableName=TableName.valueOf("t_step4");admin.disableTable(tableName);admin.deleteTable(tableName);/*********End*********/}}—5精选文库测评—6