我正在通过spark从hbase读取数据。当使用带有完整前缀的前缀过滤器读取数据时,代码运行良好 rowkey
或使用 GET
,但如果我使用部分前缀,它会冻结 rowkey
. 这个 rowkey
结构是 md5OfAkey_Akey_txDate_someKey
. 我要读取所有匹配的数据“ Akeys
“从Dataframe。这个表有一个单列族,50个列限定符,大约有2亿条记录。所以当我用 md5OfAkey_Akey_txDate
如果我构造整个键,代码就会被卡住,运行正常。但我不想通过整个考试 rowkey
因为我想读取特定帐户的所有数据( Akey
)和交易日期( txDate
). 任何帮助都将不胜感激。
暂无答案!
目前还没有任何答案,快来回答吧!