We should add basic coverage of the below stages in TEST_F ExecutionPlan.
$addFields
$redact
$hoppingWindow
$sessionWindow
$count
See the customer-facing documentation for how these stages are configured
https://www.mongodb.com/docs/atlas/atlas-stream-processing/stream-aggregation/