1、HB…

创建一个学生信息表用来存储学生的姓名姓名作为行键且假设姓名不会重复以及考试成绩其中考试成绩score是一个列族存储了各个科目的考试成绩。

然后向student中添加数据

1、HBase依赖

dependencygroupIdorg.apache.hbase/groupIdartifactIdhbase-server/artifactIdversion2.2.0/version

/dependency

dependencygroupIdorg.apache.hbase/groupIdartifactIdhbase-client/artifactIdversion2.2.0/version

package

com.example.demo.service.ICodeService;

import

org.springframework.beans.factory.annotation.Autowired;

import

org.springframework.boot.ApplicationArguments;

import

org.springframework.boot.ApplicationRunner;

import

org.springframework.core.annotation.Order;

import

org.springframework.stereotype.Component;import

java.util.HashMap;

HBaseConfiguration.create();System.setProperty(HADOOP_USER_NAME,

hadoop);conf.set(HADOOP_USER_NAME,

hadoop);conf.set(hbase.root.dir,

hdfs://master:9000/hbase);conf.set(hbase.zookeeper.quorum,

master);//配置Zookeeper的ip地址conf.set(hbase.zookeeper.property.clientPort,

ConnectionFactory.createConnection(conf);admin

关闭所有连接**

TableName.valueOf(myTableName);if

表已经存在);}

HTableDescriptor(tableName);//for

(String

hTableDescriptor.addFamily(hColumnDescriptor);//}//admin.createTable(hTableDescriptor);TableDescriptorBuilder

tableDescriptor

TableDescriptorBuilder.newBuilder(tableName);

for

ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(str)).build();//

构建列族对象

tableDescriptor.setColumnFamily(columnFamily);

设置列族}admin.createTable(tableDescriptor.build());

创建表}}/***

conn.getTable(TableName.valueOf(tableName));Put

put

Put(rowkey.getBytes());put.addColumn(colFamily.getBytes(),col.getBytes(),value.getBytes());table.put(put);table.close();}/***

根据行键删除数据*

conn.getTable(TableName.valueOf(tableName));Delete

delete

Delete(rowkey.getBytes());table.delete(delete);table.close();}/***

获取数据*

conn.getTable(TableName.valueOf(tableName));Get

get

Get(rowkey.getBytes());get.addColumn(colFamily.getBytes(),col.getBytes());Result

result

table.get(get);System.out.println(new

String(result.getValue(colFamily.getBytes(),col.getBytes())));table.close();}public

static

{init();createTable(student,new

String[]{score});insertData(student,zhangsan,score,English,69);insertData(student,zhangsan,score,Math,86);insertData(student,zhangsan,score,Computer,77);getData(student,zhangsan,score,Computer);close();}

LESS

匹配完整字节数组Bytes.compareTo(byte[])

EQUAL

3.1、ResultScanner结果处理handleResultScanner

/***

handleResultScanner(ResultScanner

scanner)

{//因为ResultScanner类继承了迭代器//使用增强for循环遍历for

(Result

Bytes.toString(rs.getRow());System.out.println(当前行的rowkey为

id);//继续增强for循环得到每一行中的每一个单元格列//获取一行中的所有单元格for

(Cell

Bytes.toString(CellUtil.cloneFamily(cell));//获取该单元格的列名String

colName

Bytes.toString(CellUtil.cloneQualifier(cell));//获取该单元格的列值String

value

Bytes.toString(CellUtil.cloneValue(cell));System.out.println(family

colName

Bytes.toString(rs.getValue(info.getBytes(),

age

Bytes.toString(rs.getValue(info.getBytes(),

gender

Bytes.toString(rs.getValue(info.getBytes(),

clazz

Bytes.toString(rs.getValue(info.getBytes(),

clazz.getBytes()));System.out.println(学号

,姓名

通过RowFilter与BinaryComparator过滤比rowKey

Test

TableName.valueOf(students);Table

studentTable

BinaryComparator(1500100010.getBytes());

rowFilter

RowFilter(CompareOperator.LESS,

binaryComparator);

Scan();scan.setFilter(rowFilter);

​ResultScanner

studentTable.getScanner(scan);handleResultScanner(scanner);

catch

通过FamilyFilter与SubstringComparator查询列簇名包含in的所有列簇下面的数据*/

Test

TableName.valueOf(students);Table

studentTable

​//创建一个比较器对象//只要列簇名中包含了in就把该列簇下的所有列查询出来SubstringComparator

