Examples

Bytewax examples to help kick off your new project. You can find other examples in the Bytewax repo.
Recoverable Streaming Joins on Shopping Cart Data
Learn the basics of recovering stateful dataflows.
Building Sessions from Search Logs
A basic example of using Bytewax to turn an incoming stream of event logs from a hypothetical search engine into metrics over search sessions.
Analyzing the Coinbase Order Book in Real-Time
Connect to webhooks, and aggregate incoming events to maintain an order book in real-time.
Processing Events from Redpanda to Postgres
Process and analyze web events in real-time and write them to Postgres
Enriching Streaming Data from Kafka
Enriching streaming data inline with Bytewax.
Analyzing Sensor Data With Kafka and DynamoDB
Capturing event-time windows to DynamoDB