我们可以使用 Hadoop Cassandra 和 Pig 获取特定的行吗

Question

我正在研究 hadoop、pig 和 cassandra 的组合。我想使用 pig 从 cassandra 中获取特定的行。我正在尝试使用 grunt 从猪访问 cassandra。但是它返回所有行。不确定是否有办法从 cassandra 获取特定行

我有一张桌子：

create table home
{
   id primary,
   age int,
   name String
};

一共有三个记录 1, 10, 汤姆 2, 5, 哈利 3, 20, 詹姆斯

我想使用 pig grunt（访问 cassandra 数据库）返回年龄>10 的数据

例子：

rows = LOAD 'cassandra://Keyspace1/home?page_size=5&where_clause=age+%3D+3&use_secondary=true' USING CassandraStorage();

有可能实现吗？我尝试了 cql，但它因猪咕噜声而失败。

Answer 1

AFAIK 你只能在索引列上使用 where 子句。