Hadoop、豚、カサンドラの組み合わせに取り組んでいます。pig を使用して cassandra から特定の行をフェッチしたい。うなり声を使用して豚からカサンドラにアクセスしようとしています。ただし、すべての行を返します。カサンドラから特定の行を取得する方法があるかどうかわからない
私はテーブルを持っています:
create table home
{
id primary,
age int,
name String
};
1、10、トム 2、5、ハリー 3、20、ジェームズの 3 つのレコードがあります。
豚のうなり声を使用して年齢> 10のデータを返したい(cassandraデータベースにアクセス)
例 :
rows = LOAD 'cassandra://Keyspace1/home?page_size=5&where_clause=age+%3D+3&use_secondary=true' USING CassandraStorage();
これを達成することは可能ですか?私はcqlを試しましたが、豚のうなり声で失敗しました。