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 APISQL内置函数用户定义的源和接收器用户定义的函数SQL客户端测试版 数据类型和序列化 为Flink程序注册自定义序列化程序 管理执行 执行配置程序打包和分布式执行并行执行执行计划重启策略 类库 FlinkCEP - Flink的复杂事件处理风暴兼容性BetaGelly:Flink Graph API图API 迭代图处理类库方法图算法图形生成器二分图 FlinkML - Flink的机器学习 快速入门指南如何贡献交叉验证Distance Metricsk-Nearest Neighbors关联MinMax ScalerMultiple Linear Regression在管道的引擎盖下看Polynomial Features随机异常值选择Standard ScalerAlternating Least SquaresSVM using CoCoA 最佳实践API迁移指南 部署和运营 集群和部署 独立群集YARN设置Mesos设置Kubernetes设置Docker设置亚马逊网络服务(AWS)Google Compute Engine设置MapR设置Hadoop集成 JobManager高可用性(HA)状态和容错 检查点保存点状态后台调整检查点和大状态 配置生产准备清单命令行界面Scala REPLKerberos身份验证设置和配置SSL设置文件系统升级应用程序和Flink版本 调试和监控 度量如何使用日志记录历史服务器监控检查点监测背压监控REST API调试Windows和事件时间调试类加载应用程序分析 Flink Development 将Flink导入IDE从Source建立Flink 内幕 组件堆栈数据流容错工作和调度任务生命周期文件系统