Skip to content
【布客】Flink 中文翻译
Flink 1.7 中文文档
Initializing search
apachecn/flink-doc-zh
【布客】Flink 中文翻译
apachecn/flink-doc-zh
入门须知
Apache Flink 1.7 中文文档
概念
概念
数据流编程模型
分布式运行环境
教程
教程
API 教程
API 教程
DataStream API教程
Setup 教程
Setup 教程
本地安装教程
在Windows上运行Flink
案例
案例
概述
批处理示例
应用开发
应用开发
项目构建设置
项目构建设置
Java项目模板
Scala的项目模板
配置依赖关系，连接器，库
基础 API 概念
基础 API 概念
概述
Scala API扩展
Java Lambda表达式
Flink DataStream API编程指南
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编程指南
Flink DataSet API编程指南
概述
数据集转换
容错
在数据集中压缩数据元
迭代
Python编程指南Beta
连接器
Hadoop兼容性测试版
本地执行
群集执行
Table API和SQL
Table API和SQL
概述
概念和通用API
流处理概念
连接到外部系统
Table API
SQL
内置函数
用户定义的源和接收器
用户定义的函数
SQL客户端测试版
数据类型和序列化
数据类型和序列化
概述
为Flink程序注册自定义序列化程序
管理执行
管理执行
执行配置
程序打包和分布式执行
并行执行
执行计划
重启策略
类库
类库
FlinkCEP - Flink的复杂事件处理
风暴兼容性Beta
Gelly：Flink Graph API
图API
图API
概述
迭代图处理
类库方法
图算法
图形生成器
二分图
FlinkML - Flink的机器学习
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 开发
Flink 开发
将Flink导入IDE
从Source建立Flink
内部结构
内部结构
组件堆栈
数据流容错
工作和调度
任务生命周期
文件系统
贡献者
关于我们
中文资源合集
Flink 1.7 中文文档
（施工中）
我们一直在努力
apachecn/AiLearning
为正常使用来必力评论功能请激活JavaScript
回到顶部
