You have an Azure Stream Analytics job that receives clickstream data from an Azure event hub.
You need to define a query in the Stream Analytics job. The query must meet the following requirements:
-> Count the number of clicks within each 10-second window based on the country of a visitor.
-> Ensure that each click is NOT counted more than once.
How should you define the query?
Click on the arrows to vote for the correct answer
A. B. C. D.A
Tumbling window functions are used to segment a data stream into distinct time segments and perform a function against them, such as the example below. The key differentiators of a Tumbling window are that they repeat, do not overlap, and an event cannot belong to more than one tumbling window.
Example:
Incorrect Answers:
B: Session windows group events that arrive at similar times, filtering out periods of time where there is no data.
C: Sliding windows, unlike Tumbling or Hopping windows, output events only for points in time when the content of the window actually changes. In other words, when an event enters or exits the window. Every window has at least one event, like in the case of Hopping windows, events can belong to more than one sliding window.
D: Hopping window functions hop forward in time by a fixed period. It may be easy to think of them as Tumbling windows that can overlap, so events can belong to more than one Hopping window result set. To make a Hopping window the same as a Tumbling window, specify the hop size to be the same as the window size.
https://docs.microsoft.com/en-us/azure/stream-analytics/stream-analytics-window-functionsThe correct answer is A.
Explanation: The query needs to count the number of clicks within each 10-second window based on the country of a visitor, while ensuring that each click is not counted more than once. The SELECT statement should include the Country field and a Count() function to count the number of clicks. The TIMESTAMP BY clause specifies the timestamp field in the input stream.
The GROUP BY clause groups the data by the Country field and a TumblingWindow function that defines a window of 10 seconds. The TumblingWindow function divides the input data into fixed-size, non-overlapping time intervals, and computes the results over each interval. This is suitable for the requirement to count clicks in 10-second windows.
Option B is incorrect because it uses a SessionWindow function, which groups the data into sessions based on a specified timeout and interval. This is not suitable for the requirement to count clicks in 10-second windows.
Option C is incorrect because it uses an Avg() function instead of a Count() function. Also, it uses a SlidingWindow function, which divides the input data into overlapping time intervals. This is not suitable for the requirement to count clicks in non-overlapping 10-second windows.
Option D is incorrect because it also uses an Avg() function instead of a Count() function. Additionally, it uses a HoppingWindow function, which divides the input data into overlapping time intervals with a specified hop size. This is not suitable for the requirement to count clicks in non-overlapping 10-second windows.