This is not the latest version. View the latest documentation
Streaming SQL tutorials | Lenses.io Documentation
Lenses.io Help Center
Lenses.io Help Center
  • Documentation
5.5 (Latest) 5.4 5.3 5.2 5.1 5.0 4.3 4.2 4.1 4.0 3.2 3.1 3.0 2.3 2.2 2.1 2.0 1.1 1.0
  • Installation
    Overview Getting started Configuration Moving to production Configuration reference
  • Guides
    Overview Admin Data observibility Compliance Self service & governance Data applications & integration CLI
  • Lenses SQL
    Overview SQL Studio Streaming SQL SQL tutorials Expressions Functions Custom functions Deserializers Supported data formats
  • Connectors
    Overview Setup Sources Sinks Connect CLI Kafka Connect Secrets Release notes
  • APIs
  • Support
  • Releases
  1. Lenses SQL
  2. SQL tutorials
  3. Streaming SQL tutorials
  • SQL Studio
    • Snapshot SQL engine
      • Quick start
      • Insert and delete data
      • Manage running queries
      • Manage Kafka topics
      • Meta fields
      • Views and synonyms
      • Running queries
      • Tune your query
  • Streaming SQL
    • Prerequisites
    • Concepts
    • Projections
    • Joins
    • Lateral Joins
    • Aggregations
    • Time and windows
    • Set storage format
    • Nullability
    • Settings
  • SQL tutorials
    • Snapshot SQL tutorials
      • Query data in Kafka
      • How to view Kafka message headers?
    • Streaming SQL tutorials
      • Build streaming apps
      • Filtering data
      • Change data format
      • Change data shape
      • Enrich Streams
      • Join two Kafka streams
      • Aggregate Tables
      • Aggregate Streams
      • Control event time
      • Multiple topics
      • Re-key your data
      • Enrich credit card streaming data
      • Converting JSON to AVRO
      • Unwrapping complex values as primitives
      • Delete data from compacted topics
      • Work with arrays
      • Work with JSON strings
      • Join 3 Kafka topics
      • Update a SQL Processor
      • Automate SQL processors creation
      • Time window aggregations
      • Control AVRO record name and namespace
  • Expressions
  • Functions
  • Custom functions
    • User defined aggregation functions
    • User defined functions
  • Deserializers
  • Supported data formats
    • Kafka and Google Protobuf
    • Legacy protobuf support
  • SQL Studio
    • Snapshot SQL engine
      • Quick start
      • Insert and delete data
      • Manage running queries
      • Manage Kafka topics
      • Meta fields
      • Views and synonyms
      • Running queries
      • Tune your query
  • Streaming SQL
    • Prerequisites
    • Concepts
    • Projections
    • Joins
    • Lateral Joins
    • Aggregations
    • Time and windows
    • Set storage format
    • Nullability
    • Settings
  • SQL tutorials
    • Snapshot SQL tutorials
      • Query data in Kafka
      • How to view Kafka message headers?
    • Streaming SQL tutorials
      • Build streaming apps
      • Filtering data
      • Change data format
      • Change data shape
      • Enrich Streams
      • Join two Kafka streams
      • Aggregate Tables
      • Aggregate Streams
      • Control event time
      • Multiple topics
      • Re-key your data
      • Enrich credit card streaming data
      • Converting JSON to AVRO
      • Unwrapping complex values as primitives
      • Delete data from compacted topics
      • Work with arrays
      • Work with JSON strings
      • Join 3 Kafka topics
      • Update a SQL Processor
      • Automate SQL processors creation
      • Time window aggregations
      • Control AVRO record name and namespace
  • Expressions
  • Functions
  • Custom functions
    • User defined aggregation functions
    • User defined functions
  • Deserializers
  • Supported data formats
    • Kafka and Google Protobuf
    • Legacy protobuf support
  1. Lenses SQL
  2. SQL tutorials
  3. Streaming SQL tutorials

Streaming SQL tutorials



Contents:

Streaming SQL tutorials
Build streaming apps
Filtering data
Change data format
Change data shape
Enrich Streams
Join two Kafka streams
Aggregate Tables
Aggregate Streams
Control event time
Multiple topics
Re-key your data
Enrich credit card streaming data
Converting JSON to AVRO
Unwrapping complex values as primitives
Delete data from compacted topics
Work with arrays
Work with JSON strings
Join 3 Kafka topics
Update a SQL Processor
Automate SQL processors creation
Time window aggregations
Control AVRO record name and namespace

Feedback

Was this page helpful?

Awesome, thank you!

Sorry to hear that. Please tell us how we can improve!

2022 © Lenses.io Ltd. Policy Terms Cookies

Apache, Apache Kafka, Kafka, and associated open source project names are trademarks of the Apache Software Foundation.