(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202210629979.3 (22)申请日 2022.06.06 (65)同一申请的已公布的文献号 申请公布号 CN 114721746 A (43)申请公布日 2022.07.08 (73)专利权人 杭州玳数 科技有限公司 地址 310000 浙江省杭州市余杭区仓前街 道余杭塘路2301号海智中心8幢102 室-5 (72)发明人 汤恭姜　陈吉平　 (74)专利代理 机构 杭州裕阳联合专利代理有限 公司 33289 专利代理师 杨琪宇 (51)Int.Cl. G06F 9/445(2018.01) G06F 8/65(2018.01)(56)对比文件 CN 114579589 A,202 2.06.03 CN 111124535 A,2020.0 5.08 CN 109815283 A,2019.0 5.28 CN 112612545 A,2021.04.0 6 WO 20202 28838 A1,2020.1 1.19 Isaac.prestosql/dots/Presto 二开开发环 境搭建.md. 《ht tps://github.com/ thestyleofme/prestosql/bl ob/dynamic - catalog-zk3.4.x/docs/Presto 二开开发环境搭 建.md》 .2020, xiaoping_1988.presto热加载catal og配 置. 《https://blog.csdn.net/xiaopi ng_1988/ article/detai ls/122198309》 .2021, A. Zee.Fearful Sym metry: The Searc h for Beauty i n Modern Physics. 《IE EE》 .2017, 董璇等.网格环境下集群管理系统. 《计算机 工程与设计》 .20 07,(第22期), 审查员 辛小霞 (54)发明名称 一种Trino catalog热加载 方法和系统 (57)摘要 本发明公开了一种Trino  catalog热加载方 法和系统， 方法包括： 通过trino集群提供 catalog resource， 所述catalog  resource提供 了catalog  restful接口； 配置用户catalog参 数， 并通过所述catalog  restful接口发送给所 述catalog  resource， 通过所述catalog   resource判断是否开启热加载功能功能； 若 开启 热加载功能则将配置的用户catalog参数通过内 部restful接口发送给内部集群节点； 集群管理 器在Discovery上创建或删除永久catalog   service； 节点管理器 定时更新catal og实例。 权利要求书2页 说明书6页 附图1页 CN 114721746 B 2022.09.09 CN 114721746 B 1.一种Tri no catalog热加载 方法， 其特 征在于， 所述方法包括： 通过trino集群提供catalog  resource， 所述catalog  resource提供了catalog   restful接口； 配置用户catalog参数， 并通过所述catalog  restful接口发送给所述catalog   resource， 通过 所述catal og resource判断是否开启热加载功能； 若开启热加载功能则将配置的用户catalog参数通过内部restful接口发送给内部 Trino 集群节点； 构建catalog集群管理器， 所述catalog集群管理器根据不同catalog请求在Discovery 上创建或删除永久 catalog service； 构建catalog节点管理器， 所述catalog节点管理器配置于每一个Trino节点， 通过所述 catalog节点管理器定时更新每 个Trino节点的catal og service实例。 2.根据权利要求1所述的一种Trino  catalog热加载方法， 其特征在于， 其中通过所述 catalog resource判断是否开启热加载功能的方法包括： 获取Trino集群的属性配置文件， 并在所述属性配置文件中配置热加载配置参数， 根据所述热加载配置参数的值判断是否开 启热加载功能， 并将需要热加载的catalog集群管 理器、 catalog节 点管理器进行初始化， 否 则通过catal og resource拦截外 部请求。 3.根据权利要求1所述的一种Trino  catalog热加载方法， 其特征在于， 所述catalog请 求包括添加catalog请求、 修改catalog请求和删除catalog请求， 所述catalog集群管理器 识别添加catalog请求和修改catalog请求后在Discovery上创建一个临时catalog   service实例， 所述临时catalog  service实例包括Di scovery上保存的临时catalog配置信 息， 当Discovery重启时， 所述临时catal og service实例自动消失。 4.根据权利要求3所述的一种Trino  catalog热加载方法， 其特征在于， 若当前catalog 请求为添加catalog请求， 所述catalog集群管理器识别添加catalog请求中的catalog配 置， 并将所述catalog配置传输到Discovery上生成临时catalog  service实例， 配置 catalog添加成功规则， 其中所述catalog添加成功规则包括至少一个catalog管理节点成 功添加catalog或至少一半的worker节点成功添加catalog， 则在Discovery上创建永久 catalog service实例， 删除Di scovery上创建的临时catalog  service实例， 并将所述永久 catalog service实例序列化到本地数据库， 否则直接删除Discovery上创建的临时 catalog service实例。 5.根据权利要求3所述的一种Trino  catalog热加载方法， 其特征在于， 若当前catalog 请求为修改catalog请求， 所述catalog集群管理器识别修改catalog请求中的catalog配 置， 并将所述catalog配置传输到Discovery上生成临时catalog  service实例， 配置修改 catalog成功规则， 其中所述修改catalog成功规则包括： 若存在至少一个catalog管 理节点 成功修改catalog或至少一半的worker节点成功修改catalog， 则在Discovery上创建永久 catalog service实例， 删除Di scovery上创建的临时catalog  service实例， 并将所述永久 catalog service实例序列化到本地数据库， 否则直接删除Discovery上创建的临时 catalog service实例。 6.根据权利要求3所述的一种Trino  catalog热加载方法， 其特征在于， 若所述catalog 请求为catalog删除请求， 首先通过所述catalog集群管理器在Discovery上删除永久权　利　要　求　书 1/2 页 2 CN 114721746 B 2catalog service实例， 进一步通过所述catalog集群管理器向所有Trino节点发送catalog 删除请求， 配置删除成功规则： 若所有catalog管 理节点的catalog删除成功， 则表 示删除成 功， 否则重新向Discovery发送请求建立 新的永久 catalog service实例。 7.根据权利要求1所述的一种Trino  catalog热加载方法， 其特征在于， 所述catalog节 点管理器定时从Discovery中获取catalog  service信息， 并将 获取的catalog  service信 息和Trino节点内存中的catalog  service实例进行对比， 若存在多个相同名字的catalog   service， 则将最 新的catal og service作为catal og配置。 8.根据权利要求1所述的一种Trino  catalog热加载方法， 其特征在于， 若所述catalog 节点管理器定时从Discovery中获取catalog  service信息中存在Trino节点内存中不存在 或未更新catalog配置信息， 则进一步根据所述catalog  service信息对所述Trino节点内 存进行catal og实例添加或更新。 9.一种Trino  catalog热加载系统， 其特征在于， 所述系统执行权利要求1 ‑8中任意一 项所述的一种Tri no catalog热加载 方法。 10.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质存储有计算机程 序， 所述计算机程序可被处理器执行权利要求1 ‑8中任意一项所述的一种Trino  catalog热 加载方法。权　利　要　求　书 2/2 页 3 CN 114721746 B 3