Streaming Data Processing with Apache Kafka and KSQL

  1. Aggregations and Windowing
    1. Statefulness in ksqlDB
      1. Materialized Views
        1. Definition and Use Cases
          1. View Maintenance
          2. State Stores
            1. Local State Management
              1. Fault Tolerance for State
                1. State Store Types
              2. Aggregating Data
                1. The GROUP BY Clause
                  1. Syntax and Usage
                    1. Grouping Keys
                      1. Multiple Column Grouping
                      2. Aggregate Functions
                        1. COUNT
                          1. COUNT_DISTINCT
                            1. SUM
                              1. AVG
                                1. MIN
                                  1. MAX
                                    1. COLLECT_LIST
                                      1. COLLECT_SET
                                      2. The HAVING Clause
                                        1. Filtering Aggregated Results
                                          1. Post-Aggregation Conditions
                                        2. Windowing Concepts
                                          1. Purpose of Windowing
                                            1. Handling Unbounded Data
                                              1. Time-Based Aggregation
                                                1. Memory Management
                                                2. Types of Windows
                                                  1. Tumbling Windows
                                                    1. Fixed-Size Non-Overlapping
                                                      1. Use Cases
                                                      2. Hopping Windows
                                                        1. Fixed-Size Overlapping
                                                          1. Advance and Size Parameters
                                                          2. Session Windows
                                                            1. Dynamic Inactivity-Based
                                                              1. Session Gap Configuration
                                                            2. Grace Period for Late-Arriving Data
                                                              1. Handling Out-of-Order Events
                                                                1. Grace Period Configuration
                                                                2. Window Retention
                                                                  1. Window Cleanup
                                                                    1. Retention Policies

                                                                Previous

                                                                6. Querying and Transforming Data

                                                                Go to top

                                                                Next

                                                                8. Joining Streams and Tables