This is a dedicated watch page for a single video.
You are analyzing the stock price of EquiTrend Corp. using real-time data. Every 5 seconds , you need to calculate a moving average over the last 30 seconds of stock price data. The data is ingested from Pub/Sub , and you're using Dataflow to perform the analysis. How should you configure your Dataflow pipeline with appropriate windowing?