Granted Patent B1

US 12,393,608 · App. 18/673,931 · Granted Aug 19, 2025

Inventor: Jiyue Ma (Hangzhou, CN)

Assignee: Zoom Communications, Inc.

G06F16/278G06F16/2433

Abstract

Claims (42)

1. A method, comprising:

communicating a request, from a driver node to a metastore manager, for initiating, in association with a data set maintained in a first data store associated with a first data management platform, a first data processing operation, to be performed by the first data management platform, to generate a first processed data set, wherein the first processed data set is stored in the first data store, and wherein a first metadata set corresponding to the first processed data set is stored in a first metastore associated with the first data store, the first metadata set comprising partition metadata indicative of partitioning information associated with the first processed data set, wherein the metastore manager is configured to:

obtain a directed acyclic graph (DAG) corresponding to the first data processing operation; and

configure the first data processing operation in association with the DAG, wherein the DAG includes an unresolved logical plan, a logical plan, and an optimized logical plan;

initiating, by the metastore manager, a synchronization operation to store, in a second metastore associated with a second data management platform, a second metadata set corresponding to a subset of the first metadata set; and

activating, by the metastore manager, a data processing pipeline that is not communicatively coupled with the first data management platform wherein the data processing pipeline includes an artificial intelligence (AI) pipeline, to cause the data processing pipeline to obtain the partition metadata using a refresh component, and wherein the data processing pipeline is configured to:

obtain, based on the partition metadata, the first processed data set;

perform a second data processing operation on the first processed data set to generate a second processed data set, wherein the second processed data set comprises an output of an AI operation; and

output the second processed data set to a unified communications as a service (UCaaS) platform.

2. The method of claim 1 , wherein the data processing pipeline is communicatively coupled, via a platform interface, with the second data management platform.

3. The method of claim 1 , wherein the data processing pipeline is communicatively coupled, via a platform interface, with only the second data management platform.

4. The method of claim 1 , wherein the first data processing operation comprises a structured query language (SQL) query on a distributed database associated with at least one of the first data store or a second data store associated with the second metastore.

5. The method of claim 1 , further comprising configuring the first data processing operation at least in part by allocating a set of computational resources for the first data processing operation.

6. A non-transitory computer-readable medium storing instructions operable to cause one or more processors to perform operations comprising:

communicating a request, from a driver node to a metastore manager, for initiating, in association with a data set maintained in a first data store associated with a first data management platform, a first data processing operation, to be performed by the first data management platform, to generate a first processed data set, wherein the first processed data set is stored in the first data store, and wherein a first metadata set corresponding to the first processed data set is stored in a first metastore associated with the first data store, the first metadata set comprising partition metadata indicative of partitioning information associated with the first processed data set, wherein the metastore manager is configured to:

obtain a directed acyclic graph (DAG) corresponding to the first data processing operation; and

configure the first data processing operation in association with the DAG, wherein the DAG includes an unresolved logical plan, a logical plan, and an optimized logical plan;

initiating, by the metastore manager, a synchronization operation to store, in a second metastore associated with a second data management platform, a second metadata set corresponding to a subset of the first metadata set; and

activating, by the metastore manager, a data processing pipeline that is not communicatively coupled with the first data management platform wherein the data processing pipeline includes an artificial intelligence (AI) pipeline, to cause the data processing pipeline to:

obtain the partition metadata using a refresh component, and wherein the data processing pipeline is configured to:

obtain, based on the partition metadata, the first processed data set;

perform a second data processing operation on the first processed data set to generate a second processed data set, wherein the second processed data set comprises an output of an AI operation; and

output the second processed data set to a unified communications as a service (UCaaS) platform.

7. The non-transitory computer-readable medium of claim 6 , wherein the data processing pipeline is configured to obtain the first processed data set via a platform interface that connects the data processing pipeline with only the second data management platform.

8. The non-transitory computer-readable medium of claim 6 , wherein the first data processing operation comprises a structured query language (SQL) query on a distributed database associated with at least one of the first data store or a second data store associated with the second metastore.

9. The non-transitory computer-readable medium of claim 6 , the operations further comprising allocating a set of computational resources for the first data processing operation.

10. A system, comprising:

one or more memories; and

one or more processors configured to execute instructions stored in the one or more memories to:

communicating a request, from a driver node to a metastore manager, for initiating, in association with a data set maintained in a first data store associated with a first data management platform, a first data processing operation, to be performed by the first data management platform, to generate a first processed data set, wherein the first processed data set is stored in the first data store, and wherein a first metadata set corresponding to the first processed data set is stored in a first metastore associated with the first data store, the first metadata set comprising partition metadata indicative of partitioning information associated with the first processed data set, wherein the metastore manager is configured to:

obtain a directed acyclic graph (DAG) corresponding to the first data processing operation; and

configure the first data processing operation in association with the DAG, wherein the DAG includes an unresolved logical plan, a logical plan, and an optimized logical plan;

initiate, by the metastore manager, a synchronization operation to store, in a second metastore associated with a second data management platform, a second metadata set corresponding to a subset of the first metadata set; and

activate, by the metastore manager, a data processing pipeline that is not communicatively coupled with the first data management platform wherein the data processing pipeline includes an artificial intelligence (AI) pipeline, to cause the data processing pipeline to obtain the partition metadata using a refresh component, and wherein the data processing pipeline is configured to:

obtain, based on the partition metadata, the first processed data set;

perform a second data processing operation on the first processed data set to generate a second processed data set, wherein the second processed data set comprises an output of an AI operation; and

output the second processed data set to a unified communications as a service (UCaaS) platform.

11. The system of claim 10 , further comprising a platform interface that communicatively couples the data processing pipeline with the second data management platform.

12. The system of claim 10 , further comprising a platform interface that communicatively couples the data processing pipeline with only the second data management platform.

13. The system of claim 10 , further comprising a platform interface that communicatively couples the first data management platform with the second data management platform.

14. The system of claim 10 , further comprising a platform interface that communicatively couples the data processing pipeline with a unified communications as a service (UCaaS) platform.

15. The system of claim 10 , wherein the second data management platform comprises a metastore manager configured to manage access, by the data processing pipeline, to the first data store.

Assignments (2)

References Cited (16)