首页 未命名正文

Apache Flink 1.6 Documentation: Component Stack

helight0 未命名 2018-08-14 52 0 kafka

Component Stack 组件栈

作为一个软件栈,Flink是一个分层设计的系统。不同的层基于底层创建,不断提升程序表现的抽象。
  • 运行时层接受JobGraph 形式的程序,一个JobGraph 是一个通用的并行数据流,它具有消费和生产数据流的任意任务。
  • DataStream的API和DataSet的API都通过独立的编译过程生成JobGraphs。DataSet的API用一个优化程序来确定程序的优化计划,而DataStream的API使用流构建器
  • 根据Flink中各种不同部署参数来执行JobGraph(例如:local,remote,YAEN等等)
  • 和Flink所带的库和APIs可以生成DataSet或DataStream的API程序。包括针对逻辑表查询的Table,针对机器学习的FlinkML,和用于图处理的Gelly。
你可以点击下图中的组件来了解更多信息。
Apache Flink: Stack

版权声明

本文仅代表作者观点,不代表本站立场。
本文系作者授权发表,未经许可,不得转载。

评论