当前位置: 首页 > news >正文

基于最新的Apache StreamPark搭建指南

一、StreamPark 的介绍

官方文档:Apache StreamPark (incubating) | Apache StreamPark (incubating)

中文文档:Apache StreamPark (incubating) | Apache StreamPark (incubating)
Github地址:https://github.com/apache/incubator-streampark

Apache StreamPark™ 是一个流处理应用程序开发管理框架,旨在轻松构建和管理流处理应用程序,提供使用 Apache Flink® 和 Apache Spark™ 编写流处理应用的开发框架和一站式实时计算平台,核心能力包括不限于应用开发、部署、管理、运维、实时数仓等。

为什么要使用 StreamPark 呢?

它降低了学习成本和开发障碍,开发人员可以专注于业务逻辑。

另外,在部署阶段,企业可能很难在没有专业管理平台的情况下使用 Apache Flink 和 Apache Spark。StreamPark提供了一个专业的任务管理平台来满足这一需求.

二、体系架构

两个部分,streampark-corestreampark-console

1. streampark-core

streampark-core 定位是一个开发时框架,关注编码开发,规范了配置文件,按照约定优于配置的方式进行开发,提供了一个开发环境的 RuntimeContext 和一系列开箱即用的连接器,扩展了 DataStream 相关的方法,融合了 DataStreamFlink SQL API,简化繁琐的操作、聚焦业务本身,提高开发效率和开发体验。

2. streampark-console

streampark-console 是一个综合实时数据平台、低代码平台,可以较好的管理 Flink 任务,集成了项目编译、发布、参数配置、启动、保存点、火焰图、Flink SQL

http://www.lryc.cn/news/501333.html

相关文章:

  • 思科模拟器路由器的基本配置
  • vue3 computed watch 拓展reduce函数
  • MyBatis 中 SQL 片段复用
  • 【实操GPT-SoVits】声音克隆模型图文版教程
  • 用HTML和CSS实现3D圣诞树效果
  • Burp入门(10)-IP伪造插件
  • Mac软件推荐
  • 实验14 RNN的记忆能力和梯度爆炸实验
  • LeetCode面试题04 检查平衡性
  • oracle归档模式下的快速热备方法-适合小库
  • 【机器学习】【分子属性预测】——python读取.tar.gz文件(以OC22数据集为例)
  • Qt中禁止或管理任务栏关闭窗口的行为
  • docker的网络类型和使用方式
  • 二维立柱图|积水类问题
  • vue前端实现导出页面为word(两种方法)
  • 22. Three.js案例-创建旋转的圆环面
  • Elasticsearch:使用阿里 infererence API 及 semantic text 进行向量搜索
  • Linux WEB服务器的部署及优化
  • 人工智能大模型LLM开源资源汇总(持续更新)
  • 目标跟踪算法:SORT、卡尔曼滤波、匈牙利算法
  • Java版-图论-拓扑排序与有向无环图
  • GTC2024 回顾 | 优阅达携手 HubSpot 亮相上海,赋能企业数字营销与全球业务增长
  • eclipse启动的时候,之前一切很正常,但突然报Reason: Failed to determine a suitable driver class的解决
  • _tkinter.TclError: can‘t find package tkdnd Unable to load tkdnd library.解决办法
  • VBA高级应用30例应用在Excel中的ListObject对象:向表中添加注释
  • folly库Conv类型转换源码解析
  • UE4 骨骼网格体合并及规范
  • Java版企业电子招标采购系统源业码Spring Cloud + Spring Boot +二次开发+ MybatisPlus + Redis
  • 通过源码⼀步⼀步分析 ArrayList 扩容机制
  • 源码分析之Openlayers中默认Controls控件渲染原理