本文档是 Apache Flink 的旧版本。建议访问
最新的稳定版本
。
v1.12
Home
Try Flink
本地模式安装
基于 DataStream API 实现欺诈检测
基于 Table API 实现实时报表
Flink 操作场景
实践练习
概览
DataStream API 简介
数据管道 & ETL
流式分析
事件驱动应用
容错处理
概念透析
概览
有状态流处理
及时流处理
Flink 架构
词汇表
应用开发
DataStream API
概览
Execution Mode (Batch/Streaming)
事件时间
概览
生成 Watermark
内置 Watermark 生成器
状态与容错
概览
Working with State
Broadcast State 模式
Checkpointing
Queryable State
State Backends
状态数据结构升级
自定义状态序列化
用户自定义 Functions
算子
概览
窗口
Joining
Process Function
异步 I/O
Data Sources
旁路输出
Handling Application Parameters
测试
实验功能
Scala API Extensions
Java Lambda 表达式
Project Configuration
DataSet API
概览
Transformations
迭代
Zipping Elements
Hadoop 兼容
本地执行
集群执行
Batch 示例
Table API & SQL
概览
概念与通用 API
流式概念
概览
动态表 (Dynamic Table)
时间属性
时态表(Temporal Tables)
流上的 Join
模式检测
Query Configuration
Legacy Features
数据类型
Table API
SQL
概览
查询语句
CREATE 语句
DROP 语句
ALTER 语句
INSERT 语句
SQL Hints
DESCRIBE 语句
EXPLAIN 语句
USE 语句
SHOW 语句
函数
概览
系统(内置)函数
自定义函数
模块
Catalogs
SQL 客户端
配置
Performance Tuning
流式聚合
User-defined Sources & Sinks
Python API
概览
环境安装
Table API 教程
DataStream API 教程
Table API用户指南
Python Table API 简介
TableEnvironment
Operations
数据类型
系统(内置)函数
自定义函数
普通自定义函数(UDF)
向量化自定义函数
PyFlink Table 和 Pandas DataFrame 互转
SQL
Catalogs
指标
连接器
DataStream API用户指南
Python DataStream API 简介
数据类型
算子
依赖管理
配置
调试
环境变量
常见问题
数据类型以及序列化
概览
自定义序列化器
管理执行
执行配置
程序打包
并行执行
执行计划
Task 故障恢复
API 迁移指南
Libraries
事件处理 (CEP)
State Processor API
图计算: Gelly
概览
Graph API
Iterative Graph Processing
Library Methods
Graph Algorithms
Graph Generators
Bipartite Graph
Connectors
DataStream Connectors
概览
容错保证
Kafka
Cassandra
Kinesis
Elasticsearch
File Sink
Streaming File Sink
RabbitMQ
NiFi
Google Cloud PubSub
Twitter
JDBC
Table & SQL Connectors
概览
Formats
概览
CSV
JSON
Confluent Avro
Avro
Debezium
Canal
Maxwell
Parquet
Orc
Raw
Kafka
Upsert Kafka
Kinesis
JDBC
Elasticsearch
FileSystem
HBase
DataGen
Print
BlackHole
Hive
概览
Hive Catalog
Hive 方言
Hive Read & Write
Hive 函数
下载
DataSet Connectors
Deployment
概览
Resource Providers
Standalone
概览
Docker
Kubernetes
Native Kubernetes
YARN
Mesos
配置参数
内存配置
配置 Flink 进程的内存
配置 TaskManager 内存
配置 JobManager 内存
调优指南
常见问题
升级指南
命令行界面
文件系统
概览
通用配置
Amazon S3
阿里云 OSS
Azure Blob 存储
Google Cloud Storage
Plugins
High Availability (HA)
概览
ZooKeeper HA Services
Kubernetes HA Services
Metric Reporters
Security
SSL 设置
Kerberos
REPLs
Python REPL
Scala REPL
Advanced
扩展资源
History Server
日志
Operations
状态与容错
Checkpoints
Savepoints
State Backends
大状态与 Checkpoint 调优
指标
REST API
Debugging
调试窗口与事件时间
调试类加载
应用程序分析
Monitoring
监控 Checkpoint
监控反压
升级应用程序和 Flink 版本
生产就绪情况核对清单
Flink 开发
导入 Flink 到 IDE 中
从源码构建 Flink
内幕
作业调度
Task 生命周期
文件系统
Javadocs
Scaladocs
Pythondocs
Project Page
Go
选择文档版本
v1.11
v1.10
v1.9
v1.8
v1.7
v1.6
v1.5
v1.4
v1.3
v1.2
v1.1
v1.0
English
'Logging' 页面已被移动
Logging
页面已经被移动了。将在 1 秒后重定向到
//ci.apache.org/projects/flink/flink-docs-release-1.12/zh/deployment/advanced/logging.html
。