当我运行hbase自定义过滤器时,我得到了以下错误:
org.apache.hadoop.hbase.client.RpcRetryingCaller@459c8c0a,org.apache.hadoop.hbase.protobuf.ProtobufUtil.toFilter(ProtobufUtil.java:1360) org.apache.hadoop.hbase.protobuf.ProtobufUtil.toScan(ProtobufUtil.java:916) at org.apache.hadoop.hbase.regionserver.HRegionServer.scan(
如何从HBase获取数据?我有一个包含empId、name、startDate、endDate和其他列的表。现在我想从一个HBase表中获取数据,这个表基于我可以使用的empId、startDate和endDate.In normal SQL:
select * from tableName where empId=val and date>=startDate and date<=endDate
我如何在HBase中做到这一点,因为它将数据存储为键值对?关键是empId。
我使用的是类似findAll() SQL的方法:
MyDomainClass.findAll("firstname='George' and lastname='kuo' and username='kjlop'"),
但我有问题:
当值以数字开头(例如,当age='2poj')时,它会抛出一个异常
我使用grails1.3.2和Gorm-HBASE0.2.4插件,在我的域类中,字段有String类型。
这是堆栈跟踪:在范围内期待令牌:'0'..'9',找到'p‘
at or
我正在尝试使用tomcat连接到HBASE,并遇到了以下错误。当我运行Hbase时,它的工作状态很好。
Caused by: java.lang.NoClassDefFoundError: org/apache/hadoop/hbase/filter/Filter
at java.lang.Class.getDeclaredFields0(Native Method)
at java.lang.Class.privateGetDeclaredFields(Class.java:2348)
at java.lang.Class.getDeclaredFields(Class.java:1779
问题
我有一个module-info.java文件,看起来如下:
module server {
...
// split package issue: lot of java classes within packages with the same name
requires hbase.common;
requires hbase.client;
...
}
变通办法1
maven-shader-plugin无法解决问题,因为它不知道groupId,只知道包名。这意味着着色器将从两个包重命名相同的包:hbase.common和hbase.client拆分
我一直在使用像Spring和HBase这样的技术来开发我的第一个RESTful服务器。
下面的Message是我服务器的核心模型;
@AllArgsConstructor
@Getter
public class Message {
private final String from;
private final String to;
private final long when;
}
我的服务器应该将消息保存并查找到HBase中。
我已经进行了研究,并阅读了以下文档:
然而,这还不够。本教程不公开如何通过特定列查找。
您能否提供基于以下查询从HBase检索消
我使用importtsv在Hbase中导入数据。
在我的tsv文件中,有些字段是空的。如何才能不在Hbase中导入?
例如,我在Hbase中有一个名为Test的表。我的tsv文件名为test.tsv,如下所示:
1 a b c d
2 q f s
当我这样做的时候:
hbase org.apache.hadoop.hbase.mapreduce.ImportTsv -Dimporttsv.columns=HBASE_ROW_KEY,I:c1,I:c2,I:c3,I:c4 Test test.tsv
我有以下结果:
1 column=I:c1, time
我得到的超时与错误似乎来自我的自定义过滤器。以下错误:
Caused by: org.apache.hadoop.hbase.exceptions.DeserializationException: parseFrom called on base Filter, but should be called on derived type
我看到在Hbase 0.98中不再支持写和readFields。目前,我的编写和readFields方法如下:
public MyCustomFilter(Schema first) {
this.schema = first;
filt
我想知道在RowKey扫描中HBase是否支持通配符。类似于:
select * from TABLE where KEY like '%SEARCH_KEY%';
我知道,如果我们对行键的前缀有一定的了解,我们就可以使用部分键扫描( HBase对这种扫描非常有效)。但是,如果我们没有信息前缀(这意味着搜索键可能在RowKey中的任何位置),那么Hbase必须运行全表扫描,对吗?
另外,如何在HBase中形成这样的查询(无论是代码还是通过shell)?
我要做的是为HBASE在PIG中创建嵌套数组。
基本上,我做了以下几点:
//Loading some address data
CITY = LOAD '/user/root/landingzone/ADRPCDCITY.csv' using PigStorage(';')
AS (dPOST_CODE:chararray, dCITY_CODE:chararray);
//Create the BAG by grouping postal code
B = GROUP CITY by dPOST_CODE;
//Store it in HBASE
STO