LogoLogo
HomeProductsDownload Community Edition
5.5
  • Lenses DevX
  • Kafka Connectors
5.5
  • Overview
  • Learn
  • What’s New?
  • Getting Started
    • Quick Start
    • Connecting Lenses to your environment
      • Prerequisites
      • Kafka
        • Apache Kafka
        • AWS MSK
        • AWS MSK Serverless
        • Aiven
        • Azure HDInsight
        • Confluent Cloud
        • Confluent Platform
        • IBM Event Streams
      • Adding a License
      • Kafka Connect
      • Schema Registries
        • AWS Glue
        • Confluent
        • Apicurio
        • IBM Event Streams Registry
      • Zookeeper
      • Alert & Audit Integrations
      • AWS
  • Deployment
    • Installation
      • Helm
      • Docker
      • Linux
      • AWS Marketplace
      • Lenses Box
      • Automating Connections
        • File Watcher Provisioning
        • API Provisioning
        • Provisioning examples
          • Kafka
          • Zookeeper
          • Schema Registry
          • Kafka Connect
          • Kerberos
          • JMX Metrics
        • Provisioning API reference
        • CLI Import & Export
    • Configuration
      • Identity & Access Management
        • Authentication
          • Admin Account
          • Azure AD
          • Basic Authentication
          • Custom Http
          • LDAP
          • SSO & SAML
            • Azure SSO
            • Google SSO
            • Keycloak SSO
            • Okta SSO
            • Onelogin SSO
            • FAQs
          • Kerberos
        • Groups
        • Users
        • Service accounts
        • Permission Reference
      • Lenses Metadata Database
      • Enable TLS on Lenses
      • Required Kafka ACLs
      • SQL Processor Deployment
      • Lenses JVM Options
      • Lenses JMX Metrics
      • Rate Limiting
      • Networking with Load Balancers
      • Logs
      • Plugins
      • Configuration Reference
  • User Guide
    • Topics
      • Finding topics & fields
      • Searching for messages
      • Inserting & deleting messages
      • Viewing topic metrics
      • Viewing topic partitions
      • Topic Settings
      • Adding metadata & tags to topics
      • Managing topic configurations
      • Approval requests
      • Downloading messages
      • Backup & Restore
    • Schemas
    • Connectors
      • Sources
      • Sinks
      • Secret Providers
    • Monitoring & Alerting
      • Infrastructure Health
      • Alerting
        • Alert Reference
      • Integrations
      • Consumer Groups
    • Self Service & Governance
      • Data policies
      • Audits
      • Kafka ACLs
      • Kafka Quotas
    • Lenses SQL
      • SQL Studio
        • Concepts
        • Best practices
        • Creating & deleting Kafka topics
        • Filtering
        • Limit & Sampling
        • Joins
        • Inserting & deleting data
        • Aggregations
        • Metadata fields
        • Views & synonyms
        • Arrays
        • Managing queries
      • SQL Processors
        • Concepts
        • Projections
        • Joins
        • Lateral Joins
        • Aggregations
        • Time & Windows
        • Storage format
        • Nullibility
        • Settings
      • SQL Reference
        • Expressions
        • Functions
          • Aggregate
            • AVG
            • BOTTOMK
            • COLLECT
            • COLLECT_UNIQUE
            • COUNT
            • FIRST
            • LAST
            • MAXK
            • MAXK_UNIQUE
            • MINK
            • MINK_UNIQUE
            • SUM
            • TOPK
          • Array
            • ELEMENT_OF
            • FLATTEN
            • IN_ARRAY
            • REPEAT
            • SIZEOF
            • ZIP_ALL
            • ZIP
          • Conditions
          • Conversion
          • Date & Time
            • CONVERT_DATETIME
            • DATE
            • DATETIME
            • EXTRACT_TIME
            • EXTRACT_DATE
            • FORMAT_DATE
            • FORMAT_TIME
            • FORMAT_TIMESTAMP
            • HOUR
            • MONTH_TEXT
            • MINUTE
            • MONTH
            • PARSE_DATE
            • PARSE_TIME_MILLIS
            • PARSE_TIME_MICROS
            • PARSE_TIMESTAMP_MILLIS
            • PARSE_TIMESTAMP_MICROS
            • SECOND
            • TIMESTAMP
            • TIME_MICROS
            • TIMESTAMP_MICROS
            • TIME_MILLIS
            • TIMESTAMP_MILLIS
            • TO_DATE
            • TO_DATETIME
            • TOMORROW
            • TO_TIMESTAMP
            • YEAR
            • YESTERDAY
          • Headers
            • HEADERASSTRING
            • HEADERASINT
            • HEADERASLONG
            • HEADERASDOUBLE
            • HEADERASFLOAT
            • HEADERKEYS
          • JSON
            • JSON_EXTRACT_FIRST
            • JSON_EXTRACT_ALL
          • Numeric
            • ABS
            • ACOS
            • ASIN
            • ATAN
            • CBRT
            • CEIL
            • COSH
            • COS
            • DEGREES
            • DISTANCE
            • FLOOR
            • MAX
            • MIN
            • MOD
            • NEG
            • POW
            • RADIANS
            • RANDINT
            • ROUND
            • SIGN
            • SINH
            • SIN
            • SQRT
            • TANH
            • TAN
          • Nulls
            • ISNULL
            • ISNOTNULL
            • COALESCE
            • AS_NULLABLE
            • AS_NON_NULLABLE
          • Obfuscation
            • ANONYMIZE
            • MASK
            • EMAIL
            • FIRST1
            • FIRST2
            • FIRST3
            • FIRST4
            • LAST1
            • LAST2
            • LAST3
            • LAST4
            • INITIALS
          • Offsets
          • Schema
            • TYPEOF
            • DUMP
          • String
            • ABBREVIATE
            • BASE64
            • CAPITALIZE
            • CENTER
            • CHOP
            • CONCAT
            • CONTAINS
            • DECODE64
            • DELETEWHITESPACE
            • DIGITS
            • DROPLEFT
            • DROPRIGHT
            • ENDSWITH
            • INDEXOF
            • LEN
            • LOWER
            • LPAD
            • MKSTRING
            • REGEXP
            • REGEX_MATCHES
            • REPLACE
            • REVERSE
            • RPAD
            • STARTSWITH
            • STRIPACCENTS
            • SUBSTR
            • SWAPCASE
            • TAKELEFT
            • TAKERIGHT
            • TRIM
            • TRUNCATE
            • UNCAPITALIZE
            • UPPER
            • UUID
          • User Defined Functions
          • User Defined Aggregate Functions
        • Deserializers
        • Supported data formats
          • Protobuf
    • Topology
      • Registering via SDK
      • Registring via REST
    • License
    • CLI
      • Data
        • Datasets
        • Data Policies
        • Elasticsearch
        • Kafka topics
        • Querying data
      • Admin
        • Alerts
        • Alert Channels
        • Audit Channels
        • Connections
        • Groups
        • Schemas
        • Service Accounts
        • License
        • Users
      • Applications
        • Kafka Connectors
        • SQL Processors
      • Manage Kafka
        • ACLs
        • Consumers
        • Quotas
      • Golang client
  • Resources
    • Support & Community
    • Tutorials
      • SQL Studio
        • Querying data
        • Accessing headers
        • Deleting data from compacted topics
        • Working with JSON
      • SQL Processors
        • Data formats
          • Changing data formats
          • Rekeying data
          • Controlling AVRO record names and namespaces
          • Changing the shape of data
        • Filtering & Joins
          • Filtering data
          • Enriching data streams
          • Joining streams of data
          • Using multiple topics
        • Aggregations
          • Aggregating data in a table
          • Aggregating streams
          • Time window aggregations
        • Complex types
          • Unwrapping complex types
          • Working with Arrays
        • Controlling event time
    • Downloads
    • API Reference
      • Authentication API
      • Lenses API Spec
      • Websocket Spec
      • Provisioning API Spec
Powered by GitBook
On this page

Was this helpful?

Export as PDF
  1. Resources
  2. Tutorials
  3. SQL Processors

Aggregations

Aggregating data in a tableAggregating streamsTime window aggregations
PreviousUsing multiple topicsNextAggregating data in a table

Last updated 8 months ago

Was this helpful?

LogoLogo

Resources

  • Privacy
  • Cookies
  • Terms & Conditions
  • Community EULA

2024 © Lenses.io Ltd. Apache, Apache Kafka, Kafka and associated open source project names are trademarks of the Apache Software Foundation.

This site uses cookies to deliver its service and to analyze traffic. By browsing this site, you accept the privacy policy.