This is a dedicated watch page for a single video.
A data engineer has the following streaming query with a blank: spark . readStream . table ( "orders_cleaned" ) . groupBy ( ___________________________ , "author" ) . agg ( count ( "order_id" ). alias ( "orders_count" ), avg ( "quantity" ). alias ( "avg_quantity" )) . writeStream . option ( "checkpointLocation" , "dbfs:/path/checkpoint" ) . table ( "orders_stats" ) They want to calculate the orders count and average quantity for each non-overlapping 15-minute interval. Which option correctly fills in the blank to meet this requirement ?