SUMMARY Apache Flink 1.7-SNAPSHOT 中文文档 概念 数据流编程模型 分布式运行时环境 教程 API 教程 DataStream API教程 Setup 教程 本地安装教程 在Windows上运行Flink 例子 批处理示例 应用开发 项目构建设置 Java项目模板 Scala的项目模板 配置依赖关系，连接器，库 基础 API 概念 Scala API扩展 Java Lambda表达式 Flink DataStream API编程指南 活动时间 生成时间戳/水印 预定义的时间戳提取器/水印发射器 状态与容错 状态运行 广播状态模式 检查点 可查询状态Beta 状态后台 管理状态的自定义序列化 算子 视窗 Join 过程函数（低级 算子操作） 外部数据访问的异步I / O. 流连接器 数据源和接收器的容错保证 Apache Kafka连接器 Apache Cassandra连接器 亚马逊AWS Kinesis Streams连接器 Elasticsearch连接器 HDFS连接器 流文件接收器 RabbitMQ连接器 Apache NiFi连接器 Twitter连接器 旁路输出 Python编程指南（流）Beta 测试 实验特点 Flink DataSet API编程指南 数据集转换 容错 在数据集中压缩数据元 迭代 Python编程指南Beta 连接器 Hadoop兼容性测试版 本地执行 群集执行 Table API和SQL 概念和通用API 流处理概念 连接到外部系统 Table API SQL 内置函数 用户定义的源和接收器 用户定义的函数 SQL客户端测试版 数据类型和序列化 为Flink程序注册自定义序列化程序 管理执行 执行配置 程序打包和分布式执行 并行执行 执行计划 重启策略 类库 FlinkCEP - Flink的复杂事件处理 风暴兼容性Beta Gelly：Flink Graph API 图API 迭代图处理 类库方法 图算法 图形生成器 二分图 FlinkML - Flink的机器学习 快速入门指南 如何贡献 交叉验证 Distance Metrics k-Nearest Neighbors关联 MinMax Scaler Multiple Linear Regression 在管道的引擎盖下看 Polynomial Features 随机异常值选择 Standard Scaler Alternating Least Squares SVM using CoCoA 最佳实践 API迁移指南 部署和运营 集群和部署 独立群集 YARN设置 Mesos设置 Kubernetes设置 Docker设置 亚马逊网络服务（AWS） Google Compute Engine设置 MapR设置 Hadoop集成 JobManager高可用性（HA） 状态和容错 检查点 保存点 状态后台 调整检查点和大状态 配置 生产准备清单 命令行界面 Scala REPL Kerberos身份验证设置和配置 SSL设置 文件系统 升级应用程序和Flink版本 调试和监控 度量 如何使用日志记录 历史服务器 监控检查点 监测背压 监控REST API 调试Windows和事件时间 调试类加载 应用程序分析 Flink Development 将Flink导入IDE 从Source建立Flink 内幕 组件堆栈 数据流容错 工作和调度 任务生命周期 文件系统 我们一直在努力 apachecn/AiLearning 为正常使用来必力评论功能请激活JavaScript
