Examples

The Time-Centric Calculations example shows how to work with time and produce past training examples and recent results for applying models.

The Reddit example shows how to read and aggregate live messages from Reddit.

The Bluesky Firehose example shows how to read and aggregate messages from the Bluesky firehose. This demonstrates how to use Kaskada to connect in real-time and parse messages as part of the query.