博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Flink1.6系列之—Component Stack概述
阅读量:5032 次
发布时间:2019-06-12

本文共 446 字,大约阅读时间需要 1 分钟。

 

Flink作为一个软件栈,是一个分层系统。栈的不同层相互叠加,并提高它们接受的程序表示的抽象级别:

  • 运行时(runtime)层以JobGraph的形式接收程序。JobGraph是一个通用的并行数据流,其中包含消费数据流和生成数据流的任务。
  • DataStream API和DataSet API都可以通过各自的编译过程生成JobGraphs。DataSet API使用优化器(optimizer)来确定程序的最佳计划,而DataStream API使用流构建器(stream builder)。
  • JobGraph是根据Flink中可用的各种部署选项执行的(例如,本地(local)、远程(remote)、YARN等)。
  • 与Flink绑定的库和API生成DataSet或者DataStream API程序。这些表用于执行逻辑表上的查询,FlinkML用于机器学习,Gelly用于图处理。

 

转载于:https://www.cnblogs.com/dreamfor123/p/9545601.html

你可能感兴趣的文章
Linux内核调试技术——jprobe使用与实现
查看>>
ubuntu设计文件权限
查看>>
http://lorempixel.com/ 可以快速产生假图
查看>>
第一次独立上手多线程高并发的项目的心路历程
查看>>
ServiceStack 介绍
查看>>
Centos7下载和安装教程
查看>>
无谓的通宵加班之后的思索
查看>>
S1的小成果:MyKTV系统
查看>>
从setting文件导包
查看>>
编写一个函数isMerge,判断一个字符串str是否可以由其他两个字符串part1和part2“组合”而成...
查看>>
Github 开源:使用控制器操作 WinForm/WPF 控件( Sheng.Winform.Controls.Controller)
查看>>
PMD使用提醒
查看>>
Codeforces 887D Ratings and Reality Shows
查看>>
论文《A Generative Entity-Mention Model for Linking Entities with Knowledge Base》
查看>>
Linux记录-salt分析
查看>>
Android Studio默认快捷键
查看>>
函数式编程与参数
查看>>
SSAS使用MDX生成脱机的多维数据集CUB文件
查看>>
HDU 2191 【多重背包】
查看>>
51nod 1433 0和5【数论/九余定理】
查看>>