作为一个软件堆栈,Flink是一个分层的系统。堆栈的不同层构建在彼此之上,并提高程序表示的抽象级别:

  • 在runtime层以JobGraph的形式接受一个程序。JobGraph是一个通用的并行数据流,包含有消耗和生成数据流的任意个任务。
  • DataStream API 和 DataSet API 通过单独的编程过程生成 JobGraphs。
  • JobGraph根据Flink中提供的各种部署选项 (local/standlone/yarn) 执行。
  • 捆绑在Flink中的库和API生成 DataSet 或 DataStream API 程序。Apache Flink - Component Stack

相关文章:

  • 2022-02-05
  • 2021-06-06
  • 2021-11-28
  • 2021-12-23
  • 2021-04-15
  • 2021-08-24
  • 2021-06-16
  • 2021-07-30
猜你喜欢
  • 2021-05-23
  • 2021-04-29
  • 2021-03-26
  • 2022-12-23
  • 2022-01-09
  • 2021-10-21
相关资源
相似解决方案