свинья - как ссылаться на столбцы в FOREACH после JOIN?

A = load 'a.txt' as (id, a1);
B = load 'b.txt as (id, b1);
C = join A by id, B by id;
D = foreach C generate id,a1,b1;
dump D;

Ошибка 4-й строки: Недопустимая проекция поля. Спроецированное поле [id] не существует в схеме

. Я попытался изменить на A.id, но затем произошел сбой последней строки: ОШИБКА 0: Scalar содержит более одной строки на выходе.

20
задан ihadanny 9 November 2011 в 09:24
поделиться