count()
クエリ条件に一致する行数を返します。
たとえば、航空会社数を計算するには、次のステートメントを使用します。
1q = foreach q generate 'carrier' as 'carrier', count() as 'count';
count() は、group または cogroup ステートメントに入力されるストリームで実行されます。新しくグループ化されたストリームやグループ化されていないストリームでは実行されません。
1q = load "Carriers";
2q = group q by (Year);
3q = foreach a1 generate count(q) as countYear, count() as count, Year as year;