當試圖運行對創建卡桑德拉模式一個CQL3 PIG,使用豬與卡桑德拉CQL3
-- 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'
我明白,這是設計,但我一直無法找到正確的方法加載到PIG的CQL3表。
有人能指出我正確的方向嗎?是否缺少一些文檔?
更新的原始帖子 – e90jimmy
這個JIRA問題是相關的:https://issues.apache.org/jira/browse/CASSANDRA-5234 – e90jimmy