ジュニアデータエンジニアの1人が、DataFrame dfを用いたグループ化された集計機能を備えたストリーミングデータパイプラインの開発を依頼されました。このパイプラインでは、重複しない5分間隔ごとに平均湿度と平均気温を計算する必要があります。イベントはデバイスごとに1分ごとに記録されます。
ストリーミング DataFrame df には次のスキーマがあります。
「device_id INT、event_time TIMESTAMP、temp FLOAT、humidity FLOAT」
コードブロック:
Certified-Data-Engineer-Professional試験の最新かつ実際の質問と回答を入手する
このタスクを完了するには、コード ブロック内の空白を正しく埋める応答を選択してください。
ストリーミング DataFrame df には次のスキーマがあります。
「device_id INT、event_time TIMESTAMP、temp FLOAT、humidity FLOAT」
コードブロック:
Certified-Data-Engineer-Professional試験の最新かつ実際の質問と回答を入手する
このタスクを完了するには、コード ブロック内の空白を正しく埋める応答を選択してください。
