SQL | Apache Flink

v2.0-SNAPSHOT

Try Flink
▾
Learn Flink
▾
Concepts
▾
Application Development
▾
- Project Configuration▾
- DataStream API▾
  - Overview
  - Execution Mode (Batch/Streaming)
  - Event Time▾
    - Generating Watermarks
    - Builtin Watermark Generators
  - State & Fault Tolerance▾
    - Working with State
    - The Broadcast State Pattern
    - Checkpointing
    - State Backends
    - Data Types & Serialization▾
  - User-Defined Functions
  - Operators▾
  - Data Sources
  - Side Outputs
  - Handling Application Parameters
  - Testing
  - Experimental Features
  - Java Lambda Expressions
  - Managing Execution▾
- Table API & SQL▾
  - Overview
  - Concepts & Common API
  - DataStream API Integration
  - Streaming Concepts▾
  - Data Types
  - Time Zone
  - Table API
  - SQL▾
  - Materialized Table▾
  - Functions▾
  - Procedures
  - Modules
  - Catalogs
  - Flink JDBC Driver
  - OLAP Quickstart
  - SQL Client
  - SQL Gateway▾
  - Hive Compatibility▾
    - Hive Dialect▾
      - Overview
      - Queries▾
        
        Overview
        
        Sort/Cluster/Distributed By
        
        Group By
        
        Join
        
        Set Operations
        
        Lateral View Clause
        
        Window Functions
        
        Sub-Queries
        
        CTE
        
        Transform Clause
        
        Table Sample
      - CREATE Statements
      - DROP Statements
      - ALTER Statements
      - INSERT Statements
      - Load Data Statements
      - SHOW Statements
      - ADD Statements
      - SET Statements
  - Configuration
  - Performance Tuning
  - User-defined Sources & Sinks
- Python API▾
  - Overview
  - Installation
  - Table API Tutorial
  - DataStream API Tutorial
  - Table API▾
    - Intro to the Python Table API
    - TableEnvironment
    - Operations▾
      - Overview
      - Row-based Operations
    - Data Types
    - System (Built-in) Functions
    - User Defined Functions▾
    - Conversions between PyFlink Table and Pandas DataFrame
    - Conversions between Table and DataStream
    - SQL
    - Catalogs
    - Metrics
    - Connectors
  - DataStream API▾
    - Intro to the Python DataStream API
    - Operators▾
    - Data Types
    - State
  - Dependency Management
  - Execution Mode
  - Configuration
  - Debugging
  - Environment Variables
  - FAQ
Libraries
▾
- Event Processing (CEP)
- State Processor API
Connectors
▾
- DataStream Connectors▾
  - Overview
  - Fault Tolerance Guarantees
  - Formats▾
    - Overview
    - Avro
    - Azure Table storage
    - CSV
    - Hadoop
    - JSON
    - Parquet
    - Text files
  - DataGen
  - Dynamic Kafka
  - Kafka
  - Cassandra
  - DynamoDB
  - Elasticsearch
  - Firehose
  - Kinesis
  - MongoDB
  - Opensearch
  - Prometheus
  - SQS
  - FileSystem
  - RabbitMQ
  - Google Cloud PubSub
  - Hybrid Source
  - Pulsar
  - JDBC
- Table API Connectors▾
  - Overview
  - Formats▾
    - Formats
    - CSV
    - JSON
    - Avro
    - Confluent Avro
    - Protobuf
    - Debezium
    - Canal
    - Maxwell
    - Ogg
    - Parquet
    - Orc
    - Raw
  - Kafka
  - Upsert Kafka
  - DynamoDB
  - Firehose
  - Kinesis
  - MongoDB
  - JDBC
  - Elasticsearch
  - Opensearch
  - FileSystem
  - HBase
  - DataGen
  - Print
  - BlackHole
  - Hive▾
  - Download
Deployment
▾
- Overview
- Java Compatibility
- Resource Providers▾
  - Standalone▾
  - Native Kubernetes
  - YARN
- Configuration
- Memory Configuration▾
- Command-Line Interface
- Elastic Scaling
- Fine-Grained Resource Management
- Speculative Execution
- File Systems▾
- High Availability▾
- Metric Reporters
- Trace Reporters
- REPLs▾
  - Python REPL
- Security▾
- Advanced▾
Operations
▾
- State & Fault Tolerance▾
- Metrics
- Traces
- REST API
- Batch▾
  - Batch Shuffle
  - Recovery job progress from job master failures
- Debugging▾
- Monitoring▾
  - Monitoring Checkpointing
  - Monitoring Back Pressure
- Upgrading Applications and Flink Versions
- Production Readiness Checklist
Flink Development
▾
- Importing Flink into an IDE
- Building Flink from Source
Internals
▾

Project Homepage
JavaDocs
PyDocs

Pick Docs Version

▾

2.0-SNAPSHOT (✓)

v1.20
v1.19

All Versions

中文版

SQL

On This Page

This documentation is for an unreleased version of Apache Flink. We recommend you use the latest stable version.

Want to contribute translation?

Edit This Page

On This Page