GoogleGoogle Professional Data Engineer (PDE) Certification
·TW
·更新於 21 Aug 2026
要將股票價格從 Pub/Sub 串流到 Dataflow,需要每 5 秒計算過去 30 秒的移動平均。您應該如何設定視窗和觸發器?
選擇一個答案
點擊一個選項來檢查您的答案。
正確答案: 使用持續時間為 30 秒、週期為 5 秒的滑動視窗,並使用 AfterWatermark.pastEndOfWindow() 發出結果。.
為什麼這是答案
正確答案是使用持續時間為 30 秒、週期為 5 秒的滑動視窗,並使用 AfterWatermark.pastEndOfWindow() 發出結果。這是因為題目要求每 5 秒計算過去 30 秒的移動平均。滑動視窗 (Sliding Window) 允許視窗重疊,非常適合計算移動平均。持續時間 (duration) 為 30 秒確保每個視窗包含 30 秒的資料,而週期 (period) 為 5 秒則表示每 5 秒產生一個新的視窗結果。AfterWatermark.pastEndOfWindow() 觸發器確保在所有預期資料到達後,每個視窗只會發出一次最終結果,這對於準確的移動平均計算至關重要。
其他選項不正確:
固定視窗 (Fixed Window) 不適用於移動平均,因為它會產生不重疊的視窗。
錯誤的觸發器設定 (例如 AfterProcessingTime) 可能導致結果不準確或重複發送。
通過考試 — 無需無休止地尋找答案
集中一處獲取此考試的所有核實題目和解釋,節省數小時的準備時間。1,000 多種認證 · 20 多種語言 · 免費開始。
更快通過您的考試 →
無需信用卡