-
curl https://flink.apache.org/q/quickstart.sh | bash
查看全部 -
flink并行度查看全部
-
维基百科，统计编辑
查看全部 -
创建项目
查看全部 -
常用算子
查看全部 -
Flink分布式运行环境
Flink是基于Master-Slave风格的架构。
Flink集群启动时，会启动一个JobManager进程、至少一个TaskManager进程。
JobManager：1、Flink系统的协调者，它负责接收Flink Job，调度组成Job的多个Task的执行。2、收集Job的状态信息，并管理Flink集群中从节点TaskManager。
TaskManager：1、实际负责执行计算的worker,在其上执行Flink Job的一组Task。2、TaskManager负责管理其所在节点上的资源信息，比如内存、磁盘、网络，在启动的时候将资源的状态向JobManager汇报。
Client：1、用户提交一个Flink程序时，会首先创建一个Client，该Client首先会对用户提交的Flink程序进行预处理，并提交到Flink集群。2、Client会将用户提交的Flink程序组装成一个JobGraph，并且是以JobGraph的形式提交的。
查看全部 -
flinl程序的基础构建块是流+转换，每个数据流始于一个或多个source、止于sink
env是flink的运行环境、上下文，然后消费获取kafka中的数据进行一系列转化操作，最后addsink将处理好的数据落地。
flink支持并行
查看全部 -
mark
查看全部 -
Flink课程大纲
查看全部 -
Flink的架构
查看全部 -
Flink的架构
查看全部 -
streams 流
transformations： map reduce
查看全部 -
Flink课程大纲
查看全部 -
窗口函数图解
查看全部 -
架构、容错
查看全部
举报
0/150
提交
取消