Spark Structured Streaming で複数の集計を行いたいと考えています。
このようなもの：
- 入力ファイルのストリームを (フォルダーから) 読み取る
- 集計 1 を実行します (一部の変換あり)
- 集計 2 (およびその他の変換) を実行する
これを構造化ストリーミングで実行すると、「ストリーミング データフレーム/データセットでは複数のストリーミング アグリゲーションはサポートされていません」というエラーが表示されます。
構造化ストリーミングでこのような複数の集計を行う方法はありますか?