[發明專利]用于分布式處理平臺的統一客戶端

有效

• 申請號: 201611242433.3
• 申請日: 2016-12-29
• 公開（公告）號: CN107193854B
• 公開（公告）日: 2022-02-25
• 發明（設計）人: J.D.胡;A.麥克沙恩;A.阿卜杜勒拉赫曼;F.馬利;M.凱雷斯
• 申請（專利權）人: 商業對象軟件有限公司
• 主分類號: G06F16/182
• 分類號: G06F16/182;G06F9/54;G06F9/50
• 代理公司: 北京市柳沈律師事務所 11105
• 代理人: 邵亞麗

1.一種由運行應用的至少一個處理器執行的由計算機實現的方法，所述方法包括：

由所述至少一個處理器從應用訪問統一客戶端，所述統一客戶端包括多個子客戶端，每個子客戶端被配置為與包括多個子系統的分布式處理平臺的相應子系統接口；

由所述至少一個處理器通過所述統一客戶端為所述統一客戶端與所述分布式處理平臺中包括的多個子系統中的至少兩個子系統之間的通信建立單個會話，其中單個會話是統一會話，其至少包括:i)連接第一子客戶端和第一子系統的第一連接，以及ii)連接第二子客戶端和第二子系統的第二連接，其中在統一連接倉庫中描述的連接配對中第一連接與第二連接相關聯；并且

在所述單個會話期間，由所述至少一個處理器將所述應用與所述統一客戶端的第一子客戶端接口來請求所述分布式處理平臺的第一子系統執行至少一個第一數據處理操作，并且進行切換以將所述應用與統一客戶端的第二子客戶端接口以請求分布式處理平臺的第二子系統執行至少一個第二數據處理操作，所述切換基于將第一連接與第二連接相關聯的連接配對。

2.如權利要求1所述的方法，其中，第一和第二子客戶端通過公共接口互操作。

3.如權利要求1所述的方法，其中，所述第一和第二數據處理操作是由所述第一和第二子系統響應于來自所述第一和第二子客戶端的順序調用而串行執行的。

4.如權利要求1所述的方法，其中，所述第一和第二數據處理操作是由所述第一和第二子系統響應于來自所述第一和第二子客戶端的調用而并行執行的。

5.如權利要求1所述的方法，其中，所述第一和第二子客戶端是與作為所述分布式處理平臺的不同子系統的第一和第二子系統分別接口的不同類型的子客戶端。

6.如權利要求1所述的方法，其中，由第一子客戶端向第二子客戶端提供引用，所述引用指示由所述第一子系統執行的所述至少一個第一數據處理操作的結果。

7.如權利要求1所述的方法，其中，所述多個子客戶端包括以下各項中的一者或多者：

MapReduce客戶端，被配置為與MapReduce子系統接口；

Hive客戶端，被配置為與Hive引擎子系統接口；

Spark客戶端，被配置為與Spark引擎子系統接口；

SparkSQL客戶端，被配置為與SparkSQL子系統接口；或者

存儲客戶端，被配置為與存儲子系統接口。

8.如權利要求1所述的方法，其中，所述分布式處理平臺是Hadoop平臺。

9.一種系統，包括：

至少一個處理器；以及

通信地耦合到所述至少一個處理器的存儲器，所述存儲器存儲指令，所述指令當被所述至少一個處理器執行時使得所述至少一個處理器執行操作，所述操作包括：

從所述至少一個處理器所運行的應用訪問統一客戶端，所述統一客戶端包括多個子客戶端，每個子客戶端被配置為與包括多個子系統的分布式處理平臺的相應子系統接口；

通過所述統一客戶端為所述統一客戶端與所述分布式處理平臺中包括的多個子系統中的至少兩個子系統之間的通信建立單個會話，其中單個會話是統一會話，其至少包括:i)連接第一子客戶端和第一子系統的第一連接，以及ii)連接第二子客戶端和第二子系統的第二連接，其中在統一連接倉庫中描述的連接配對中第一連接與第二連接相關聯；并且

在所述單個會話期間，將所述應用與所述統一客戶端的第一子客戶端接口來請求所述分布式處理平臺的第一子系統執行至少一個第一數據處理操作，并且進行切換以將所述應用與統一客戶端的第二子客戶端接口以請求分布式處理平臺的第二子系統執行至少一個第二數據處理操作，所述切換基于將第一連接與第二連接相關聯的所述連接配對。

10.如權利要求9所述的系統，其中，第一和第二子客戶端通過公共接口互操作。