v1.16.2

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
    - Queryable State
    - State Backends
    - Data Types & Serialization▾
  - User-Defined Functions
  - Operators▾
  - Data Sources
  - Side Outputs
  - Handling Application Parameters
  - Testing
  - Experimental Features
  - Scala API Extensions
  - Java Lambda Expressions
  - Managing Execution▾
- Table API & SQL▾
  - Overview
  - Concepts & Common API
  - DataStream API Integration
  - Streaming Concepts▾
  - Data Types
  - Time Zone
  - Table API
  - SQL▾
  - Functions▾
  - Modules
  - Catalogs
  - 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
    - HiveServer2 Endpoint
  - 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
- DataSet API (Legacy)▾
Libraries
▾
- Event Processing (CEP)
- State Processor API
- Graphs▾
Connectors
▾
- DataSet Connectors▾
  - Formats▾
- DataStream Connectors▾
  - Overview
  - Fault Tolerance Guarantees
  - Formats▾
    - Overview
    - Avro
    - Azure Table storage
    - CSV
    - Hadoop
    - JSON
    - Parquet
    - Text files
  - Kafka
  - Cassandra
  - DynamoDB
  - Elasticsearch
  - Firehose
  - Kinesis
  - MongoDB
  - Opensearch
  - 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
- 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
- Security▾
  - SSL Setup
  - Kerberos
- REPLs▾
  - Python REPL
- Advanced▾
Operations
▾
- State & Fault Tolerance▾
- Metrics
- REST API
- Batch▾
  - Batch Shuffle
- 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
ScalaDocs
PyDocs

Pick Docs Version

▾

v1.16
v1.15

All Versions

中文版

Versions

Versions #

An appendix of hosted documentation for all versions of Apache Flink.

v1.16
v1.15
v1.14
v1.13
v1.12
v1.11
v1.10
v1.9
v1.8
v1.7
v1.6
v1.5
v1.4
v1.3
v1.2
v1.1
v1.0

Want to contribute translation?

Edit This Page