开发者社区> 问答> 正文

在OneSQL平台上,Flink作为OLAP分析引擎是如何工作的?

在OneSQL平台上,Flink作为OLAP分析引擎是如何工作的?

展开
收起
真的很搞笑 2024-07-22 22:36:43 35 0
2 条回答
写回答
取消 提交回答
  • "在OneSQL平台上,Flink作为OLAP分析引擎的工作流程如下:

    SQL提交:用户通过SQL Gateway提交SQL查询。
    结果持久化判断:Gateway判断是否需要将结果持久化到Hive表,若需要则通过HiveCatalog接口创建Hive表。
    SQL解析与提交:在Gateway上进行SQL解析,设置作业并行度,生成Pipeline并提交到Flink Session集群执行。
    结果返回:执行完成后,将结果返回给客户端。"

    2024-07-23 09:50:48
    赞同 1 展开评论 打赏
  • 用户通过 Hue 页面提交的 SQL,通过 OneSQL 后端转发给 Flink SQL Gateway,并提交到 Flink Session 集群上执行查询任务,Flink SQL Gateway 获取查询任务的执行进度返回给 Hue 页面,并返回查询结果。

    image.png

    参考文档https://flink-learning.org.cn/article/detail/5e1346050125d69fc226d1069e4d5652?name=article&tab=suoyou&page=19

    2024-07-23 09:22:19
    赞同 1 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
基于云原生数据仓库AnalyticDB PG的最佳实践 立即下载
新氧云原生全栈数仓最佳实践 立即下载
离线实时一体化数仓与湖仓一体—云原生大数据平台的持续演进 立即下载