在OneSQL平台上,Flink作为OLAP分析引擎是如何工作的?
"在OneSQL平台上,Flink作为OLAP分析引擎的工作流程如下:
SQL提交:用户通过SQL Gateway提交SQL查询。
结果持久化判断:Gateway判断是否需要将结果持久化到Hive表,若需要则通过HiveCatalog接口创建Hive表。
SQL解析与提交:在Gateway上进行SQL解析,设置作业并行度,生成Pipeline并提交到Flink Session集群执行。
结果返回:执行完成后,将结果返回给客户端。"
用户通过 Hue 页面提交的 SQL,通过 OneSQL 后端转发给 Flink SQL Gateway,并提交到 Flink Session 集群上执行查询任务,Flink SQL Gateway 获取查询任务的执行进度返回给 Hue 页面,并返回查询结果。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。