educoder平臺HBase高級特性：過濾器一

第1關(guān)：使用過濾器查詢指定行的數(shù)據(jù)packagestepl;importjava.io.IOException;importorg.apache.hadoop.cli.util.*;importorg.apache.hadoop.conf.*;importorg.apache.hadoop.hbase.*;importorg.apache.hadoop.hbase.client.*;importorg.apache.hadoop.hbase.filter.*;importorg.apache.hadoop.hbase.util.*;publicclassTask{publicvoidquery(StringtName)throwsException{/*********Begin*********/Configurationconfig=newConfiguration();Connectionconn=ConnectionFactory.createConnection(config);TableNametableName=TableName.valueOf(tName);Tabletable=conn.getTable(tableName);Scanscan1=newScan();scan1.addColumn(Bytes.toBytes("basic_info"),Bytes.toBytes("gender"));Filterfilter1=newRowFilter(CompareOperator.EQUAL,newBinaryComparator(Bytes.toBytes("2018")));scan1.setFilter(filter1);ResultScannerscanner1=table.getScanner(scan1);System.out.println("row:2018");for(Resultresult:scanner1){for(Cellcell:result.listCells()){System.out.println("basic_info:gender"+newString(CellUtil.cloneValue(cell),"utf-8"));}}scanner1.close();Scanscan2=newScan();scan2.addColumn(Bytes.toBytes("school_info"),Bytes.toBytes("college"));Filterfilter2=newRowFilter(CompareOperator.GREATER,newBinaryComparator(Bytes.toBytes("2018")));scan2.setFilter(filter2);ResultScannerscanner2=table.getScanner(scan2);for(Resultresult:scanner2){System.out.println("row:"+newString(result.getRow(),"utf-8"));for(Cellcell:result.listCells()){System.out.println("school_info:college"+newString(CellUtil.cloneValue(cell),"utf-8"));}}scanner2.close();

Scanscan3=newScan();scan3.addColumn(Bytes.toBytes("basic_info"),Bytes.toBytes("name"));Filterfilter3=newRowFilter(CompareOperator.LESS_OR_EQUAL,newBinaryComparator(Bytes.toBytes("2020")));scan3.setFilter(filter3);ResultScannerscanner3=table.getScanner(scan3);for(Resultresult:scanner3){newSystem.out.println("row:"+newString(result.getRow(),"utf-8"));for(Cellcell:result.listCells()){newSystem.out.println("basic_info:nameString(CellUtil.cloneValue(cell),"utf-8"));scanner3.close();conn.close();/*********End*********/第2關(guān)：使用正則表達式與子字符串匹配行鍵packagestep2;importjava.io.IOException;importorg.apache.hadoop.cli.util.*;importorg.apache.hadoop.conf.*;importorg.apache.hadoop.hbase.*;importorg.apache.hadoop.hbase.client.*;importorg.apache.hadoop.hbase.filter.*;importorg.apache.hadoop.hbase.filter.SubstringComparator;importorg.apache.hadoop.hbase.util.*;publicclassTask{publicvoidquery()throwsException{/*********Begin*********/Configurationconfig=newConfiguration();Connectionconn=ConnectionFactory.createConnection(config);TableNametableName=TableName.valueOf("t2_student_table");Tabletable=conn.getTable(tableName);Scanscanl=newScan();Filterfilterl=newRowFilter(CompareOperator.EQUAL,newRegexStringComparator("1.*9$"));//匹配任意開頭，以2結(jié)尾。scanl.setFilter(filterl);

ResultScannerscannerl=table.getScanner(scanl);for(Resultresult:scannerl){System.out.println("row:"+newString(result.getRow(),"utf-8"));for(Cellcell:result.listCells()){Stringfamily=Bytes.toString(CellUtil.cloneFamily(cell));Stringqualifier=Bytes.toString(CellUtil.cloneQualifier(cell));Stringvalue=Bytes.toString(CellUtil.cloneValue(cell));System.out.println(family+":"+qualifier+""+value);}}scanner1.close();Filterfilter2Scanscan2=newScan();Filterfilter2newRowFilter(CompareOperator.EQUAL,newSubstringComparator("231"));scan2.setFilter(filter2);ResultScannerscanner2=table.getScanner(scan2);for(Resultresult:scanner2){System.out.println("row:"+newString(result.getRow(),"utf-8"));for(Cellcell:result.listCells()){Stringfamily=Bytes.toString(CellUtil.cloneFamily(cell));Stringqualifier=Bytes.toString(CellUtil.cloneQualifier(cell));Stringvalue=Bytes.toString(CellUtil.cloneValue(cell));System.out.println(family+":"+qualifier+""+value);}}scanner2.close();conn.close();/*********End*********/第3關(guān)：列族過濾器、值過濾器、列名過濾器packagestep3;importjava.io.IOException;importorg.apache.hadoop.cli.util.*;importorg.apache.hadoop.conf.*;importorg.apache.hadoop.hbase.*;importorg.apache.hadoop.hbase.client.*;importorg.apache.hadoop.hbase.filter.*;importorg.apache.hadoop.hbase.util.*;importorg.apache.hadoop.hbase.filter.SubstringComparator;publicclassTask{publicvoidquery()throwsException{/*********Begin*********/Configurationconfig=newConfiguration();Connectionconn=ConnectionFactory.createConnection(config);TableNametableName=TableName.valueOf(Bytes.toBytes("t3_student_table"));Tabletable=conn.getTable(tableName);Filterfilter1=newFamilyFilter(CompareOperator.EQUAL,newBinaryComparator(Bytes.toBytes("school_info")));Getget1=newGet(Bytes.toBytes("1019"));get1.setFilter(filter1);Resultresult1=table.get(get1);System.out.println("row:"+newString(result1.getRow(),"utf-8"));for(Cellcell:result1.listCells()){Stringfamily=Bytes.toString(CellUtil.cloneFamily(cell));Stringqualifier=Bytes.toString(CellUtil.cloneQualifier(cell));Stringvalue=Bytes.toString(CellUtil.cloneValue(cell));System.out.println(family+":"+qualifier+""+value);}Filterfilter2=newQualifierFilter(CompareOperator.EQUAL,newSubstringComparator("c"));Getget2=newGet(Bytes.toBytes("2020"));get2.setFilter(filter2);Resultresult2=table.get(get2);System.out.println("row:"+newString(result2.getRow(),"utf-8"));for(Cellcell:result2.listCells()){Stringfamily=Bytes.toString(CellUtil.cloneFamily(cell));Stringqualifier=Bytes.toString(CellUtil.cloneQualifier(cell));Stringvalue=Bytes.toString(CellUtil.cloneValue(cell));System.out.println(family+":"+qualifier+""+value);}Scanscan3=newScan();Filterfilter3=newValueFilter(CompareOperator.EQUAL,newSubstringComparator("張"))；scan3.setFilter(filter3);ResultScannerscanner3=table.getScanner(scan3);for(Resultresult:scanner3){System.out.println("row:"+newString(result.getRow(),"utf-8"));for(Cellcell:re