Flink 1.7-SNAPSHOT 中文文档
Apache Flink文档
概念
数据流编程模型
分布式运行时环境
教程
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
内幕
组件堆栈
数据流容错
工作和调度
任务生命周期
文件系统
Powered by
GitBook
状态和容错
状态和容错
results matching "
"
No results matching "
"