我正在研究 hadoop、pig 和 cassandra 的组合。我想使用 pig 从 cassandra 中获取特定的行。我正在尝试使用 grunt 从猪访问 cassandra。但是它返回所有行。不确定是否有办法从 cassandra 获取特定行
我有一张桌子:
create table home
{
id primary,
age int,
name String
};
共有三个记录 1, 10, Tom 2, 5, Harry 3, 20, James
我想使用 pig grunt 返回年龄>10 的数据(访问 cassandra 数据库)
例子 :
rows = LOAD 'cassandra://Keyspace1/home?page_size=5&where_clause=age+%3D+3&use_secondary=true' USING CassandraStorage();
有可能实现这一目标吗?我尝试了 cql,但它因猪咕噜声而失败。