大量のメッセージを並列処理する際、各スレッドの処理完了を待ってから次のアクションに進むために使用するコンポーネントはどれか。

DataWeaveにおいて、配列の要素を特定のキーでグループ化し、その結果をオブジェクトとして返す関数はどれか。