如何使用hbasetemplate“findallby{column}”？

iyr7buue 于 2021-05-31 发布在 Hadoop

关注(0)|答案(1)|浏览(470)

我一直在利用spring和hbase等技术开发我的第一台restful服务器。 Message 下面是我的服务器的核心模型；

@AllArgsConstructor
@Getter
public class Message {
    private final String from;
    private final String to;
    private final long when;
}

我的服务器应该在hbase中保存和查找邮件。
我已经研究并阅读了以下文档：https://docs.spring.io/spring-hadoop/docs/2.5.0.release/reference/html/springandhadoop-hbase.html#data-访问对象dao支持
然而，这还不够。本教程没有公开如何按特定列查找。
能否提供一个代码段，根据以下查询从hbase检索消息？

SELECT from, to, when FROM Message WHERE to = {userId} OR from = {userId}

Java hadoop hbase spring-data spring-data-hadoop

来源：https://stackoverflow.com/questions/54282215/how-to-findallbycolumn-with-hbasetemplate

1条答案

按热度按时间

fbcarpbf1#

下面给出了一个基于列的查询示例：

Scan scan = new Scan();
scan.addColumn(HbaseJsonEventSerializer.COLUMFAMILY_FILTERS_BYTES,
                Bytes.toBytes(columnName));
        Filter filter = new SingleColumnValueFilter(HbaseJsonEventSerializer.COLUMFAMILY_FILTERS_BYTES,
                Bytes.toBytes(columnName), CompareOp.EQUAL, Bytes.toBytes(columnValue));
        scan.setFilter(filter);
        List<String> rows  =
        hbaseTemplate.find("searchclicks", scan, new RowMapper<String>() {
            @Override
            public String mapRow(Result result, int rowNum) throws Exception {
                byte[] value = result.getValue(
                        HbaseJsonEventSerializer.COLUMFAMILY_FILTERS_BYTES,
                        Bytes.toBytes(columnName));
                if (value != null) {
                    String facetValue = new String(value);
                    LOG.debug("Facet field: {} and Facet Value: {}",
                            new Object[] { columnName, facetValue });
                }
                return facetValue;
            }
        });

有关更多示例，请参阅：
https://www.programcreek.com/java-api-examples/?code=jaibeermalik/searchanalytics-bigdata/searchanalytics bigdata master/src/main/java/org/jai/hbase/hbaserviceimpl.java

展开查看全部

赞(0）回复(0）举报 2021-06-01

我来回答

如何使用hbasetemplate“findallby{column}”？

1条答案

相关问题

热门标签

最新问答