Designing and creating windowed aggregates

In this section, let's explore the different windowed aggregates that are available in ASA. ASA supports the following five types of windows:

• Tumbling windows
• Hopping windows
• Sliding windows
• Session windows
• Snapshot windows

Let's look at each of them in detail. We will be using the following sample event schema in our examples.

eventSchema = StructType()
  .add("tripId", StringType())
  .add("createdAt", TimestampType())
  .add("startLocation", StringType())
  .add("endLocation", StringType())
  .add("distance", IntegerType())
  .add("fare", IntegerType())

Let us start with Tumbling windows.

Tumbling windows

Tumbling windows are non-overlapping time windows. All the windows are of the same size. Here is a depiction of how they look:

Figure 10.26 ...