substringComparator

FamilyFilter(CompareOperator.EQUAL,

​Scan

Scan();scan.setFilter(familyFilter);

​//获取数据ResultScanner

studentTable.getScanner(scan);handleResultScanner(scanner);

catch

TableName.valueOf(students);Table

studentTable

​//创建前缀比较器BinaryPrefixComparator

new

BinaryPrefixComparator(i.getBytes());

familyFilter

FamilyFilter(CompareOperator.EQUAL,

​Scan

Scan();scan.setFilter(familyFilter);

​ResultScanner

studentTable.getScanner(scan);handleResultScanner(scanner);

catch

通过QualifierFilter与SubstringComparator查询列名包含ge的列的值**/

Test

TableName.valueOf(students);Table

studentTable

​//创建包含比较器//age//genderSubstringComparator

substringComparator

QualifierFilter(CompareOperator.EQUAL,

​Scan

Scan();scan.setFilter(qualifierFilter);

​ResultScanner

studentTable.getScanner(scan);handleResultScanner(scanner);

catch

通过QualifierFilter与SubstringComparator查询列名包含ge的列的值*/

Test

TableName.valueOf(students);Table

studentTable

QualifierFilter(CompareOperator.EQUAL,

​Scan

Scan();scan.setFilter(qualifierFilter);

​ResultScanner

studentTable.getScanner(scan);handleResultScanner(scanner);

catch

通过ValueFilter与BinaryPrefixComparator过滤出所有的cell中值以

Test

TableName.valueOf(students);Table

studentTable

​//创建前缀比较器BinaryPrefixComparator

new

BinaryPrefixComparator(张.getBytes());

valueFilter

ValueFilter(CompareOperator.EQUAL,

​Scan

Scan();scan.setFilter(valueFilter);

​ResultScanner

​//因为ResultScanner类继承了迭代器//使用增强for循环遍历

for

Bytes.toString(CellUtil.cloneFamily(cell));

String

Bytes.toString(CellUtil.cloneQualifier(cell));

String

Bytes.toString(CellUtil.cloneValue(cell));

colName

​handleResultScanner(scanner);}

catch

过滤出文科的学生只会返回以文科开头的数据列其他列的数据不符合条件不会返回*/

Test

​//创建正则比较器RegexStringComparator

new

ValueFilter(CompareFilter.CompareOp.EQUAL,

​Scan

Scan();scan.setFilter(valueFilter);

​ResultScanner

students.getScanner(scan);handleResultScanner(scanner);

catch

SingleColumnValueFilter会返回满足条件的cell所在行的所有cell的值即会返回一行数据**

通过SingleColumnValueFilter与查询文科班所有学生信息*/

Test

TableName.valueOf(students);Table

studentTable

​//创建一个正则比较器RegexStringComparator

new

​//创建单列值过滤器对象SingleColumnValueFilter

new

SingleColumnValueFilter(info.getBytes(),clazz.getBytes(),CompareOperator.EQUAL,regexStringComparator);

​Scan

Scan();scan.setFilter(singleColumnValueFilter);

​ResultScanner

studentTable.getScanner(scan);handleResultScanner(scanner);

catch

3.7、列值排除过滤器SingleColumnValueExcludeFilter

/***

与SingleColumnValueFilter相反会排除掉指定的列其他的列全部返回**

通过SingleColumnValueExcludeFilter与BinaryComparator查询文科一班所有学生信息最终不返回clazz列*/

Test

SingleColumnValueExcludeFilter(){try

students

TableName.valueOf(students);Table

studentTable

BinaryComparator(文科一班.getBytes());

​//创建一个列值排除过滤器SingleColumnValueExcludeFilter

new

SingleColumnValueExcludeFilter(info.getBytes(),clazz.getBytes(),CompareOperator.EQUAL,binaryComparator);

​Scan

Scan();scan.setFilter(singleColumnValueExcludeFilter);

​ResultScanner

studentTable.getScanner(scan);handleResultScanner(scanner);

catch

通过PrefixFilter查询以150010008开头的所有前缀的rowkey*/

Test

TableName.valueOf(students);Table

studentTable

PrefixFilter(150010008.getBytes());Scan

scan

​scan.setFilter(prefixFilter);ResultScanner

scanner

studentTable.getScanner(scan);handleResultScanner(scanner);

catch

Scan();//设置起始rowKeyscan.setStartRow(.getBytes());//设置最大的返回结果返回pageSize条scan.setMaxResultSize(pageSize);//分页过滤器PageFilter

pageFilter

PageFilter(pageSize);scan.setFilter(pageFilter);ResultScanner

resultScanner

result.getRow();System.out.println(数据的rowKey为

cells

cell.getValue();//id列和age列是整型数据if

(f1.equals(Bytes.toString(family))

id.equals(Bytes.toString(qualifier))

age.equals(Bytes.toString(value))){System.out.println(列族为Bytes.toString(family)列名为Bytes.toString(qualifier)列值为Bytes.toInt(value));}

else

{System.out.println(列族为Bytes.toString(family)列名为Bytes.toString(qualifier)列值为Bytes.toString(value));}}}}

else

1;scan.setMaxResultSize(resultSize);//设置一次性往前扫描5条最后一个rowKey是第三页起始rowKeyPageFilter

pageFilter

PageFilter(resultSize);scan.setFilter(pageFilter);//resultScanner里面有5条数据ResultScanner

scanner

Scan();scan1.setStartRow(startRow.getBytes());scan1.setMaxResultSize(pageSize);PageFilter

pageFilter1

PageFilter(pageSize);scan1.setFilter(pageFilter1);ResultScanner

scanner1

result.getRow();System.out.println(数据的rowKey为

cells

Bytes.toString(CellUtil.cloneFamily(cell));//获取该单元格的列名String

colName

Bytes.toString(CellUtil.cloneQualifier(cell));//获取该单元格的列值String

value

Bytes.toString(CellUtil.cloneValue(cell));//id列和age列是整型数据if

(f1.equals(Bytes.toString(family))

id.equals(Bytes.toString(qualifier))

age.equals(Bytes.toString(value))){System.out.println(列族为Bytes.toString(family)列名为Bytes.toString(qualifier)列值为Bytes.toInt(value));}

else

{System.out.println(列族为Bytes.toString(family)列名为Bytes.toString(qualifier)列值为Bytes.toString(value));}}}}

/***

通过运用4种比较器过滤出姓于年纪大于23岁性别为女且是理科的学生。

**

正则比较器

TableName.valueOf(students);Table

studentTable

第一个过滤器过滤出是理科开头的班级*/RegexStringComparator

new

RegexStringComparator(^理科.*);//单列值过滤器SingleColumnValueFilter

new

SingleColumnValueFilter(info.getBytes(),

clazz.getBytes(),CompareOperator.EQUAL,

​/***

SubstringComparator(女);SingleColumnValueFilter

new

SingleColumnValueFilter(info.getBytes(),

gender.getBytes(),CompareOperator.EQUAL,

​/***

第三个过滤器过滤出年龄大于23岁的*/BinaryComparator

binaryComparator

BinaryComparator(20.getBytes());SingleColumnValueFilter

new

SingleColumnValueFilter(info.getBytes(),

age.getBytes(),CompareOperator.GREATER,

binaryComparator);

第四个过滤器过滤出姓于的学生*/BinaryPrefixComparator

new

BinaryPrefixComparator(于.getBytes());SingleColumnValueFilter

new

SingleColumnValueFilter(info.getBytes(),

name.getBytes(),CompareOperator.EQUAL,

​Scan

​//要想实现多个需求同时过滤就需要创建多个过滤器添加到一个过滤器列表中//然后将过滤器列表传给扫描器scanFilterList

filterList

FilterList();filterList.addFilter(singleColumnValueFilter);filterList.addFilter(singleColumnValueFilter1);filterList.addFilter(singleColumnValueFilter2);filterList.addFilter(singleColumnValueFilter3);

​ResultScanner

TableName.valueOf(students);Table

studentTable

创建第一个过滤器过滤是以15001001开头的rowkey*/BinaryPrefixComparator

new

BinaryPrefixComparator(15001001.getBytes());//创建行键过滤器RowFilter

rowFilter

RowFilter(CompareOperator.EQUAL,

​/***

创建第二个过滤器过滤出文科的学生*/RegexStringComparator

new

RegexStringComparator(^文科.*);SingleColumnValueFilter

new

SingleColumnValueFilter(info.getBytes(),

clazz.getBytes(),CompareOperator.EQUAL,regexStringComparator);

​FilterList

FilterList();filterList.addFilter(rowFilter);filterList.addFilter(singleColumnValueFilter);

​Scan

Scan();scan.setFilter(filterList);ResultScanner

scanner

studentTable.getScanner(scan);handleResultScanner(scanner);

catch