educoder平台HBase开发：批量操作

1、第 1 关：批量获取数据package step1;import java.io.IOException;import java.util.ArrayList;import java.util.List;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.hbase.Cell;import org.apache.hadoop.hbase.CellScanner;import org.apache.hadoop.hbase.CellUtil;import org.apache.hadoop.hbase.HBas

2、eConfiguration;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.Get;import org.apache.hadoop.hbase.client.HTable;import o

3、rg.apache.hadoop.hbase.client.Result;import org.apache.hadoop.hbase.client.ResultScanner;import org.apache.hadoop.hbase.client.Scan;import org.apache.hadoop.hbase.client.Table;import org.apache.hadoop.hbase.client.TableDescriptor;import org.apache.hadoop.hbase.generated.rest.rest_jsp;import org.apac

4、he.hadoop.hbase.util.Bytes; public class Task public void batchGet() throws Exception *Begin*Configuration config = HBaseConfiguration.create();Connection Connection = ConnectionFactory.createConnection(config);List<String> rows = new ArrayList<>();rows.add("2018");/rows.add(&q

5、uot;2019");rows.add("2020");TableName tableName =TableName.valueOf(Bytes.toBytes("step1_student");Table table = Connection.getTable(tableName);getData(table,rows);/* 匸r" */public List<String> getData(Table table, List<String> rows) throws Exception List<G

6、et> gets = new ArrayList<>();for (String str : rows) Get get = new Get(Bytes.toBytes(str);gets.add(get);List<String> values = new ArrayList<>();Result results = table.get(gets);for (Result result : results) System.out.println("Row:" + Bytes.toString(result.getRow();for

7、 (Cell kv : result.rawCells() String family = Bytes.toString(CellUtil.cloneFamily(kv);String qualifire = Bytes.toString(CellUtil.cloneQualifier(kv);String value = Bytes.toString(CellUtil.cloneValue(kv);values.add(value);System.out.println(family + ":" + qualifire + "t" + value);r

8、eturn values;命令行：HBase点击测评之前，请先开启 Hadoop (start-dfs.sh)和HBase(start- hbase.sh),并且需要等待HBase初始化完成(20秒左右)，否则无法在 中创建表。第 2 关：批量删除数据package step2;import java.io.IOException;import java.util.ArrayList;import java.util.HashMap;import java.util.List;import java.util.Map;import org.apache.hadoop.conf.Configur

9、ation;import org.apache.hadoop.hbase.HBaseConfiguration;import org.apache.hadoop.hbase.HColumnDescriptor;import org.apache.hadoop.hbase.HTableDescriptor;import org.apache.hadoop.hbase.TableDescriptors;import org.apache.hadoop.hbase.TableName;import org.apache.hadoop.hbase.client.*;import org.apache.

10、hadoop.hbase.util.Bytes; public class Task public void batchDelete()throws Exception9/ 9*Begin*Configuration conf = HBaseConfiguration.create();Connection conn = ConnectionFactory.createConnection(conf);TableName tableName = TableName.valueOf("step2_table");Table table = conn.getTable(tabl

11、eName);List<String> rows1 = new ArrayList(); for(int i = 1; i<6;i+)String row = "row" + i; rows1.add(row);delete(table,rows1);List<String> rows2 = new ArrayList<>(); for(int i = 7;i<11;i+)String row = "row" + i; rows2.add(row);delete(table,rows2);* End*pub

12、lic void delete(Table table,List<String> rows)throws IOException List<Delete> deletes = new ArrayList<>();for(String str : rows)byte row = Bytes.toBytes(str);Delete delete = new Delete(row);deletes.add(delete);table.delete(deletes);第 3 关：批量导入数据至 HBasepackage step3;import java.io.IO

13、Exception;import java.util.ArrayList;import java.util.HashMap;import java.util.List;import java.util.Map;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.hbase.HBaseConfiguration;import org.apache.hadoop.hbase.HColumnDescriptor;import org.apache.hadoop.hbase.HTableDescriptor;impo

14、rt org.apache.hadoop.hbase.TableDescriptors;import org.apache.hadoop.hbase.TableName;import org.apache.hadoop.hbase.client.Admin;import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;import org.apache.hadoop.hbase.client.Conn

15、ection;import org.apache.hadoop.hbase.client.ConnectionFactory;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.ResultScanner;import org.apache.hadoop.hbase.client.Scan;import org.ap

16、ache.hadoop.hbase.client.Table;import org.apache.hadoop.hbase.client.TableDescriptor;import org.apache.hadoop.hbase.client.TableDescriptorBuilder;import org.apache.hadoop.hbase.util.Bytes;public class Task public void batchPut()throws Exception*Begin*Configuration config = new Configuration();Connec

17、tion conn = ConnectionFactory.createConnection(config);Admin admin = conn.getAdmin();/ 建表TableName tableName = TableName.valueOf(Bytes.toBytes("stu");TableDescriptorBuilder builder =TableDescriptorBuilder.newBuilder(tableName);ColumnFamilyDescriptorfamilyColumnFamilyDescriptorBuilder.newBu

18、ilder(Bytes.toBytes("basic_info").build();ColumnFamilyDescriptorfamily2ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("school_info").build( );=builder.setColumnFamily(family);builder.setColumnFamily(family2); admin.createTable(builder.build();List<Put> puts = new Ar

19、rayList<>();String rows = "20181122","20181123"Strin gbasic_i nfos二"阿克蒙"，”male","1987-05- 23","telquot;,"HUNan-ChangSha","F格拉","male","1986-05- 23","telquot;,"HUNan-Cha

20、ngSha"String basic_colums = "name","gender","birthday","connect","address"Stringschool_infos="ChengXing","class12","Software","ChengXing","class 2 grade 2","Software"String school_colums = "college","class",&