This documentation is for an out-of-date version of Apache Flink. We recommend you use
the latest stable version
.
v1.11
Home
Try Flink
Local Installation
Fraud Detection with the DataStream API
Real Time Reporting with the Table API
Python API
Flink Operations Playground
Learn Flink
Overview
Intro to the DataStream API
Data Pipelines & ETL
Streaming Analytics
Event-driven Applications
Fault Tolerance
Concepts
Overview
Stateful Stream Processing
Timely Stream Processing
Flink Architecture
Glossary
Application Development
DataStream API
Overview
Event Time
Overview
Generating Watermarks
Builtin Watermark Generators
State & Fault Tolerance
Overview
Working with State
The Broadcast State Pattern
Checkpointing
Queryable State
State Backends
State Schema Evolution
Custom State Serialization
User-Defined Functions
Operators
Overview
Windows
Joining
Process Function
Async I/O
Data Sources
Side Outputs
Handling Application Parameters
Testing
Experimental Features
Scala API Extensions
Java Lambda Expressions
Project Configuration
DataSet API
Overview
Transformations
Iterations
Zipping Elements
Hadoop Compatibility
Local Execution
Cluster Execution
Batch Examples
Table API & SQL
Overview
Concepts & Common API
Streaming Concepts
Overview
Dynamic Tables
Time Attributes
Joins in Continuous Queries
Temporal Tables
Detecting Patterns
Query Configuration
Data Types
Table API
SQL
Overview
Queries
CREATE Statements
DROP Statements
ALTER Statements
INSERT Statement
SQL Hints
DESCRIBE Statements
EXPLAIN Statements
USE Statements
SHOW Statements
Functions
Overview
System (Built-in) Functions
User-defined Functions
Modules
Catalogs
SQL Client
Hive Integration
Overview
HiveCatalog
Hive Dialect
Hive Read & Write
Hive Streaming
Hive functions
Configuration
Performance Tuning
Streaming Aggregation
User-defined Sources & Sinks
Python API
Installation
Table API Tutorial
Table API User's Guide
Intro to the Python Table API
TableEnvironment
Operations
Data Types
System (Built-in) Functions
User Defined Functions
General User-defined Functions
Vectorized User-defined Functions
Conversions between PyFlink Table and Pandas DataFrame
Dependency Management
SQL
Catalogs
Metrics
Configuration
Connectors
Environment Variables
FAQ
Data Types & Serialization
Overview
Custom Serializers
Managing Execution
Execution Configuration
Program Packaging
Parallel Execution
Execution Plans
Task Failure Recovery
API Migration Guides
Libraries
Event Processing (CEP)
State Processor API
Graphs: Gelly
Overview
Graph API
Iterative Graph Processing
Library Methods
Graph Algorithms
Graph Generators
Bipartite Graph
Connectors
DataStream Connectors
Overview
Fault Tolerance Guarantees
Kafka
Cassandra
Kinesis
Elasticsearch
Hadoop FileSystem
Streaming File Sink
RabbitMQ
NiFi
Google Cloud PubSub
Twitter
JDBC
Table & SQL Connectors
Overview
Formats
Overview
CSV
JSON
Avro
Debezium
Canal
Parquet
Orc
Kafka
JDBC
Elasticsearch
FileSystem
HBase
DataGen
Print
BlackHole
DataSet Connectors
Deployment & Operations
Clusters & Deployment
Overview
Local Cluster
Standalone Cluster
YARN
Mesos
Docker
Kubernetes
Native Kubernetes
Hadoop Integration
High Availability (HA)
State & Fault Tolerance
Checkpoints
Savepoints
State Backends
Tuning Checkpoints and Large State
Configuration
Memory Configuration
Set up Flink's Process Memory
Set up TaskManager Memory
Set up JobManager Memory
Memory tuning guide
Troubleshooting
Migration Guide
Production Readiness Checklist
CLI
Python REPL
Scala REPL
External Resources
Kerberos
SSL Setup
File Systems
Overview
Common Configurations
Amazon S3
Aliyun OSS
Azure Blob Storage
Upgrading Applications and Flink Versions
Plugins
Debugging & Monitoring
Metrics
Logging
History Server
Monitoring Checkpointing
Monitoring Back Pressure
Monitoring REST API
Debugging Windows & Event Time
Debugging Classloading
Application Profiling & Debugging
Flink Development
Importing Flink into an IDE
Building Flink from Source
Internals
Jobs and Scheduling
Task Lifecycle
File Systems
Javadocs
Scaladocs
Pythondocs
Project Page
Go
Pick Docs Version
v1.10
v1.9
v1.8
v1.7
v1.6
v1.5
v1.4
v1.3
v1.2
v1.1
v1.0
中文版
Page 'Getting Started' Has Moved
The page
Getting Started
has been moved. Redirecting to
//ci.apache.org/projects/flink/flink-docs-release-1.11/index.html
in 1 second.
v1.11 v1.11