Я запускаю сценарий pig (0.9.1) из Java в локальном режиме, который получает записи от Cassandra (1.0.6). Сценарий:
rows = LOAD 'cassandra://Keyspace/Data' USING CassandraStorage() AS (key, columns: bag {T: tuple(name, value)});
cols = FOREACH rows GENERATE flatten(columns);
colnames = FOREACH cols GENERATE $0;
namegroups = GROUP colnames BY (chararray) $0;
namecounts = FOREACH namegroups GENERATE COUNT($1), group;
orderednames = ORDER namecounts BY $0;
topnames = LIMIT orderednames 50;
dump topnames;
Всякий раз, когда я пытаюсь запустить скрипт, я получаю:
org.apache.pig.impl.logicalLayer.FrontendException: Error during parsing. can't look backwards more than one token in this stream
Интересно, что когда я запускаю скрипт PIG, который просто читает и записывает файловую систему (без Cassandra), он работает нормально. Я использую файл CassandraStorage, который поставляется с Cassandra.
Есть идеи? Спасибо.