count()

たとえば、航空会社数を計算するには、次のステートメントを使用します。

count() は、group または cogroup ステートメントに入力されるストリームで実行されます。新しくグループ化されたストリームやグループ化されていないストリームでは実行されません。