ApachePig—我们可以使用HadoopCassandra和pig获取特定的行吗

dauxcl2d  于 2021-06-25  发布在  Pig
关注(0)|答案(1)|浏览(284)

我正在研究hadoop、pig和cassandra的组合。我想用pig从cassandra那里获取特定的行。我正试着用咕噜从Pig身上获取Cassandra。但是它返回所有行。不确定是否有办法从cassandra那里获得特定的行
我有一张table:

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,但是它失败了。

6qfn3psc

6qfn3psc1#

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

相关问题