FlinkSqlGateway源码研究
发布时间
阅读量：
阅读量
Flink Sql Gateway作为Flink集群的“任务网关”，具备通过REST API接口提交查询、插入以及删除等各类任务的功能。
官网推荐与Flink jdbc driver搭配使用，不过jdbc driver限制了很多功能，如果自己开发数据平台，最好还是直接使用sql gateway。想要透彻的使用sql gateway，需要了解一下问题：
1 如何处理并发请求？多个提交怎么处理？
2 如何维护多个sql之间的关联性？
3 sql字符串如何提交到集群形成代码
4 sql-gateway都支持哪些功能？
1. 整体架构
从内部结构来看，Sql Gateway本质上由两个核心组件构成：其一是负责会话管理的SessionManager，其二是提供网络服务功能的SqlGatewayEndpoint服务器。
全部评论 (0)
还没有任何评论哟~