Confluent Confluent
Documentation Flink SQL Keywords in Confluent Cloud for Apache Flink
Confluent Developer Marketplace Get started
Home Confluent Cloud Confluent Platform Connectors Clients
Flink SQL Keywords in Confluent Cloud for Apache Flink
Get started
    Home Confluent Cloud Confluent Platform Connectors Clients

    CLOUD

    • Overview
    • Get Started
      • Overview
      • Free Trial
      • Quick Start: Confluent Cloud
      • Quick Start: REST API
      • Manage Schemas
      • Tutorials and Examples
        • Overview
        • Tutorial: Use Replicator to Copy Kafka Data to Cloud
        • Example: Create Fully Managed Services
      • Use Docs with AI Tools
    • Regions and Availability
      • Overview
    • Use Kafka Clusters
      • Overview
      • Resilience
      • Cluster Deletion Protection
      • Multi-Tenancy and Client Quotas
        • Overview
        • Quick Start
      • Manage Clusters
        • Create a Cluster
        • View Clusters
        • Update a Cluster
        • Delete a Cluster
        • Resize a Dedicated Cluster
        • Manage Configuration Settings
      • Migrate Clusters
        • Migrate to Confluent Cloud
        • Migrate with kcp
      • Copy and Share Data
        • Cluster Linking
          • Overview
          • Quick Start
          • Configure, Manage, and Monitor
            • Configure and Manage Cluster Links
            • Manage Mirror Topics
            • Manage Private Networking
            • Manage Security
            • Monitor Metrics
          • Use Cases and Tutorials
            • Share Data Across Clusters, Regions, and Clouds
            • Disaster Recovery and Failover
            • Create Hybrid Cloud and Bridge-to-Cloud Deployments
            • Use Tiered Separation of Critical Workloads
            • Migrate Data
            • Manage Audit Logs
          • Troubleshooting
        • Replicator
          • Quick Start
          • Use Replicator to Migrate Topics
      • Connect Confluent Platform and Cloud Environments
        • Overview
        • Connect Self-Managed Gateway to Cloud
          • Confluent Cloud Gateway Overview
          • Configure and Deploy
            • Overview
            • Configure and Deploy using Docker
            • Configure and Deploy using CFK
            • Configure Security using Docker
            • Configure Security using CFK
          • Enforce Centralized Governance
            • Overview
            • Configure Centralized Governance
          • Migrate Kafka Clusters
          • Set up Network Isolation and Custom Domains
        • Connect Self-Managed Control Center to Cloud
        • Connect Self-Managed Clients to Cloud
        • Connect Self-Managed Connect to Cloud
        • Connect Self-Managed REST Proxy to Cloud
        • Connect Self-Managed ksqlDB to Cloud
        • Connect Self-Managed MQTT to Cloud
        • Connect Self-Managed Schema Registry to Cloud
        • Connect Self-Managed Streams to Cloud
        • Example: Autogenerate Self-Managed Component Configs for Cloud
      • Automate with Infrastructure as Code
        • Create Clusters with Terraform
        • Terraform Security Best Practices
        • Create Clusters with Pulumi
      • FAQ
    • Build Streaming Applications
      • Overview
      • Architectural Considerations
      • Client Quick Start
      • Configure Clients
        • Consumer
        • Share Consumers
        • Producer
        • Configuration Properties
      • Test and Monitor a Client
        • Test
        • Monitor
          • Overview
          • Monitoring with JMX
          • Configure JMX
          • Producer Metrics
          • Consumer Metrics
          • Share Consumer Metrics
        • Reset Offsets
      • Optimize and Tune
        • Overview
        • Throughput
        • Latency
        • Durability
        • Availability
        • Freight
      • Client Guides
        • Python
        • .NET Client
        • JavaScript Client
        • Go Client
        • C++ Client
        • Java Client
      • Kafka Client APIs for Confluent Cloud
        • Python Client API
        • .NET Client API
        • JavaScript Client API
        • Go Client API
        • C++ Client API
        • Java Client API
      • Deprecated Client APIs
      • Client Examples
        • Overview
        • Python Client
        • .NET Client
        • JavaScript Client
        • Go Client
        • C++ Client
        • Java
        • Spring Boot
        • KafkaProducer
        • REST
        • Clojure
        • Groovy
        • Kafka Connect Datagen
        • kafkacat
        • Kotlin
        • Ruby
        • Rust
        • Scala
      • Confluent Plugin for JetBrains IDEs
      • VS Code Extension
    • Build Kafka Streams Applications
      • Overview
      • Quick Start
      • Metrics
      • Monitor Applications
      • Upgrade Guide
      • ksqlDB
        • Create Stream Processing Apps with ksqlDB
        • Quick Start
        • Enable ksqlDB Integration with Schema Registry
        • ksqlDB Cluster API Quick Start
        • Monitor ksqlDB
        • Manage ksqlDB by using the CLI
        • Manage Connectors With ksqlDB
        • Develop ksqlDB Applications
        • Pull Queries
        • Grant Role-Based Access
        • Migrate ksqlDB Applications on Confluent Cloud
    • AI and ML
      • Overview
      • Build AI with Confluent Intelligence
        • Overview
        • Streaming Agents
          • Overview
          • Agent Runtime Guide
          • Call Tools
          • Create and Run Streaming Agents
          • Manage Agents in the Console
          • Reflection Workflows
          • Monitor Streaming Agents
          • Debug Streaming Agents
          • Examples
        • Real-Time Context Engine
          • Overview
          • Get Started
          • Manage
          • Query Data
          • Lightning Queries
          • Billing
          • Manage Access
          • Support and Limitations
        • Built-in AI/ML Functions
          • Overview
          • Analyze Sentiment
          • Detect Anomalies
          • Detect PII
          • Forecast Trends
          • Invoke a Tool in an AI Workflow
          • ML Preprocessing Functions
          • Model Inference Functions
        • Create Embeddings
          • Overview
          • Create Embeddings
        • Run a Managed AI Model
        • Run a Remote AI Model
        • Search External Tables
          • Overview
          • Key Search with External Sources
          • Text Search with External Sources
          • Vector Search with External Sources
        • FAQ
      • Use AI Tools with Confluent
        • Overview
        • Access Confluent Cloud with the Managed MCP Servers
        • Build with the Open-Source MCP Server
        • Build with Agent Skills
    • Manage Topics
      • Overview
      • Configuration Reference
      • Message Browser
      • Share Streams
        • Overview
        • Provide Stream Shares
        • Consume Stream Shares
      • Tableflow
        • Overview
        • Concepts
          • Overview
          • Storage
          • Schemas
          • Materialize Change Data Capture Streams
          • Billing
          • Write Modes
        • Get Started
          • Overview
          • Quick Start with Managed Storage
          • Quick Start Using Your Storage and AWS Glue
          • Quick Start with Delta Lake Tables
        • How-to Guides
          • Overview
          • Configure Storage
          • Encrypt Sensitive Fields
          • Integrate Catalogs
            • Overview
            • Integrate with AWS Glue Catalog
            • Integrate with Snowflake Open Catalog or Apache Polaris
            • Integrate with Unity Catalog
            • User-defined namespaces
          • Query Data
            • Overview
            • Query with AWS
            • Query with DuckDB
            • Query with Flink
            • Query with Snowflake
            • Query with Trino
        • Operate
          • Overview
          • Configure
          • Grant Role-Based Access
          • Monitor
          • Use Private Networking
          • Use Private Networking with Azure
          • Supported Cloud Regions
      • Real-Time Context Engine
      • FAQ
    • Manage and Monitor Resources with USM
      • Overview
      • Register Confluent Platform with USM
        • Overview
        • Set Up Payment Method
        • Configure Private Networking
        • Configure a Service Account
        • Deploy the USM Agent
        • Complete the Cluster Registration
      • Register Confluent Platform Connect Cluster with USM
      • Monitor Confluent Platform Resources
        • Overview
        • Clusters
        • Topics
        • Connectors
        • Consumer Lag
        • Clients
        • Kafka Streams
        • Alerts
      • Data Governance for Confluent Platform
      • Remove the USM Agent
      • Troubleshoot
    • Govern Data Streams
      • Overview
      • Stream Governance
        • Manage Governance Packages
        • Data Portal
        • Track Data with Stream Lineage
        • Manage Stream Catalog
          • Stream Catalog User Guide
          • REST API Catalog Usage and Examples Guide
          • GraphQL API Catalog Usage and Examples Guide
      • Manage Schemas
        • Overview
        • Manage Schemas
        • Delete Schemas and Manage Storage
        • Use Broker-Side Schema ID Validation
        • Schema Linking
        • Schema Registry Tutorial
      • Fundamentals
        • Key Concepts
        • Schema Evolution and Compatibility
        • Schema Formats
          • Serializers and Deserializers Overview
          • Avro
          • Protobuf
          • JSON Schema
        • Data Contracts
        • Security Considerations
        • Enable Private Networking
          • Enable Private Networking with Schema Registry PrivateLink
          • Enable Private Networking for Schema Registry with a Public Endpoint
      • Reference
        • Overview
        • Configure Clients
        • Schema Registry C++ Client (libschemaregistry)
        • Maven Plugin
        • REST API Usage Examples
        • Use AsyncAPI to Describe Topics and Schemas
      • FAQ
    • Connect to External Services
      • Overview
      • Install Connectors
        • ActiveMQ Source
        • AlloyDB Sink
        • Amazon CloudWatch Logs Source
        • Amazon CloudWatch Metrics Sink
        • Amazon DocumentDB Sink
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
        • Amazon DynamoDB CDC Source
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
        • Amazon DynamoDB Sink
        • Amazon Kinesis Source
        • Amazon Redshift Sink
        • Amazon S3 Sink
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
        • Amazon S3 Source
        • Amazon SQS Source
        • AWS Lambda Sink
        • Azure Blob Storage Sink
          • Configure and Launch
          • Configure with Azure Egress Private Link Endpoints
        • Azure Blob Storage Source
        • Azure Cognitive Search Sink
        • Azure Cosmos DB Sink [Deprecated]
        • Azure Cosmos DB Sink V2
        • Azure Cosmos DB Source [Deprecated]
        • Azure Cosmos DB Source V2
        • Azure Data Lake Storage Gen2 Sink
        • Azure Event Hubs Source
        • Azure Functions Sink
        • Azure Log Analytics Sink
        • Azure Log Analytics Sink V2
        • Azure Service Bus Source
        • Azure Synapse Analytics Sink
        • ClickHouse Sink
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Azure Egress Private Link Endpoints
          • Configure with Google Cloud Private Service Connect Endpoints
        • Couchbase Source
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Azure Egress Private Link Endpoints
          • Configure with GCP Egress Private Service Connect Endpoints
        • Couchbase Sink
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Azure Egress Private Link Endpoints
          • Configure with GCP Egress Private Service Connect Endpoints
        • Databricks Delta Lake Sink
          • Set up Databricks Delta Lake (AWS) Sink Connector for Confluent Cloud
          • Configure and launch the connector
        • Datadog Metrics Sink
        • Datagen Source (development and testing)
        • Elasticsearch Service Sink [Deprecated]
        • Elasticsearch Service Sink V2
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Google Cloud Private Service Connect Endpoints
          • Configure with Azure Egress Private Link Endpoints
        • GitHub Source
        • Google BigQuery Sink [End of Life]
        • Google BigQuery Sink V2
        • Google Cloud BigTable Sink
        • Google Cloud Dataproc Sink [End of Life]
        • Google Cloud Firestore Sink
        • Google Cloud Functions Gen 2 Sink
        • Google Cloud Functions Sink [End of Life]
        • Google Cloud Pub/Sub Source
        • Google Cloud Spanner CDC Source (Debezium)
        • Google Cloud Spanner Sink
        • Google Cloud Storage Sink
        • Google Cloud Storage Source
        • HTTP Sink
        • HTTP Sink V2
        • HTTP Source
        • HTTP Source V2
        • IBM Db2 Source (JDBC)
        • IBM MQ Sink
        • IBM MQ Source
        • InfluxDB 2 Sink
        • InfluxDB 2 Source
        • InfluxDB 3 Sink
        • Jira Source
        • MariaDB CDC Source (Debezium)
        • Microsoft SQL Server CDC Source (Debezium) [End of Life]
        • Microsoft SQL Server CDC Source V2 (Debezium)
          • Configure and launch the connector
          • Backward incompatibility considerations
        • Microsoft SQL Server Sink (JDBC)
        • Microsoft SQL Server Source (JDBC)
        • MongoDB Atlas Sink
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Azure Egress Private Link Endpoints
          • Configure with Google Cloud Egress Private Service Connect Endpoints
        • MongoDB Atlas Source
        • MongoDB CDC Source (Debezium)
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Azure Egress Private Link Endpoints
          • Configure with Google Cloud Egress Private Service Connect Endpoints
        • MQTT Sink
        • MQTT Source
        • MySQL CDC Source (Debezium) [End of Life]
        • MySQL CDC Source V2 (Debezium)
          • Configure and Launch the connector
          • Backward Incompatible Changes
        • MySQL Sink (JDBC)
        • MySQL Source (JDBC)
        • Neo4j Sink
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Google Cloud Private Service Connect Endpoints
        • New Relic Metrics Sink
        • OpenSearch Sink
        • Oracle XStream CDC Source
          • Overview
          • Configure and Launch the connector
          • Oracle Database Prerequisites
          • Downstream Capture
          • Cascading Downstream Capture
          • Change Events
          • Signals and Actions
          • Examples
          • Troubleshooting
          • Monitoring
        • Oracle CDC Source
          • Overview
          • Configure and Launch the connector
          • Horizontal Scaling
          • Oracle Database Prerequisites
          • SMT Examples
          • DDL Changes
          • Troubleshooting
        • Oracle Database Sink (JDBC)
        • Oracle Database Source (JDBC)
        • PagerDuty Sink [End of Life]
        • Pinecone Sink
        • PostgreSQL CDC Source (Debezium) [End of Life]
        • PostgreSQL CDC Source V2 (Debezium)
          • Configure and Launch the connector
          • Backward Incompatible Changes
        • PostgreSQL Sink (JDBC)
        • PostgreSQL Source (JDBC)
        • RabbitMQ Sink
        • RabbitMQ Source
        • Redis Sink [Deprecated]
        • Redis Kafka Sink
        • Redis Kafka Source
        • Salesforce Bulk API 2.0 Sink
        • Salesforce Bulk API 2.0 Source
        • Salesforce Bulk API Source
        • Salesforce CDC Source
        • Salesforce Platform Event Sink
        • Salesforce Platform Event Source
        • Salesforce PushTopic Source
        • Salesforce SObject Sink
        • Salesforce Source V2
        • ServiceNow Sink
        • ServiceNow Source (Legacy) [Deprecated]
        • ServiceNow Source V2
        • SFTP Sink
        • SFTP Source
        • Snowflake Sink
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Azure Egress Private Link Endpoints
          • Configure with Google Cloud Private Service Connect Endpoints
        • Snowflake Source
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Azure Egress Private Link Endpoints
          • Configure with Google Cloud Private Service Connect Endpoints
        • Solace Sink
        • Solace Source
        • Splunk Sink
        • Zendesk Source
      • Confluent Marketplace
        • Overview
        • Component Archive Specification
        • Contribute
      • Install Custom Plugins and Custom Connectors
        • Overview
        • Quick Start
        • Manage Custom Connectors
        • Limitations and Support
        • API and CLI
      • Manage Client-Side Encryption
      • Manage Provider Integration
      • Secret Manager Integration
        • Overview
        • Azure Key Vault Integration
        • AWS Secrets Manager Integration
        • Google Cloud Secret Manager Integration
      • Networking and DNS
        • Overview
        • AWS Egress PrivateLink Endpoints for First-Party Services
        • AWS Egress PrivateLink Endpoints for Self-Managed Services
        • AWS Egress PrivateLink Endpoints for Amazon RDS
        • AWS Egress PrivateLink Endpoints for Amazon DocumentDB
        • Azure Egress Private Link Endpoints for First-Party Services
        • Azure Egress Private Link Endpoints for Self-Managed Services
        • Google Cloud Private Service Connect Endpoints for First-Party Services
        • Google Cloud Private Service Connect Endpoints for Self-Managed Services
      • Connect API Usage
      • Manage Public Egress IP Addresses
      • Sample Connector Output
      • Configure Single Message Transformations
      • Configure Custom SMTs
        • Quick Start
        • Manage Custom SMT APIs
        • Limitations and Support
      • View Connector Events
      • Interpret Connector Statuses
      • Manage Service Accounts
      • Configure RBAC
      • View Errors in the Dead Letter Queue
      • Connector Limits
      • Manage Offsets
      • Migrate Self-Managed Connectors
      • Transforms List
        • Overview
        • AdjustPrecisionAndScale
        • BytesToString
        • Cast
        • ChangeTopicCase
        • Drop
        • DropHeaders
        • EventRouter
        • ExtractField
        • ExtractNestedField
        • ExtractTimeStamp
        • ExtractTopic
        • Filter (Kafka)
        • Filter (Confluent)
        • Flatten (Kafka)
        • Flatten (Confluent)
        • HeaderFrom
        • HeaderToValue
        • HoistField
        • InsertField
        • InsertHeader
        • KeyToValue
        • MaskField
        • MessageTimestampRouter
        • ReplaceField (Kafka)
        • ReplaceField (Confluent)
        • SetMaximumPrecision
        • SetSchemaMetadata
        • TimestampConverter
        • TimestampNow
        • TimestampNowField
        • TimestampRouter
        • TimescaleDB
        • TimezoneConverter
        • TombstoneHandler
        • TopicRegexRouter
        • ValueToKey
      • Reference
        • Additional Connector Configuration
        • Confluent AI-Assisted Troubleshooting
    • Integrate with Confluent Cloud
      • Overview
      • Connect with Confluent Program
      • Reuse Connections with External Services
        • Overview
        • Supported External Services
        • Manage Connections
      • Integrate with Cloud Service Providers
        • Overview
        • Create an AWS Provider Integration
        • Create an Azure Provider Integration
        • Create a Google Cloud Provider Integration
        • Manage a Provider Integration
    • Process Data with Flink
      • Overview
      • Get Started
        • Overview
        • Quick Start with Cloud Console
        • Quick Start with SQL Shell in Confluent CLI
        • Quick Start with Java Table API
        • Quick Start with Python Table API
      • Concepts
        • Overview
        • Autopilot
        • Batch and Stream Processing
        • Billing
        • Comparison with Apache Flink
        • Compute Pools
        • Delivery Guarantees and Latency
        • Determinism
        • External Tables
        • Materialized Tables
        • Private Networking
        • Process Table Functions
        • Schema and Statement Evolution
        • Security Controls
        • Snapshot Queries
        • Statements
        • Statement CFU Metrics
        • Tables and Topics
        • Time and Watermarks
        • User-defined Functions
      • How-To Guides
        • Overview
        • Aggregate a Stream in a Tumbling Window
        • Combine Streams and Track Most Recent Records
        • Compare Current and Previous Values in a Stream
        • Configure a Dead Letter Queue
        • Convert the Serialization Format of a Topic
        • Create a Process Table Function
        • Create a UDF
        • Deduplicate Rows in a Table
        • Deploy a Statement with CI/CD
        • Evolve a Streaming Pipeline
        • Generate Custom Sample Data
        • Handle Late-Arriving Data
        • Handle Multiple Event Types
        • Log Debug Messages in UDFs
        • Mask Fields in a Table
        • Read and Write Custom Changelog Formats
        • Read Records without a Schema ID Prefix
        • Profile a Query
        • Resolve Statement Issues
        • Scan and Summarize Tables
        • Run a Snapshot Query
        • Set a Baseline CFU for a Statement
        • Transform a Topic
        • Use Client-Side Field Level Encryption
        • View Time Series Data
      • Operate and Deploy
        • Overview
        • Carry-over Offsets
        • Deploy with dbt
        • Deploy Table API Programs
        • Development Lifecycle
        • Enable Private Networking
        • Generate a Flink API Key
        • Grant Role-Based Access
        • Manage Compute Pools
        • Manage Connections
        • Manage with Terraform
        • Monitor and Manage Statements
        • Move SQL Statements to Production
        • Use the Query Profiler
        • REST API
      • Flink Reference
        • Overview
        • SQL Syntax
        • DDL Statements
          • Statements Overview
          • ALTER AGENT
          • ALTER CONNECTION
          • ALTER MODEL
          • ALTER MATERIALIZED TABLE
          • ALTER TABLE
          • ALTER TOOL
          • ALTER VIEW
          • CREATE AGENT
          • CREATE CONNECTION
          • CREATE FUNCTION
          • CREATE MATERIALIZED TABLE
          • CREATE MODEL
          • CREATE OR ALTER MATERIALIZED TABLE
          • CREATE TABLE
          • CREATE TOOL
          • CREATE VIEW
          • DESCRIBE
          • DROP AGENT
          • DROP CONNECTION
          • DROP FUNCTION
          • DROP MATERIALIZED TABLE
          • DROP MODEL
          • DROP TABLE
          • DROP TOOL
          • DROP VIEW
          • HINTS
          • EXPLAIN
          • RESET
          • SET
          • SHOW
          • USE CATALOG
          • USE database_name
        • DML Statements
          • Queries Overview
          • Deduplication
          • Group Aggregation
          • INSERT INTO FROM SELECT
          • INSERT VALUES
          • Joins
          • LIMIT
          • Pattern Recognition
          • ORDER BY
          • OVER Aggregation
          • SELECT
          • Set Logic
          • EXECUTE STATEMENT SET
          • Top-N
          • Window Aggregation
          • Window Deduplication
          • Window Join
          • Window Top-N
          • Window Table-Valued Function
          • WITH
        • Functions
          • AI Model Inference
          • Aggregate
          • Changelog Conversion
          • Collections
          • Comparison
          • Conditional
          • Datetime
          • Flink SQL Functions
          • Hashing
          • JSON
          • ML Preprocessing
          • Numeric
          • Search
          • String
          • Table API
        • Data Types
        • Data Type Mappings
        • Time Zone
        • Keywords
        • Information Schema
        • Example Streams
        • SQL Examples
        • Table API
        • CLI Reference
      • Get Help
      • FAQ
    • Manage Networking
      • Confluent Cloud Networking Overview
      • Networking on AWS
        • AWS Networking Overview
        • Public Networking on AWS
        • Confluent Cloud Network on AWS
        • PrivateLink on AWS
          • PrivateLink Overview
          • Inbound PrivateLink for Dedicated Clusters
          • Inbound PrivateLink for Serverless Products
          • Outbound PrivateLink for Dedicated Clusters
          • Outbound PrivateLink for Serverless Products
        • VPC Peering on AWS
        • Transit Gateway on AWS
        • Private Network Interface on AWS
        • DNS Forwarding on AWS
      • Networking on Azure
        • Azure Networking Overview
        • Public Networking on Azure
        • Confluent Cloud Network on Azure
        • Private Link on Azure
          • Private Link Overview
          • Inbound Private Link for Dedicated Clusters
          • Inbound Private Link for Serverless Products
          • Outbound Private Link for Dedicated Clusters
          • Outbound Private Link for Serverless Products
        • VNet Peering on Azure
      • Networking on Google Cloud
        • Google Cloud Networking Overview
        • Public Networking on Google Cloud
        • Confluent Cloud Network on Google Cloud
        • Private Service Connect on Google Cloud
          • Private Service Connect Overview
          • Inbound Private Service Connect for Dedicated Clusters
          • Inbound Private Service Connect for Serverless Products
          • Outbound Private Service Connect for Dedicated Clusters
        • VPC Peering on Google Cloud
      • Connectivity for Confluent Resources
        • Overview
        • Public Egress IP Address for Connectors and Cluster Linking
        • Cluster Linking using AWS PrivateLink
        • Follower Fetching using AWS VPC Peering
      • Use the Confluent Cloud Console with Private Networking
      • Test Connectivity
      • Networking FAQ
    • Log and Monitor
      • Metrics
      • Integrate Third-Party Monitoring Tools
      • Manage Notifications
      • Monitor Consumer Lag
      • Monitor Dedicated Clusters
        • Manage Performance and Expansion
        • Track Usage by Team
      • Export Logs to Third-Party Tools
      • Tutorials and Examples
        • Run Example Queries
        • Observability for Kafka Clients
      • FAQ
    • Manage Security
      • Overview
      • Manage Authentication
        • Overview
        • Manage User Identities
          • Overview
          • Manage User Accounts
            • Overview
            • Authentication Security Protections
            • Manage Local User Accounts
            • Multi-factor Authentication
            • Manage SSO User Accounts
          • Manage User Identity Providers
            • Overview
            • Use Single Sign-On (SSO)
            • Manage SAML Single Sign-On (SSO)
            • Manage Azure Marketplace SSO
            • Just-in-time User Provisioning
            • Group Mapping
              • Overview
              • Enable Group Mapping
              • Manage Group Mappings
              • Troubleshooting
              • Best Practices
            • Manage Trusted Domains
            • Manage SSO provider
            • Troubleshoot SSO
        • Manage Workload Identities
          • Overview
          • Manage Workload Identities
          • Manage Service Accounts and API Keys
            • Overview
            • Create Service Accounts
            • Manage Service Accounts
            • Manage API Keys
              • Overview
              • Manage API keys
              • Best Practices
              • Troubleshoot
          • Manage OAuth/OIDC Identity Providers
            • Overview
            • Add an OIDC Identity Provider
            • Use OAuth Identity Pools and Filters
            • Manage Identity Provider Configurations
            • Manage the JWKS URI
            • Configure OAuth Clients
              • Overview
              • Go Clients
              • Java Clients
              • JavaScript Clients
              • .NET Clients
              • Python Clients
              • Configuration Reference
              • Configure UAMI
              • Configure AWS IAM Java Client Plugin
              • Configure AWS IAM Python Client Plugin
              • Configure AWS IAM .NET Client Plugin
            • Access Kafka REST APIs
            • Use Confluent STS Tokens with REST APIs
            • Best Practices
            • Troubleshoot OAuth Issues
          • Manage mTLS Identity Providers
            • Overview
            • Configure mTLS
            • Manage Certificate Authorities
            • Manage Certificate Identity Pools
            • Create CEL Filters for mTLS
            • Create JSON payloads for mTLS
            • Manage Certificate Revocation
            • Troubleshoot mTLS Issues
      • Control Access
        • Overview
        • Resource Hierarchy
          • Overview
          • Organizations
            • Overview
            • Manage Multiple Organizations
          • Environments
          • Confluent Resource Names (CRNs)
        • Manage Role-Based Access Control
          • Overview
          • Predefined RBAC Roles
          • Manage Role Bindings
          • Use ACLs with RBAC
        • Manage IP Filtering
          • Overview
          • Manage IP Groups
          • Manage IP Filters
          • Best Practices
        • Manage Access Control Lists
          • Overview
          • Operations
          • Examples
          • Troubleshoot
          • Reference
        • Use the Confluent CLI with multiple credentials on Confluent Cloud
      • Encrypt and Protect Data
        • Overview
        • Manage Data in Transit With TLS
        • Use Self-Managed Encryption Keys
          • Overview
          • Use Self-Managed Encryption Keys on AWS
          • Use Self-Managed Encryption Keys on Azure
          • Use Self-Managed Encryption Keys on Google Cloud
          • Use Self-Managed Encryption Keys with Tableflow
          • Use Confluent CLI for Self-Managed Encryption Keys
          • Use BYOK API for Self-Managed Encryption Keys
          • Revoke Access to Data at Rest
          • Best Practices
          • Troubleshoot Key Policy Issues
        • Use Client-Side Field Level Encryption
          • Overview
          • Manage CSFLE using Confluent Cloud Console
          • Use Client-side Field Level Encryption
          • Configuration Settings
          • Manage Encryption Keys
          • Manage Multiple Encryption Rules
          • Quick Start
          • Implement a Custom KMS Driver
          • Process Encrypted Data with Apache Flink
          • Code examples
          • Troubleshoot
          • FAQ
        • Use Client-Side Payload Encryption
      • Monitor Activity
        • Concepts
        • Audit Log Event Categories
        • Audit Log Event Records
        • Audit Log Event Schema
        • Auditable Event Methods
          • Access Transparency
          • Connector
          • Custom Connector Plugin
          • Endpoints
          • Flink Management and Operations
          • Flink Authentication and Authorization
          • IP Filter Authorization
          • Kafka Cluster Management and Operations
          • Kafka Cluster Authentication and Authorization
          • ksqlDB Cluster Authentication and Authorization
          • Networking
          • Notifications Service
          • OAuth-OIDC Identity Provider and Identity Pool
          • Organization
          • Role-Based Access Control
          • Real-Time Context Engine
          • Schema Registry Management and Operations
          • Schema Registry Authentication and Authorization
          • Tableflow Control Plane
          • Tableflow Data Plane
          • Unified Stream Manager Control Plane
        • Access and Consume Audit Logs
        • Access Transparency
        • Retain Audit Logs
        • Best Practices
        • Troubleshoot
      • Access Management Tutorial
    • Manage Billing
      • Overview
      • Billing Dimensions
      • Invoices and Costs
      • Cost Allocation
      • Amazon Web Services
        • Pay As You Go
        • Commitments
      • Google Cloud
        • Pay as you Go
        • Commitments
        • Professional Services
      • Microsoft Azure
        • Pay As You Go
        • Commitments
        • Jio Commitments
        • Professional Services
      • Marketplace Organization Suspension and Deactivation
      • Troubleshoot Billing
      • FAQ
      • Legacy Billing Reference
    • Manage Service Quotas
      • Overview
      • Service Quotas
      • View Service Quotas Using Confluent CLI
      • Service Quotas API
    • APIs
      • Overview
      • Confluent Cloud API Usage and Reference
        • Overview
        • Confluent Cloud API Reference
        • Metrics API Reference
        • Admin and Produce REST API Usage
        • Connect API Usage
        • Provider Integration API Usage
        • Stream Catalog REST API Usage
        • Service Quotas API Usage
      • Kafka Client API Reference
        • Overview
        • .NET Client API Reference
        • C++ Client API Reference
        • Go Client API Reference
        • Java Client API Reference
        • JavaScript Client API Reference
        • Python Client API Reference
      • Flink Client API Usage and Reference
      • GraphQL API Usage and Reference
    • Confluent CLI
    • Release Notes & FAQ
      • Release Notes
      • FAQ
      • Upgrade Policy
      • Compliance
      • Generate a HAR file for Troubleshooting
      • AI Assistant
    • Support
    • Glossary
    Table of contents

    CLOUD

    • Overview
    • Get Started
      • Overview
      • Free Trial
      • Quick Start: Confluent Cloud
      • Quick Start: REST API
      • Manage Schemas
      • Tutorials and Examples
        • Overview
        • Tutorial: Use Replicator to Copy Kafka Data to Cloud
        • Example: Create Fully Managed Services
      • Use Docs with AI Tools
    • Regions and Availability
      • Overview
    • Use Kafka Clusters
      • Overview
      • Resilience
      • Cluster Deletion Protection
      • Multi-Tenancy and Client Quotas
        • Overview
        • Quick Start
      • Manage Clusters
        • Create a Cluster
        • View Clusters
        • Update a Cluster
        • Delete a Cluster
        • Resize a Dedicated Cluster
        • Manage Configuration Settings
      • Migrate Clusters
        • Migrate to Confluent Cloud
        • Migrate with kcp
      • Copy and Share Data
        • Cluster Linking
          • Overview
          • Quick Start
          • Configure, Manage, and Monitor
            • Configure and Manage Cluster Links
            • Manage Mirror Topics
            • Manage Private Networking
            • Manage Security
            • Monitor Metrics
          • Use Cases and Tutorials
            • Share Data Across Clusters, Regions, and Clouds
            • Disaster Recovery and Failover
            • Create Hybrid Cloud and Bridge-to-Cloud Deployments
            • Use Tiered Separation of Critical Workloads
            • Migrate Data
            • Manage Audit Logs
          • Troubleshooting
        • Replicator
          • Quick Start
          • Use Replicator to Migrate Topics
      • Connect Confluent Platform and Cloud Environments
        • Overview
        • Connect Self-Managed Gateway to Cloud
          • Confluent Cloud Gateway Overview
          • Configure and Deploy
            • Overview
            • Configure and Deploy using Docker
            • Configure and Deploy using CFK
            • Configure Security using Docker
            • Configure Security using CFK
          • Enforce Centralized Governance
            • Overview
            • Configure Centralized Governance
          • Migrate Kafka Clusters
          • Set up Network Isolation and Custom Domains
        • Connect Self-Managed Control Center to Cloud
        • Connect Self-Managed Clients to Cloud
        • Connect Self-Managed Connect to Cloud
        • Connect Self-Managed REST Proxy to Cloud
        • Connect Self-Managed ksqlDB to Cloud
        • Connect Self-Managed MQTT to Cloud
        • Connect Self-Managed Schema Registry to Cloud
        • Connect Self-Managed Streams to Cloud
        • Example: Autogenerate Self-Managed Component Configs for Cloud
      • Automate with Infrastructure as Code
        • Create Clusters with Terraform
        • Terraform Security Best Practices
        • Create Clusters with Pulumi
      • FAQ
    • Build Streaming Applications
      • Overview
      • Architectural Considerations
      • Client Quick Start
      • Configure Clients
        • Consumer
        • Share Consumers
        • Producer
        • Configuration Properties
      • Test and Monitor a Client
        • Test
        • Monitor
          • Overview
          • Monitoring with JMX
          • Configure JMX
          • Producer Metrics
          • Consumer Metrics
          • Share Consumer Metrics
        • Reset Offsets
      • Optimize and Tune
        • Overview
        • Throughput
        • Latency
        • Durability
        • Availability
        • Freight
      • Client Guides
        • Python
        • .NET Client
        • JavaScript Client
        • Go Client
        • C++ Client
        • Java Client
      • Kafka Client APIs for Confluent Cloud
        • Python Client API
        • .NET Client API
        • JavaScript Client API
        • Go Client API
        • C++ Client API
        • Java Client API
      • Deprecated Client APIs
      • Client Examples
        • Overview
        • Python Client
        • .NET Client
        • JavaScript Client
        • Go Client
        • C++ Client
        • Java
        • Spring Boot
        • KafkaProducer
        • REST
        • Clojure
        • Groovy
        • Kafka Connect Datagen
        • kafkacat
        • Kotlin
        • Ruby
        • Rust
        • Scala
      • Confluent Plugin for JetBrains IDEs
      • VS Code Extension
    • Build Kafka Streams Applications
      • Overview
      • Quick Start
      • Metrics
      • Monitor Applications
      • Upgrade Guide
      • ksqlDB
        • Create Stream Processing Apps with ksqlDB
        • Quick Start
        • Enable ksqlDB Integration with Schema Registry
        • ksqlDB Cluster API Quick Start
        • Monitor ksqlDB
        • Manage ksqlDB by using the CLI
        • Manage Connectors With ksqlDB
        • Develop ksqlDB Applications
        • Pull Queries
        • Grant Role-Based Access
        • Migrate ksqlDB Applications on Confluent Cloud
    • AI and ML
      • Overview
      • Build AI with Confluent Intelligence
        • Overview
        • Streaming Agents
          • Overview
          • Agent Runtime Guide
          • Call Tools
          • Create and Run Streaming Agents
          • Manage Agents in the Console
          • Reflection Workflows
          • Monitor Streaming Agents
          • Debug Streaming Agents
          • Examples
        • Real-Time Context Engine
          • Overview
          • Get Started
          • Manage
          • Query Data
          • Lightning Queries
          • Billing
          • Manage Access
          • Support and Limitations
        • Built-in AI/ML Functions
          • Overview
          • Analyze Sentiment
          • Detect Anomalies
          • Detect PII
          • Forecast Trends
          • Invoke a Tool in an AI Workflow
          • ML Preprocessing Functions
          • Model Inference Functions
        • Create Embeddings
          • Overview
          • Create Embeddings
        • Run a Managed AI Model
        • Run a Remote AI Model
        • Search External Tables
          • Overview
          • Key Search with External Sources
          • Text Search with External Sources
          • Vector Search with External Sources
        • FAQ
      • Use AI Tools with Confluent
        • Overview
        • Access Confluent Cloud with the Managed MCP Servers
        • Build with the Open-Source MCP Server
        • Build with Agent Skills
    • Manage Topics
      • Overview
      • Configuration Reference
      • Message Browser
      • Share Streams
        • Overview
        • Provide Stream Shares
        • Consume Stream Shares
      • Tableflow
        • Overview
        • Concepts
          • Overview
          • Storage
          • Schemas
          • Materialize Change Data Capture Streams
          • Billing
          • Write Modes
        • Get Started
          • Overview
          • Quick Start with Managed Storage
          • Quick Start Using Your Storage and AWS Glue
          • Quick Start with Delta Lake Tables
        • How-to Guides
          • Overview
          • Configure Storage
          • Encrypt Sensitive Fields
          • Integrate Catalogs
            • Overview
            • Integrate with AWS Glue Catalog
            • Integrate with Snowflake Open Catalog or Apache Polaris
            • Integrate with Unity Catalog
            • User-defined namespaces
          • Query Data
            • Overview
            • Query with AWS
            • Query with DuckDB
            • Query with Flink
            • Query with Snowflake
            • Query with Trino
        • Operate
          • Overview
          • Configure
          • Grant Role-Based Access
          • Monitor
          • Use Private Networking
          • Use Private Networking with Azure
          • Supported Cloud Regions
      • Real-Time Context Engine
      • FAQ
    • Manage and Monitor Resources with USM
      • Overview
      • Register Confluent Platform with USM
        • Overview
        • Set Up Payment Method
        • Configure Private Networking
        • Configure a Service Account
        • Deploy the USM Agent
        • Complete the Cluster Registration
      • Register Confluent Platform Connect Cluster with USM
      • Monitor Confluent Platform Resources
        • Overview
        • Clusters
        • Topics
        • Connectors
        • Consumer Lag
        • Clients
        • Kafka Streams
        • Alerts
      • Data Governance for Confluent Platform
      • Remove the USM Agent
      • Troubleshoot
    • Govern Data Streams
      • Overview
      • Stream Governance
        • Manage Governance Packages
        • Data Portal
        • Track Data with Stream Lineage
        • Manage Stream Catalog
          • Stream Catalog User Guide
          • REST API Catalog Usage and Examples Guide
          • GraphQL API Catalog Usage and Examples Guide
      • Manage Schemas
        • Overview
        • Manage Schemas
        • Delete Schemas and Manage Storage
        • Use Broker-Side Schema ID Validation
        • Schema Linking
        • Schema Registry Tutorial
      • Fundamentals
        • Key Concepts
        • Schema Evolution and Compatibility
        • Schema Formats
          • Serializers and Deserializers Overview
          • Avro
          • Protobuf
          • JSON Schema
        • Data Contracts
        • Security Considerations
        • Enable Private Networking
          • Enable Private Networking with Schema Registry PrivateLink
          • Enable Private Networking for Schema Registry with a Public Endpoint
      • Reference
        • Overview
        • Configure Clients
        • Schema Registry C++ Client (libschemaregistry)
        • Maven Plugin
        • REST API Usage Examples
        • Use AsyncAPI to Describe Topics and Schemas
      • FAQ
    • Connect to External Services
      • Overview
      • Install Connectors
        • ActiveMQ Source
        • AlloyDB Sink
        • Amazon CloudWatch Logs Source
        • Amazon CloudWatch Metrics Sink
        • Amazon DocumentDB Sink
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
        • Amazon DynamoDB CDC Source
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
        • Amazon DynamoDB Sink
        • Amazon Kinesis Source
        • Amazon Redshift Sink
        • Amazon S3 Sink
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
        • Amazon S3 Source
        • Amazon SQS Source
        • AWS Lambda Sink
        • Azure Blob Storage Sink
          • Configure and Launch
          • Configure with Azure Egress Private Link Endpoints
        • Azure Blob Storage Source
        • Azure Cognitive Search Sink
        • Azure Cosmos DB Sink [Deprecated]
        • Azure Cosmos DB Sink V2
        • Azure Cosmos DB Source [Deprecated]
        • Azure Cosmos DB Source V2
        • Azure Data Lake Storage Gen2 Sink
        • Azure Event Hubs Source
        • Azure Functions Sink
        • Azure Log Analytics Sink
        • Azure Log Analytics Sink V2
        • Azure Service Bus Source
        • Azure Synapse Analytics Sink
        • ClickHouse Sink
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Azure Egress Private Link Endpoints
          • Configure with Google Cloud Private Service Connect Endpoints
        • Couchbase Source
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Azure Egress Private Link Endpoints
          • Configure with GCP Egress Private Service Connect Endpoints
        • Couchbase Sink
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Azure Egress Private Link Endpoints
          • Configure with GCP Egress Private Service Connect Endpoints
        • Databricks Delta Lake Sink
          • Set up Databricks Delta Lake (AWS) Sink Connector for Confluent Cloud
          • Configure and launch the connector
        • Datadog Metrics Sink
        • Datagen Source (development and testing)
        • Elasticsearch Service Sink [Deprecated]
        • Elasticsearch Service Sink V2
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Google Cloud Private Service Connect Endpoints
          • Configure with Azure Egress Private Link Endpoints
        • GitHub Source
        • Google BigQuery Sink [End of Life]
        • Google BigQuery Sink V2
        • Google Cloud BigTable Sink
        • Google Cloud Dataproc Sink [End of Life]
        • Google Cloud Firestore Sink
        • Google Cloud Functions Gen 2 Sink
        • Google Cloud Functions Sink [End of Life]
        • Google Cloud Pub/Sub Source
        • Google Cloud Spanner CDC Source (Debezium)
        • Google Cloud Spanner Sink
        • Google Cloud Storage Sink
        • Google Cloud Storage Source
        • HTTP Sink
        • HTTP Sink V2
        • HTTP Source
        • HTTP Source V2
        • IBM Db2 Source (JDBC)
        • IBM MQ Sink
        • IBM MQ Source
        • InfluxDB 2 Sink
        • InfluxDB 2 Source
        • InfluxDB 3 Sink
        • Jira Source
        • MariaDB CDC Source (Debezium)
        • Microsoft SQL Server CDC Source (Debezium) [End of Life]
        • Microsoft SQL Server CDC Source V2 (Debezium)
          • Configure and launch the connector
          • Backward incompatibility considerations
        • Microsoft SQL Server Sink (JDBC)
        • Microsoft SQL Server Source (JDBC)
        • MongoDB Atlas Sink
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Azure Egress Private Link Endpoints
          • Configure with Google Cloud Egress Private Service Connect Endpoints
        • MongoDB Atlas Source
        • MongoDB CDC Source (Debezium)
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Azure Egress Private Link Endpoints
          • Configure with Google Cloud Egress Private Service Connect Endpoints
        • MQTT Sink
        • MQTT Source
        • MySQL CDC Source (Debezium) [End of Life]
        • MySQL CDC Source V2 (Debezium)
          • Configure and Launch the connector
          • Backward Incompatible Changes
        • MySQL Sink (JDBC)
        • MySQL Source (JDBC)
        • Neo4j Sink
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Google Cloud Private Service Connect Endpoints
        • New Relic Metrics Sink
        • OpenSearch Sink
        • Oracle XStream CDC Source
          • Overview
          • Configure and Launch the connector
          • Oracle Database Prerequisites
          • Downstream Capture
          • Cascading Downstream Capture
          • Change Events
          • Signals and Actions
          • Examples
          • Troubleshooting
          • Monitoring
        • Oracle CDC Source
          • Overview
          • Configure and Launch the connector
          • Horizontal Scaling
          • Oracle Database Prerequisites
          • SMT Examples
          • DDL Changes
          • Troubleshooting
        • Oracle Database Sink (JDBC)
        • Oracle Database Source (JDBC)
        • PagerDuty Sink [End of Life]
        • Pinecone Sink
        • PostgreSQL CDC Source (Debezium) [End of Life]
        • PostgreSQL CDC Source V2 (Debezium)
          • Configure and Launch the connector
          • Backward Incompatible Changes
        • PostgreSQL Sink (JDBC)
        • PostgreSQL Source (JDBC)
        • RabbitMQ Sink
        • RabbitMQ Source
        • Redis Sink [Deprecated]
        • Redis Kafka Sink
        • Redis Kafka Source
        • Salesforce Bulk API 2.0 Sink
        • Salesforce Bulk API 2.0 Source
        • Salesforce Bulk API Source
        • Salesforce CDC Source
        • Salesforce Platform Event Sink
        • Salesforce Platform Event Source
        • Salesforce PushTopic Source
        • Salesforce SObject Sink
        • Salesforce Source V2
        • ServiceNow Sink
        • ServiceNow Source (Legacy) [Deprecated]
        • ServiceNow Source V2
        • SFTP Sink
        • SFTP Source
        • Snowflake Sink
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Azure Egress Private Link Endpoints
          • Configure with Google Cloud Private Service Connect Endpoints
        • Snowflake Source
          • Configure and Launch
          • Configure with AWS Egress PrivateLink Endpoints
          • Configure with Azure Egress Private Link Endpoints
          • Configure with Google Cloud Private Service Connect Endpoints
        • Solace Sink
        • Solace Source
        • Splunk Sink
        • Zendesk Source
      • Confluent Marketplace
        • Overview
        • Component Archive Specification
        • Contribute
      • Install Custom Plugins and Custom Connectors
        • Overview
        • Quick Start
        • Manage Custom Connectors
        • Limitations and Support
        • API and CLI
      • Manage Client-Side Encryption
      • Manage Provider Integration
      • Secret Manager Integration
        • Overview
        • Azure Key Vault Integration
        • AWS Secrets Manager Integration
        • Google Cloud Secret Manager Integration
      • Networking and DNS
        • Overview
        • AWS Egress PrivateLink Endpoints for First-Party Services
        • AWS Egress PrivateLink Endpoints for Self-Managed Services
        • AWS Egress PrivateLink Endpoints for Amazon RDS
        • AWS Egress PrivateLink Endpoints for Amazon DocumentDB
        • Azure Egress Private Link Endpoints for First-Party Services
        • Azure Egress Private Link Endpoints for Self-Managed Services
        • Google Cloud Private Service Connect Endpoints for First-Party Services
        • Google Cloud Private Service Connect Endpoints for Self-Managed Services
      • Connect API Usage
      • Manage Public Egress IP Addresses
      • Sample Connector Output
      • Configure Single Message Transformations
      • Configure Custom SMTs
        • Quick Start
        • Manage Custom SMT APIs
        • Limitations and Support
      • View Connector Events
      • Interpret Connector Statuses
      • Manage Service Accounts
      • Configure RBAC
      • View Errors in the Dead Letter Queue
      • Connector Limits
      • Manage Offsets
      • Migrate Self-Managed Connectors
      • Transforms List
        • Overview
        • AdjustPrecisionAndScale
        • BytesToString
        • Cast
        • ChangeTopicCase
        • Drop
        • DropHeaders
        • EventRouter
        • ExtractField
        • ExtractNestedField
        • ExtractTimeStamp
        • ExtractTopic
        • Filter (Kafka)
        • Filter (Confluent)
        • Flatten (Kafka)
        • Flatten (Confluent)
        • HeaderFrom
        • HeaderToValue
        • HoistField
        • InsertField
        • InsertHeader
        • KeyToValue
        • MaskField
        • MessageTimestampRouter
        • ReplaceField (Kafka)
        • ReplaceField (Confluent)
        • SetMaximumPrecision
        • SetSchemaMetadata
        • TimestampConverter
        • TimestampNow
        • TimestampNowField
        • TimestampRouter
        • TimescaleDB
        • TimezoneConverter
        • TombstoneHandler
        • TopicRegexRouter
        • ValueToKey
      • Reference
        • Additional Connector Configuration
        • Confluent AI-Assisted Troubleshooting
    • Integrate with Confluent Cloud
      • Overview
      • Connect with Confluent Program
      • Reuse Connections with External Services
        • Overview
        • Supported External Services
        • Manage Connections
      • Integrate with Cloud Service Providers
        • Overview
        • Create an AWS Provider Integration
        • Create an Azure Provider Integration
        • Create a Google Cloud Provider Integration
        • Manage a Provider Integration
    • Process Data with Flink
      • Overview
      • Get Started
        • Overview
        • Quick Start with Cloud Console
        • Quick Start with SQL Shell in Confluent CLI
        • Quick Start with Java Table API
        • Quick Start with Python Table API
      • Concepts
        • Overview
        • Autopilot
        • Batch and Stream Processing
        • Billing
        • Comparison with Apache Flink
        • Compute Pools
        • Delivery Guarantees and Latency
        • Determinism
        • External Tables
        • Materialized Tables
        • Private Networking
        • Process Table Functions
        • Schema and Statement Evolution
        • Security Controls
        • Snapshot Queries
        • Statements
        • Statement CFU Metrics
        • Tables and Topics
        • Time and Watermarks
        • User-defined Functions
      • How-To Guides
        • Overview
        • Aggregate a Stream in a Tumbling Window
        • Combine Streams and Track Most Recent Records
        • Compare Current and Previous Values in a Stream
        • Configure a Dead Letter Queue
        • Convert the Serialization Format of a Topic
        • Create a Process Table Function
        • Create a UDF
        • Deduplicate Rows in a Table
        • Deploy a Statement with CI/CD
        • Evolve a Streaming Pipeline
        • Generate Custom Sample Data
        • Handle Late-Arriving Data
        • Handle Multiple Event Types
        • Log Debug Messages in UDFs
        • Mask Fields in a Table
        • Read and Write Custom Changelog Formats
        • Read Records without a Schema ID Prefix
        • Profile a Query
        • Resolve Statement Issues
        • Scan and Summarize Tables
        • Run a Snapshot Query
        • Set a Baseline CFU for a Statement
        • Transform a Topic
        • Use Client-Side Field Level Encryption
        • View Time Series Data
      • Operate and Deploy
        • Overview
        • Carry-over Offsets
        • Deploy with dbt
        • Deploy Table API Programs
        • Development Lifecycle
        • Enable Private Networking
        • Generate a Flink API Key
        • Grant Role-Based Access
        • Manage Compute Pools
        • Manage Connections
        • Manage with Terraform
        • Monitor and Manage Statements
        • Move SQL Statements to Production
        • Use the Query Profiler
        • REST API
      • Flink Reference
        • Overview
        • SQL Syntax
        • DDL Statements
          • Statements Overview
          • ALTER AGENT
          • ALTER CONNECTION
          • ALTER MODEL
          • ALTER MATERIALIZED TABLE
          • ALTER TABLE
          • ALTER TOOL
          • ALTER VIEW
          • CREATE AGENT
          • CREATE CONNECTION
          • CREATE FUNCTION
          • CREATE MATERIALIZED TABLE
          • CREATE MODEL
          • CREATE OR ALTER MATERIALIZED TABLE
          • CREATE TABLE
          • CREATE TOOL
          • CREATE VIEW
          • DESCRIBE
          • DROP AGENT
          • DROP CONNECTION
          • DROP FUNCTION
          • DROP MATERIALIZED TABLE
          • DROP MODEL
          • DROP TABLE
          • DROP TOOL
          • DROP VIEW
          • HINTS
          • EXPLAIN
          • RESET
          • SET
          • SHOW
          • USE CATALOG
          • USE database_name
        • DML Statements
          • Queries Overview
          • Deduplication
          • Group Aggregation
          • INSERT INTO FROM SELECT
          • INSERT VALUES
          • Joins
          • LIMIT
          • Pattern Recognition
          • ORDER BY
          • OVER Aggregation
          • SELECT
          • Set Logic
          • EXECUTE STATEMENT SET
          • Top-N
          • Window Aggregation
          • Window Deduplication
          • Window Join
          • Window Top-N
          • Window Table-Valued Function
          • WITH
        • Functions
          • AI Model Inference
          • Aggregate
          • Changelog Conversion
          • Collections
          • Comparison
          • Conditional
          • Datetime
          • Flink SQL Functions
          • Hashing
          • JSON
          • ML Preprocessing
          • Numeric
          • Search
          • String
          • Table API
        • Data Types
        • Data Type Mappings
        • Time Zone
        • Keywords
        • Information Schema
        • Example Streams
        • SQL Examples
        • Table API
        • CLI Reference
      • Get Help
      • FAQ
    • Manage Networking
      • Confluent Cloud Networking Overview
      • Networking on AWS
        • AWS Networking Overview
        • Public Networking on AWS
        • Confluent Cloud Network on AWS
        • PrivateLink on AWS
          • PrivateLink Overview
          • Inbound PrivateLink for Dedicated Clusters
          • Inbound PrivateLink for Serverless Products
          • Outbound PrivateLink for Dedicated Clusters
          • Outbound PrivateLink for Serverless Products
        • VPC Peering on AWS
        • Transit Gateway on AWS
        • Private Network Interface on AWS
        • DNS Forwarding on AWS
      • Networking on Azure
        • Azure Networking Overview
        • Public Networking on Azure
        • Confluent Cloud Network on Azure
        • Private Link on Azure
          • Private Link Overview
          • Inbound Private Link for Dedicated Clusters
          • Inbound Private Link for Serverless Products
          • Outbound Private Link for Dedicated Clusters
          • Outbound Private Link for Serverless Products
        • VNet Peering on Azure
      • Networking on Google Cloud
        • Google Cloud Networking Overview
        • Public Networking on Google Cloud
        • Confluent Cloud Network on Google Cloud
        • Private Service Connect on Google Cloud
          • Private Service Connect Overview
          • Inbound Private Service Connect for Dedicated Clusters
          • Inbound Private Service Connect for Serverless Products
          • Outbound Private Service Connect for Dedicated Clusters
        • VPC Peering on Google Cloud
      • Connectivity for Confluent Resources
        • Overview
        • Public Egress IP Address for Connectors and Cluster Linking
        • Cluster Linking using AWS PrivateLink
        • Follower Fetching using AWS VPC Peering
      • Use the Confluent Cloud Console with Private Networking
      • Test Connectivity
      • Networking FAQ
    • Log and Monitor
      • Metrics
      • Integrate Third-Party Monitoring Tools
      • Manage Notifications
      • Monitor Consumer Lag
      • Monitor Dedicated Clusters
        • Manage Performance and Expansion
        • Track Usage by Team
      • Export Logs to Third-Party Tools
      • Tutorials and Examples
        • Run Example Queries
        • Observability for Kafka Clients
      • FAQ
    • Manage Security
      • Overview
      • Manage Authentication
        • Overview
        • Manage User Identities
          • Overview
          • Manage User Accounts
            • Overview
            • Authentication Security Protections
            • Manage Local User Accounts
            • Multi-factor Authentication
            • Manage SSO User Accounts
          • Manage User Identity Providers
            • Overview
            • Use Single Sign-On (SSO)
            • Manage SAML Single Sign-On (SSO)
            • Manage Azure Marketplace SSO
            • Just-in-time User Provisioning
            • Group Mapping
              • Overview
              • Enable Group Mapping
              • Manage Group Mappings
              • Troubleshooting
              • Best Practices
            • Manage Trusted Domains
            • Manage SSO provider
            • Troubleshoot SSO
        • Manage Workload Identities
          • Overview
          • Manage Workload Identities
          • Manage Service Accounts and API Keys
            • Overview
            • Create Service Accounts
            • Manage Service Accounts
            • Manage API Keys
              • Overview
              • Manage API keys
              • Best Practices
              • Troubleshoot
          • Manage OAuth/OIDC Identity Providers
            • Overview
            • Add an OIDC Identity Provider
            • Use OAuth Identity Pools and Filters
            • Manage Identity Provider Configurations
            • Manage the JWKS URI
            • Configure OAuth Clients
              • Overview
              • Go Clients
              • Java Clients
              • JavaScript Clients
              • .NET Clients
              • Python Clients
              • Configuration Reference
              • Configure UAMI
              • Configure AWS IAM Java Client Plugin
              • Configure AWS IAM Python Client Plugin
              • Configure AWS IAM .NET Client Plugin
            • Access Kafka REST APIs
            • Use Confluent STS Tokens with REST APIs
            • Best Practices
            • Troubleshoot OAuth Issues
          • Manage mTLS Identity Providers
            • Overview
            • Configure mTLS
            • Manage Certificate Authorities
            • Manage Certificate Identity Pools
            • Create CEL Filters for mTLS
            • Create JSON payloads for mTLS
            • Manage Certificate Revocation
            • Troubleshoot mTLS Issues
      • Control Access
        • Overview
        • Resource Hierarchy
          • Overview
          • Organizations
            • Overview
            • Manage Multiple Organizations
          • Environments
          • Confluent Resource Names (CRNs)
        • Manage Role-Based Access Control
          • Overview
          • Predefined RBAC Roles
          • Manage Role Bindings
          • Use ACLs with RBAC
        • Manage IP Filtering
          • Overview
          • Manage IP Groups
          • Manage IP Filters
          • Best Practices
        • Manage Access Control Lists
          • Overview
          • Operations
          • Examples
          • Troubleshoot
          • Reference
        • Use the Confluent CLI with multiple credentials on Confluent Cloud
      • Encrypt and Protect Data
        • Overview
        • Manage Data in Transit With TLS
        • Use Self-Managed Encryption Keys
          • Overview
          • Use Self-Managed Encryption Keys on AWS
          • Use Self-Managed Encryption Keys on Azure
          • Use Self-Managed Encryption Keys on Google Cloud
          • Use Self-Managed Encryption Keys with Tableflow
          • Use Confluent CLI for Self-Managed Encryption Keys
          • Use BYOK API for Self-Managed Encryption Keys
          • Revoke Access to Data at Rest
          • Best Practices
          • Troubleshoot Key Policy Issues
        • Use Client-Side Field Level Encryption
          • Overview
          • Manage CSFLE using Confluent Cloud Console
          • Use Client-side Field Level Encryption
          • Configuration Settings
          • Manage Encryption Keys
          • Manage Multiple Encryption Rules
          • Quick Start
          • Implement a Custom KMS Driver
          • Process Encrypted Data with Apache Flink
          • Code examples
          • Troubleshoot
          • FAQ
        • Use Client-Side Payload Encryption
      • Monitor Activity
        • Concepts
        • Audit Log Event Categories
        • Audit Log Event Records
        • Audit Log Event Schema
        • Auditable Event Methods
          • Access Transparency
          • Connector
          • Custom Connector Plugin
          • Endpoints
          • Flink Management and Operations
          • Flink Authentication and Authorization
          • IP Filter Authorization
          • Kafka Cluster Management and Operations
          • Kafka Cluster Authentication and Authorization
          • ksqlDB Cluster Authentication and Authorization
          • Networking
          • Notifications Service
          • OAuth-OIDC Identity Provider and Identity Pool
          • Organization
          • Role-Based Access Control
          • Real-Time Context Engine
          • Schema Registry Management and Operations
          • Schema Registry Authentication and Authorization
          • Tableflow Control Plane
          • Tableflow Data Plane
          • Unified Stream Manager Control Plane
        • Access and Consume Audit Logs
        • Access Transparency
        • Retain Audit Logs
        • Best Practices
        • Troubleshoot
      • Access Management Tutorial
    • Manage Billing
      • Overview
      • Billing Dimensions
      • Invoices and Costs
      • Cost Allocation
      • Amazon Web Services
        • Pay As You Go
        • Commitments
      • Google Cloud
        • Pay as you Go
        • Commitments
        • Professional Services
      • Microsoft Azure
        • Pay As You Go
        • Commitments
        • Jio Commitments
        • Professional Services
      • Marketplace Organization Suspension and Deactivation
      • Troubleshoot Billing
      • FAQ
      • Legacy Billing Reference
    • Manage Service Quotas
      • Overview
      • Service Quotas
      • View Service Quotas Using Confluent CLI
      • Service Quotas API
    • APIs
      • Overview
      • Confluent Cloud API Usage and Reference
        • Overview
        • Confluent Cloud API Reference
        • Metrics API Reference
        • Admin and Produce REST API Usage
        • Connect API Usage
        • Provider Integration API Usage
        • Stream Catalog REST API Usage
        • Service Quotas API Usage
      • Kafka Client API Reference
        • Overview
        • .NET Client API Reference
        • C++ Client API Reference
        • Go Client API Reference
        • Java Client API Reference
        • JavaScript Client API Reference
        • Python Client API Reference
      • Flink Client API Usage and Reference
      • GraphQL API Usage and Reference
    • Confluent CLI
    • Release Notes & FAQ
      • Release Notes
      • FAQ
      • Upgrade Policy
      • Compliance
      • Generate a HAR file for Troubleshooting
      • AI Assistant
    • Support
    • Glossary
    1. Home
    2. Cloud
    3. Process Data with Confluent Cloud for Apache Flink
    4. Flink SQL and Table API Reference for Confluent Cloud for Apache Flink

    Flink SQL Reserved Keywords in Confluent Cloud for Apache Flink

    Keywords are words that have significance in Confluent Cloud for Apache Flink®. Some keywords, like AND, CHAR, and SELECT are reserved and require special treatment for use as identifiers like table names, column names, and the names of built-in functions.

    You can use reserved words as identifiers if you quote them with backtick characters. If you want to use one of the reserved words as a field name, enclose it with backticks, for example:

    `DATABASES`
    `RAW`
    

    You can use nonreserved keywords as identifiers without enclosing them with backticks.

    In the following tables, reserved keywords are shown in bold.

    Some string combinations are reserved as keywords for future use.

    Index

    A

    B

    C

    D

    E

    F

    G

    H

    I

    J

    K

    L

    M

    N

    O

    P

    Q

    R

    S

    T

    U

    V

    W

    X

    Y

    Z

    A

    A

    ABS

    ABSENT

    ABSOLUTE

    ACTION

    ADA

    ADD

    ADMIN

    AFTER

    ALL

    ALLOCATE

    ALLOW

    ALTER

    ALWAYS

    AND

    ANALYZE

    ANY

    APPLY

    ARE

    ARRAY

    ARRAY_AGG

    ARRAY_CONCAT_AGG

    ARRAY_MAX_CARDINALITY

    AS

    ASC

    ASENSITIVE

    ASSERTION

    ASSIGNMENT

    ASYMMETRIC

    AT

    ATOMIC

    ATTRIBUTE

    ATTRIBUTES

    AUTHORIZATION

    AVG

    B

    BEFORE

    BEGIN

    BEGIN_FRAME

    BEGIN_PARTITION

    BERNOULLI

    BETWEEN

    BIGINT

    BINARY

    BIT

    BLOB

    BOOLEAN

    BOTH

    BREADTH

    BUCKETS

    BY

    BYTES

    C

    C

    CALL

    CALLED

    CARDINALITY

    CASCADE

    CASCADED

    CASE

    CAST

    CATALOG

    CATALOG_NAME

    CATALOGS

    CEIL

    CEILING

    CENTURY

    CHAIN

    CHANGELOG_MODE

    CHAR

    CHARACTER

    CHARACTERISTICS

    CHARACTERS

    CHARACTER_LENGTH

    CHARACTER_SET_CATALOG

    CHARACTER_SET_NAME

    CHARACTER_SET_SCHEMA

    CHAR_LENGTH

    CHECK

    CLASS_ORIGIN

    CLASSIFIER

    CLOB

    CLOSE

    COALESCE

    COBOL

    COLLATE

    COLLATION

    COLLATION_CATALOG

    COLLATION_NAME

    COLLATION_SCHEMA

    COLLECT

    COLUMN

    COLUMNS

    COLUMN_NAME

    COMMAND_FUNCTION

    COMMAND_FUNCTION_CODE

    COMMENT

    COMMIT

    COMMITTED

    COMPACT

    COMPILE

    COMPUTE

    CONDITION

    CONDITION_NUMBER

    CONDITIONAL

    CONNECT

    CONNECTION

    CONNECTION_NAME

    CONSTRAINT

    CONSTRAINTS

    CONSTRAINT_CATALOG

    CONSTRAINT_NAME

    CONSTRAINT_SCHEMA

    CONSTRUCTOR

    CONTAINS

    CONTAINS_SUBSTR

    CONTINUE

    CONTINUOUS

    CONVERT

    CORR

    CORRESPONDING

    COUNT

    COVAR_POP

    COVAR_SAMP

    CREATE

    CROSS

    CUBE

    CUME_DIST

    CURRENT

    CURRENT_CATALOG

    CURRENT_DATE

    CURRENT_DEFAULT_TRANSFORM_GROUP

    CURRENT_PATH

    CURRENT_ROLE

    CURRENT_ROW

    CURRENT_SCHEMA

    CURRENT_TIME

    CURRENT_TIMESTAMP

    CURRENT_TRANSFORM_GROUP_FOR_TYPE

    CURRENT_USER

    CURSOR

    CURSOR_NAME

    CYCLE

    D

    DATA

    DATABASE

    DATABASES

    DATE

    DATE_DIFF

    DATE_TRUNC

    DATETIME

    DATETIME_DIFF

    DATETIME_INTERVAL_CODE

    DATETIME_INTERVAL_PRECISION

    DAY

    DAYOFWEEK

    DAYS

    DAYOFYEAR

    DATETIME_TRUNC

    DEALLOCATE

    DEC

    DECADE

    DECIMAL

    DECLARE

    DEFAULT

    DEFAULTS

    DEFERRABLE

    DEFERRED

    DEFINE

    DEFINED

    DEFINER

    DEGREE

    DELETE

    DENSE_RANK

    DEPTH

    DEREF

    DERIVED

    DESC

    DESCRIBE

    DESCRIPTION

    DESCRIPTOR

    DETERMINISTIC

    DIAGNOSTICS

    DISALLOW

    DISCONNECT

    DISPATCH

    DISTINCT

    DISTRIBUTED

    DISTRIBUTION

    DOMAIN

    DOT

    DOUBLE

    DOW

    DOY

    DRAIN

    DROP

    DYNAMIC

    DYNAMIC_FUNCTION

    DYNAMIC_FUNCTION_CODE


    E

    EACH

    ELEMENT

    ELSE

    EMPTY

    ENCODING

    END

    END-EXEC

    END_FRAME

    END_PARTITION

    ENFORCED

    EPOCH

    EQUALS

    ERROR

    ESCAPE

    ESTIMATED_COST

    EVERY

    EXCEPT

    EXCEPTION

    EXCLUDE

    EXCLUDING

    EXEC

    EXECUTE

    EXISTS

    EXP

    EXPLAIN

    EXTEND

    EXTENDED

    EXTERNAL

    EXTRACT

    F

    FALSE

    FETCH

    FILTER

    FINAL

    FIRST

    FIRST_VALUE

    FLOAT

    FLOOR

    FOLLOWING

    FOR

    FOREIGN

    FORMAT

    FORTRAN

    FOUND

    FRAC_SECOND

    FRAME_ROW

    FREE

    FRESHNESS

    FRIDAY

    FROM

    FULL

    FUNCTION

    FUNCTIONS

    FUSION

    G

    G

    GENERAL

    GENERATED

    GEOMETRY

    GET

    GLOBAL

    GO

    GOTO

    GRANT

    GRANTED

    GROUP

    GROUPING

    GROUPS

    GROUP_CONCAT

    H

    HAVING

    HASH

    HIERARCHY

    HOLD

    HOP

    HOUR

    HOURS

    I

    IDENTITY

    IF

    IGNORE

    IMMEDIATE

    IMMEDIATELY

    IMPLEMENTATION

    ILIKE

    IMPORT

    IN

    INCLUDE

    INCLUDING

    INCREMENT

    INDICATOR

    INITIAL

    INITIALLY

    INNER

    INOUT

    INPUT

    INSENSITIVE

    INSERT

    INSTANCE

    INSTANTIABLE

    INT

    INTEGER

    INTERSECT

    INTERSECTION

    INTERVAL

    INTO

    INVOKER

    IS

    ISODOW

    ISOLATION

    ISOYEAR

    J

    JAR

    JARS

    JAVA

    JOB

    JOBS

    JOIN

    JSON

    JSON_ARRAY

    JSON_ARRAYAGG

    JSON_EXECUTION_PLAN

    JSON_EXISTS

    JSON_OBJECT

    JSON_OBJECTAGG

    JSON_QUERY

    JSON_SCOPE

    JSON_VALUE

    K

    K

    KEY

    KEY_MEMBER

    KEY_TYPE

    L

    LABEL

    LAG

    LANGUAGE

    LARGE

    LAST

    LAST_VALUE

    LATERAL

    LEAD

    LEADING

    LEFT

    LENGTH

    LEVEL

    LIBRARY

    LIKE

    LIKE_REGEX

    LIMIT

    LN

    LOAD

    LOCAL

    LOCALTIME

    LOCALTIMESTAMP

    LOCATOR

    LOWER

    M

    M

    MAP

    MATCH

    MATCHED

    MATCHES

    MATCH_NUMBER

    MATCH_RECOGNIZE

    MATERIALIZED

    MAX

    MAXVALUE

    MEASURES

    MEMBER

    MERGE

    MESSAGE_LENGTH

    MESSAGE_OCTET_LENGTH

    MESSAGE_TEXT

    METADATA

    METHOD

    MICROSECOND

    MILLENNIUM

    MILLISECOND

    MIN

    MINUS

    MINUTE

    MINUTES

    MINUTE

    MINVALUE

    ML_PREDICT

    MOD

    MODEL

    MODELS

    MODIFIES

    MODIFY

    MODULE

    MODULES

    MONDAY

    MONTH

    MONTHS

    MORE

    MULTISET

    MUMPS

    N

    NAME

    NAMES

    NANOSECOND

    NATIONAL

    NATURAL

    NCHAR

    NCLOB

    NESTING

    NEW

    NEXT

    NO

    NONE

    NORMALIZE

    NORMALIZED

    NOT

    NTH_VALUE

    NTILE

    NULL

    NULLABLE

    NULLIF

    NULLS

    NUMBER

    NUMERIC

    O

    OBJECT

    OCCURRENCES_REGEX

    OCTETS

    OCTET_LENGTH

    OF

    OFFSET

    OLD

    OMIT

    ON

    ONE

    ONLY

    OPEN

    OPTION

    OPTIONS

    OR

    ORDER

    ORDERING

    ORDINAL

    ORDINALITY

    OTHERS

    OUT

    OUTER

    OUTPUT

    OVER

    OVERLAPS

    OVERLAY

    OVERRIDING

    OVERWRITE

    OVERWRITING

    P

    PAD

    PARAMETER

    PARAMETER_MODE

    PARAMETER_NAME

    PARAMETER_ORDINAL_POSITION

    PARAMETER_SPECIFIC_CATALOG

    PARAMETER_SPECIFIC_NAME

    PARAMETER_SPECIFIC_SCHEMA

    PARTIAL

    PARTITION

    PARTITIONED

    PARTITIONS

    PASCAL

    PASSING

    PASSTHROUGH

    PAST

    PATH

    PATTERN

    PER

    PERCENT

    PERCENTILE_CONT

    PERCENTILE_DISC

    PERCENT_RANK

    PERIOD

    PERMUTE

    PIVOT

    PLACING

    PLAN

    PLAN_ADVICE

    PLI

    PORTION

    POSITION

    POSITION_REGEX

    POWER

    PRECEDES

    PRECEDING

    PRECISION

    PREPARE

    PRESERVE

    PREV

    PRIMARY

    PRIOR

    PRIVILEGES

    PROCEDURE

    PROCEDURES

    PUBLIC

    PYTHON

    Q

    QUALIFY

    QUARTER

    QUARTERS

    R

    RANGE

    RANK

    RAW

    READ

    READS

    REAL

    RECURSIVE

    REF

    REFERENCES

    REFERENCING

    REFRESH_MODE

    REGR_AVGX

    REGR_AVGY

    REGR_COUNT

    REGR_INTERCEPT

    REGR_R2

    REGR_SLOPE

    REGR_SXX

    REGR_SXY

    REGR_SYY

    RELATIVE

    RELEASE

    REMOVE

    RENAME

    REPEATABLE

    REPLACE

    RESET

    RESPECT

    RESTART

    RESTRICT

    RESULT

    RETURN

    RETURNED_CARDINALITY

    RETURNED_LENGTH

    RETURNED_OCTET_LENGTH

    RETURNED_SQLSTATE

    RETURNING

    RETURNS

    REVOKE

    RIGHT

    RLIKE

    ROLE

    ROLLBACK

    ROLLUP

    ROUTINE

    ROUTINE_CATALOG

    ROUTINE_NAME

    ROUTINE_SCHEMA

    ROW

    ROWS

    ROW_COUNT

    ROW_NUMBER

    RUNNING

    S

    SAFE_CAST

    SAFE_OFFSET

    SAFE_ORDINAL

    SATURDAY

    SAVEPOINT

    SCALA

    SCALAR

    SCALE

    SCHEMA

    SCHEMA_NAME

    SCOPE

    SCOPE_CATALOGS

    SCOPE_NAME

    SCOPE_SCHEMA

    SCROLL

    SEARCH

    SECOND

    SECONDS

    SECTION

    SECURITY

    SEEK

    SELECT

    SELF

    SENSITIVE

    SEPARATOR

    SEQUENCE

    SERIALIZABLE

    SERVER

    SERVER_NAME

    SESSION

    SESSION_USER

    SET

    SETS

    SHOW

    SIMILAR

    SIMPLE

    SIZE

    SKIP

    SMALLINT

    SOME

    SOURCE

    SPACE

    SPECIFIC

    SPECIFICTYPE

    SPECIFIC_NAME

    SQL

    SQLEXCEPTION

    SQLSTATE

    SQLWARNING

    SQL_BIGINT

    SQL_BINARY

    SQL_BIT

    SQL_BLOB

    SQL_BOOLEAN

    SQL_CHAR

    SQL_CLOB

    SQL_DATE

    SQL_DECIMAL

    SQL_DOUBLE

    SQL_FLOAT

    SQL_INTEGER

    SQL_INTERVAL_DAY

    SQL_INTERVAL_DAY_TO_HOUR

    SQL_INTERVAL_DAY_TO_MINUTE

    SQL_INTERVAL_DAY_TO_SECOND

    SQL_INTERVAL_HOUR

    SQL_INTERVAL_HOUR_TO_MINUTE

    SQL_INTERVAL_HOUR_TO_SECOND

    SQL_INTERVAL_MINUTE

    SQL_INTERVAL_MINUTE_TO_SECOND

    SQL_INTERVAL_MONTH

    SQL_INTERVAL_SECOND

    SQL_INTERVAL_YEAR

    SQL_INTERVAL_YEAR_TO_MONTH

    SQL_LONGVARBINARY

    SQL_LONGVARCHAR

    SQL_LONGVARNCHAR

    SQL_NCHAR

    SQL_NCLOB

    SQL_NUMERIC

    SQL_NVARCHAR

    SQL_REAL

    SQL_SMALLINT

    SQL_TIME

    SQL_TIMESTAMP

    SQL_TINYINT

    SQL_TSI_DAY

    SQL_TSI_FRAC_SECOND

    SQL_TSI_HOUR

    SQL_TSI_MICROSECOND

    SQL_TSI_MINUTE

    SQL_TSI_MONTH

    SQL_TSI_QUARTER

    SQL_TSI_SECOND

    SQL_TSI_WEEK

    SQL_TSI_YEAR

    SQL_VARBINARY

    SQL_VARCHAR

    SQRT

    START

    STATE

    STATEMENT

    STATIC

    STATISTICS

    STDDEV_POP

    STDDEV_SAMP

    STOP

    STREAM

    STRING

    STRING_AGG

    STRUCTURE

    STYLE

    SUBCLASS_ORIGIN

    SUBMULTISET

    SUBSET

    SUBSTITUTE

    SUBSTRING

    SUBSTRING_REGEX

    SUCCEEDS

    SUM

    SUNDAY

    SUSPEND

    SYMMETRIC

    SYSTEM

    SYSTEM_TIME

    SYSTEM_USER

    T

    TABLE

    TABLES

    TABLESAMPLE

    TABLE_NAME

    TEMPORARY

    THEN

    THURSDAY

    TIES

    TIME

    TIMESTAMP

    TIMESTAMP_DIFF

    TIMESTAMP_LTZ

    TIMESTAMP_TRUNC

    TIMESTAMPADD

    TIMESTAMPDIFF

    TIMEZONE_HOUR

    TIMEZONE_MINUTE

    TIME_DIFF

    TIME_TRUNC

    TINYINT

    TO

    TOP_LEVEL_COUNT

    TRAILING

    TRANSACTION

    TRANSACTIONS_ACTIVE

    TRANSACTIONS_COMMITTED

    TRANSACTIONS_ROLLED_BACK

    TRANSFORM

    TRANSFORMS

    TRANSLATE

    TRANSLATE_REGEX

    TRANSLATION

    TREAT

    TRIGGER

    TRIGGER_CATALOG

    TRIGGER_NAME

    TRIGGER_SCHEMA

    TRIM

    TRIM_ARRAY

    TRUE

    TRUNCATE

    TRY_CAST

    TUESDAY

    TUMBLE

    TYPE

    U

    UESCAPE

    UNBOUNDED

    UNCOMMITTED

    UNCONDITIONAL

    UNDER

    UNION

    UNIQUE

    UNKNOWN

    UNLOAD

    UNNAMED

    UNNEST

    UNPIVOT

    UPDATE

    UPPER

    UPSERT

    USAGE

    USE

    USER

    USER_DEFINED_TYPE_CATALOG

    USER_DEFINED_TYPE_CODE

    USER_DEFINED_TYPE_NAME

    USER_DEFINED_TYPE_SCHEMA

    USING

    UTF16

    UTF32

    UTF8

    V

    VALUE

    VALUES

    VALUE_OF

    VARBINARY

    VARCHAR

    VARYING

    VAR_POP

    VAR_SAMP

    VERSION

    VERSIONING

    VIEW

    VIEWS

    VIRTUAL

    W

    WATERMARK

    WATERMARKS

    WEDNESDAY

    WEEK

    WEEKS

    WHEN

    WHENEVER

    WHERE

    WIDTH_BUCKET

    WINDOW

    WITH

    WITHIN

    WITHOUT

    WORK

    WRAPPER

    WRITE

    X

    XML

    Y

    YEAR

    YEARS

    Z

    ZONE

    Related content

    • DDL Statements

    • Flink SQL Queries

    Note

    This website includes content developed at the Apache Software Foundation under the terms of the Apache License v2.

    Ask the community Confluent Support Portal Last published: Aug 20, 2026
    Terms & Conditions | Privacy Policy | Do Not Sell My Information | Modern Slavery Policy | Cookie Settings | Feedback

    Copyright © Confluent, Inc. 2014- Apache®, Apache Kafka®, Kafka®, Apache Flink®, Flink®, Apache Iceberg®, Iceberg® and associated open source project names are trademarks of the Apache Software Foundation

    Give feedback about this page
    On this page:
    • Index
    • A
    • B
    • C
    • D
    • E
    • F
    • G
    • H
    • I
    • J
    • K
    • L
    • M
    • N
    • O
    • P
    • Q
    • R
    • S
    • T
    • U
    • V
    • W
    • X
    • Y
    • Z
    • Related content