Flink组件栈
flink组件栈
libraries
api 层
runtime
flink on yarn
Flink组件栈
Libaries层:
在API层之上构建的满足特定应用的实现计算框架,也分别对应于面向流处理和面向批处理两类。
API层:
主要实现了面向无界Stream的流处理和面向Batch的批处理API,其中面向流处理对应DataStream API,面向批处理对应的DataSet API。
Runtime层:
提供了支持Flink计算的全部核心实现,比如:支持分布式Stream处理、JobGraph到ExecutionGraph的映射、调度等等,为上层API层提供基础服务。
Deployment层
主要涉及Flink部署模式:
1、本地
2、集群(Standalone、YARN)
3、云(GCE/EC2)
Libaries层
Flink的API层
Runtime层
Deployment层
Flink组件栈
Flink组件栈
Flink组件栈
-Libaries层
Flink组件栈
-API层
Flink组件栈
-Runtime层
Flink组件栈
yarn是什么
Flink组件栈
-Deployment层
Flink组件栈