Table of contents README（已更新至1.11版本） 尝试 Flink 本地安装 利用数据流API进行欺诈检测 使用Table API进行实时报告 Python API Flink 操作游乐园 了解 Flink 学习Flink：动手训练 DataStream API简介 数据管道及ETL 流分析 事件驱动应用 通过状态快照实现容错 概念 概述 有状态的流处理 及时流处理 分布式运行环境 Flink架构 词汇表 介绍 运维 应用 架构 应用场景 Apache Flink应用场景 Getting Started 概述 代码走查 DataStream API Table API Docker游乐园 教程 API教程 DataStream API教程 配置教程 本地配置 在Windows上运行Flink 示例 概述 批次示例 应用开发 项目构建配置 Scala项目模版 Java项目模版 配置Dependencies, Connectors, Libraries API基础概念 概述 Streaming(DataStream API) 概述 执行模式(批/流) Event Time 概述 生成水位线(Watermarks) 内置水位线生成器 状态&容错 概述 工作状态 广播状态模式 检查点(Checkpointing) 可查询状态(Beta) State Backends 状态模式演化 自定义状态序列化 用户自定义函数（UDF） Operators 概述 Windows Joining 处理函数(低级操作) 异步I/O 数据源(Data Source) 侧输出 测试 实验特性 Scala API拓展 Java Lambda表达式 项目配置 Batch(DataSet API) 概述 转换 迭代 Zipping元素 Hadoop兼容性 本地执行 集群执行 批处理示例 Table API & SQL 概述 概念&通用API Streaming相关概念 概述 动态表 时间属性 持续查询中的关联 时态表 模式检测 查询配置 数据类型 Table API SQL 总览 查询 CREATE语句 DROP语句 ALTER语句 INSERT语句 连接外部系统 函数 总览 内嵌函数 用户自定义函数 模块(Module) Catalogs SQL客户端 Hive 概述 HiveCatalog 读取和写入Hive表 Hive函数 在scala shell中使用Hive连接器 配置 性能优化 流式聚合 用户自定义Source&Sink Python API 安装 Table API教程 Table API用户指南 用户自定义函数 通用的用户自定义函数 向量化的用户自定义函数 配置 依赖管理 常见问题 数据类型&序列化 概述 自定义序列化 管理执行 执行配置 项目打包 并行执行 执行计划 任务失败恢复 最佳实践 API迁移向导 Libraries 事件处理(CEP) State Processor API 图计算:Gelly 概述 Graph API 迭代图处理 Libarary方法 图算法 图生成器 二分图 Connectors DataStream Connectors 概述 容错保证 Kafka Cassandra Kinesis Elasticsearch Hadoop文件系统 Streaming File Sink RabbitMQ NiFi Google Cloud PubSub Twitter JDBC Table & SQL Connentors 总览 格式 总览 CSV JSON Avro Debezium Canal Parquet Orc Kafka JDBC Elasticsearch 文件系统 HBase DataGen Print BlackHole DataSet Connectors 部署-操作 集群和部署 独立集群 Yarn Mesos Docker Kubernetes 本地Kubernetes Hadoop整合 高可用(HA) 状态&容错 Checkpoints Savepoints 状态后端 优化检查点和大状态 配置 内存配置 设置Flink处理内存 设置TaskManager内存 设置JobManager内存 设置任务执行器（Task Executor）内存 内存模型详情 内存调优指南 故障排查 迁移指南 生产准备检查表 CLI Python REPL Scala REPL Kerberos SSL设置 文件系统 总览 常用配置 亚马逊S3 阿里云OSS Azure Blob存储 升级应用程序和Flink版本 插件(Plugins) 监控&调试 指标 日志 History Server 监控检查点 监测背压 监控REST API 调试Windows和Event Time 调试类加载 应用程序分析 Flink开发 将Flink导入IDE Source构建Flink 技术内幕 组件栈 数据流容错 任务和调度 Task生命周期 文件系统 Others FAQ Blog Release Notes Flink 1.9 获取帮助 社区及项目信息 How To Contribute