Microsoft Technology Licensing, LLC

Huawei Technologies Co., Limited

Ting Yu Cliff Leung

Liangzhao Zeng

Tao Li

Yat On Lau

Bing Zhou

Jimmy Hong

Wenwei Xue

Xiaoyang Gao

Yen-Ting Liu

Ting-Kuan Wu

Chuang Yao

Embodiments of the system in includes data set analytics to identify one or more dataset utilized by a workflow. The data set analytics identifies upstream data sets referenced by the data sets utilized by the workflow. The set of all data sets relevant to the workflow are considered applicable data sets, and are analyzed. The data set analytics determines a usage pattern of each of the applicable data sets by the workflow, and identifies one or more data quality assertions for each of the applicable of data sets based on the usage pattern. The data set analytics further perform a quality evaluation of the applicable data sets by applying data quality assertions to the applicable data sets used by the workflow.

Flow-based data quality monitoring

Embodiments maintain a data pool that includes heterogeneous data sets, and receiving a first data batch of a data set from a data source into the data pool. Embodiments determine a current state of the data set based on a data set state diagram including a plurality of data set states, and identify a condition of the first data batch. Embodiments further set a data batch state for the first data batch, based on a data batch state diagram, and update the data batch state of a prior data batch received before the first data batch, based on the condition of the first data batch. Embodiments additionally transition the data set state diagram, based on the condition of the first data batch, to an updated data set state. Embodiments maintain a data state repository storing the data set state for each of the plurality of heterogeneous data sets.

Event driven data health monitoring

A query processing method including decomposing an SQL into logical plans based on data source feature information, to obtain a logical plan set, where the data source feature information is stored in an internal storage space of the query engine; generating physical plans for the logical plan set based on the data source feature information, to obtain a physical plan set; determining query costs of the physical plan set based on the data source feature information, to obtain a physical plan with a highest priority; and executing the physical plan with the highest priority, to obtain a query result queried by a user.

Query processing method, data source registration method, and query engine

Embodiments of the system in include a memory that stores a metamodel including a plurality of predefined characteristics for data sets. A data repository stores a plurality of heterogeneous data sets, each of the plurality of data sets comprising a plurality of data batches received over time. An interface receives a new data set for storage into the data repository, and data health reasoner to retrieve the stored metamodel from the memory, the stored metamodel including a plurality of predefined characteristics. The data health reasoner determines measured values of a subset of the plurality of predefined characteristics identified based on the stored metamodel, and determines a set of data health metrics for the data set based on the measured values of the subset of the set of the predefined characteristics. The data health reasoner formulates a plurality of data validation assertions for the data set and apply the plurality of data validation assertions to each instance of the data set. A user interface receives a request from a service that consumes data from the data set, and provides the plurality of data validation assertions to the service with the data from the data set, wherein each of the plurality of heterogeneous data sets in the data repository have a plurality of data validation assertions derived from the stored meta-model.

Automated data health reasoning

A query processing method includes decomposing an SQL into logical plans based on data source feature information, to obtain a logical plan set, where the data source feature information is stored in an internal data source feature library of a query engine, and the internal data source feature library is stored in cache space of the query engine; generating physical plans for the logical plan set based on the data source feature information, to obtain a physical plan set; determining query costs of the physical plan set based on the data source feature information, to obtain a physical plan with a highest priority; and executing the physical plan with the highest priority, to obtain a query result queried by a user. A data source registration method and a query engine is further disclosed.

Growing community of inventors

San Jose, CA, United States of America

Ting Yu Cliff Leung