Table of Contents

• User Guide
  • Installing
  • Simple Example
  • Collecting and Windowing Example
  • Join Example
  • Wordcount Example
  • Polling Input Example
  • Recovery Example
  • Execution
  • Debugging
  • Workers and Parallelization
  • Dataflow Programming
  • Joins
  • Kafka
  • Windowing
  • Recovery
  • Pub/Sub and Polling
  • Rescaling
  • Custom Operators
  • Custom IO Connectors
  • Performance
  • Batching large-overhead operations
  • Deployment Overview
  • Containers
  • Using waxctl to Run your Dataflow on Kubernetes
  • Using waxctl to Run your Dataflow on AWS
  • Using waxctl to Run your Dataflow on GCP
  • Helm Chart
  • Metrics
  • Glossary
  • Migration Guide
  • Contribution Guide
  • Local Development
  • Architecture History
  • Profiling Bytewax
  • Library Release Checklist
  • Connector Hub
  • Writing Documentation

• Tutorials
  • Building Sessions from Search Logs
  • Handling Missing Values in Data Streams
  • Real-Time Financial Exchange Order Book
  • Recoverable Streaming Shopping Cart Application
  • Profiling Streaming Time Series Data

• API Reference
  • bytewax
    • bytewax.connectors
      • bytewax.connectors.demo
      • bytewax.connectors.files
      • bytewax.connectors.kafka
        • bytewax.connectors.kafka.operators
        • bytewax.connectors.kafka.serde
      • bytewax.connectors.stdio
    • bytewax.dataflow
    • bytewax.inputs
    • bytewax.operators
      • bytewax.operators.helpers
      • bytewax.operators.windowing
    • bytewax.outputs
    • bytewax.recovery
    • bytewax.run
    • bytewax.testing
    • bytewax.tracing
    • bytewax.visualize