基于springboot集成hbase过程解析
这篇文章主要介绍了基于springboot集成hbase过程解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
springboot-habse:
https://github.com/spring-projects/spring-hadoop-samples/tree/master/hbase
依赖：
org.springframework.data spring-data-hadoop-hbase 2.5.0.RELEASE org.apache.hbase hbase-client 1.1.2 org.springframework.data spring-data-hadoop 2.5.0.RELEASE
增加配置
官方提供的方式是通过xml方式，简单改写后如下：
@Configuration
publicclassHBaseConfiguration{
@Value("${hbase.zookeeper.quorum}")
privateStringzookeeperQuorum;
@Value("${hbase.zookeeper.property.clientPort}")
privateStringclientPort;
@Value("${zookeeper.znode.parent}")
privateStringznodeParent;
@Bean
publicHbaseTemplatehbaseTemplate(){
org.apache.hadoop.conf.Configurationconf=neworg.apache.hadoop.conf.Configuration();
conf.set("hbase.zookeeper.quorum",zookeeperQuorum);
conf.set("hbase.zookeeper.property.clientPort",clientPort);
conf.set("zookeeper.znode.parent",znodeParent);
returnnewHbaseTemplate(conf);
}
}
application.yml：
hbase: zookeeper: quorum:hadoop001,hadoop002,hadoop003 property: clientPort:2181 zookeeper: znode: parent:/hbase
HbaseTemplatetest:
@Service
@Slf4j
publicclassHBaseService{
@Autowired
privateHbaseTemplatehbaseTemplate;
publicListgetRowKeyAndColumn(StringtableName,StringstartRowkey,StringstopRowkey,Stringcolumn,Stringqualifier){
FilterListfilterList=newFilterList(FilterList.Operator.MUST_PASS_ALL);
if(StringUtils.isNotBlank(column)){
log.debug("{}",column);
filterList.addFilter(newFamilyFilter(CompareFilter.CompareOp.EQUAL,newBinaryComparator(Bytes.toBytes(column))));
}
if(StringUtils.isNotBlank(qualifier)){
log.debug("{}",qualifier);
filterList.addFilter(newQualifierFilter(CompareFilter.CompareOp.EQUAL,newBinaryComparator(Bytes.toBytes(qualifier))));
}
Scanscan=newScan();
if(filterList.getFilters().size()>0){
scan.setFilter(filterList);
}
scan.setStartRow(Bytes.toBytes(startRowkey));
scan.setStopRow(Bytes.toBytes(stopRowkey));
returnhbaseTemplate.find(tableName,scan,(rowMapper,rowNum)->rowMapper);
}
publicListgetListRowkeyData(StringtableName,ListrowKeys,StringfamilyColumn,Stringcolumn){
returnrowKeys.stream().map(rk->{
if(StringUtils.isNotBlank(familyColumn)){
if(StringUtils.isNotBlank(column)){
returnhbaseTemplate.get(tableName,rk,familyColumn,column,(rowMapper,rowNum)->rowMapper);
}else{
returnhbaseTemplate.get(tableName,rk,familyColumn,(rowMapper,rowNum)->rowMapper);
}
}
returnhbaseTemplate.get(tableName,rk,(rowMapper,rowNum)->rowMapper);
}).collect(Collectors.toList());
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。