2013-04-18 163 views
1

當試圖運行對創建卡桑德拉模式一個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表。

有人能指出我正確的方向嗎?是否缺少一些文檔?

+0

更新的原始帖子 – e90jimmy

+0

這個JIRA問題是相關的:https://issues.apache.org/jira/browse/CASSANDRA-5234 – e90jimmy

回答

1

這現在支持在卡桑德拉1.2.8

0

正如e90jimmy說,它在卡桑德拉1.2.8支持,但我們使用計數器列類型時,有一個問題。這是固定由Alex劉但由於迴歸問題在1.2.7補丁不繼續:

https://issues.apache.org/jira/browse/CASSANDRA-5234

爲了解決這個問題,等到2.0成爲生產準備或下載源代碼,應用補丁從上面的鏈接中自行重建cassandra .jar。工作對我來說現在...

0

訪問豬Cql3表,最好的辦法是使用CqlStorage處理器

的語法類似於你有一個以上

row = Load 'cql://Keyspace/ColumnFamily/' Using CqlStorage() 

更多信息In the Dev Blog Post