当尝试针对 CQL3 创建的 Cassandra Schema 运行 PIG 时,
-- This script simply gets a row count of the given column family
rows = LOAD 'cassandra://Keyspace1/ColumnFamily/' USING CassandraStorage();
counted = foreach (group rows all) generate COUNT($1);
dump counted;
我收到以下错误。
Error: Column family 'ColumnFamily' not found in keyspace 'KeySpace1'
我知道这是设计使然,但我一直无法找到将 CQL3 表加载到 PIG 中的正确方法。
有人可以指出我正确的方向吗?是否缺少一些文档?