US 10,872,095 B2Granted

Aggregation framework system architecture and method

AssigneeMongoDB, Inc.

InventorsEliot Horowitz, David Lenox Storch, Charles William Swanson

Life of this patent

Estimating the term…

Loading patent…

Abstract

A system and computer implemented method for execution of aggregation expressions on a distributed non-relational database system is provided. According to an aspect, an operation is provided to perform the aggregation operation. An indication of at least one foreign collection of documents is accepted. An indication of at least one variable for at least one local field of at least one local collection of documents is accepted. An indication of a pipeline for execution on the at least one local collection of documents and the at least one foreign collection of documents is accepted. An operation comparing the local field of the at least one local collection of documents and the foreign field of the at least one foreign collection of documents is performed. Responsive to the operation, data from the at least one local collection of documents and the at least one foreign collection of documents is aggregated.

Claims24

Dependent claims

A computer implemented method for execution of aggregation expressions on a distributed non-relational database system, the method comprising the acts of:

executing, by a computer system, an aggregation operation, wherein the aggregation operation includes a plurality of data operations on a distributed non-relational database having a plurality of collections of documents including at least one local collection of documents and at least one foreign collection of documents;
providing an operation using the at least one local collection of documents and the at least one foreign collection of documents, wherein the operation performing the aggregation operation comprises the acts of:
accepting an indication of the at least one foreign collection of documents;
accepting an indication of at least one variable for at least one local field of the at least one local collection of documents;
accepting an indication of a pipeline for execution on the at least one local collection of documents and the at least one foreign collection of documents, wherein the indication of the pipeline includes:
an indication of at least one foreign field of the at least one foreign collection of documents;
an indication of the at least one variable for the at least one local field of the at least one local collection of documents, wherein referencing the at least one variable allows access to the at least one local field from the pipeline;
and
an indication of a comparison operation for comparing the at least one local field of the at least one local collection of documents and the at least one foreign field of the at least one foreign collection of documents;
performing the comparison operation comparing the at least one local field of the at least one local collection of documents and the at least one foreign field of the at least one foreign collection of documents;
and
aggregating data from the at least one local collection of documents and the at least one foreign collection of documents responsive to the comparison operation.

9 more elements

A distributed database system for execution of aggregation expressions on a distributed non-relational database system, the system comprising:

at least one processor operatively connected to a memory;
a distributed non-relational database having a plurality of collections of documents including at least one local collection of documents and at least one foreign collection of documents;
a component adapted to perform an operation using the at least one local collection of documents and the at least one foreign collection of documents, comprising:
means for accepting an indication of the at least one foreign collection of documents;
means for accepting an indication of at least one variable for at least one local field of the at least one local collection of documents;
means for accepting an indication of a pipeline for execution on the at least one local collection of documents and the at least one foreign collection of documents, wherein the indication of the pipeline includes:
an indication of at least one foreign field of the at least one foreign collection of documents;
an indication of the at least one variable for the at least one local field of the at least one local collection of documents, wherein referencing the at least one variable allows access to the at least one local field from the pipeline;
and
an indication of a comparison operation for comparing the at least one local field of the at least one local collection of documents and the at least one foreign field of the at least one foreign collection of documents;
means for performing the comparison operation comparing the at least one local field of the at least one local collection of documents and the at least one foreign field of the at least one foreign collection of documents;
and
means for aggregating data from the at least one local collection of documents and the at least one foreign collection of documents responsive to the comparison operation.

10 more elements

A computer implemented method for execution of aggregation expressions on a distributed non-relational database system, the method comprising the acts of:

receiving, by a computer system, an operation referencing at least one local collection of documents and at least one foreign collection of documents, wherein the operation comprises the acts of:
accepting an indication of a pipeline for execution on the at least one local collection of documents and the at least one foreign collection of documents, wherein the indication of the pipeline includes an indication of a comparison operation for comparing at least one local field of the at least one local collection of documents and at least one foreign field of the at least one foreign collection of documents;
performing the comparison operation comparing the at least one local field of the at least one local collection of documents and the at least one foreign field of the at least one foreign collection of documents;
and
aggregating data from the at least one local collection of documents and the at least one foreign collection of documents responsive to the comparison operation.

2 more elements

Dependencies are inferred from the claim text.

Facts

Application: 16/013,720Filed 20 Jun 2018 · continuation in part
Priority: 26 Jul 2012
Published: US 2018/0300381 A118 Oct 2018
Granted: 22 Dec 2020
Term ends: Not estimatedThe source records don’t support an estimate.

Classification11 codes

G06F 16/258
Integrating or interfacing systems involving database management systems: data format conversion from or to a database
G06F 16/23
Of structured data, e.g. relational data: updating
G06F 16/24556
Unary operations; Data partitioning operations: aggregation; Duplicate elimination
G06F 16/2471
Special types of queries, e.g. statistical queries, fuzzy queries or distributed queries: distributed queries

Family

Application61/676,188Us provisional application · filed 26 Jul 2012
Application13/794,710Parent of this continuation-in-part · filed 11 Mar 2013
Application13/794,710Parent of this continuation · filed 11 Mar 2013
Application13/951,987Parent of this continuation · filed 26 Jul 2013
Application14/672,901Parent of this continuation-in-part · filed 30 Mar 2015
Application15/042,297Parent of this continuation-in-part · filed 12 Feb 2016
Application62/341,511Us provisional application · filed 25 May 2016
Application62/341,490Us provisional application · filed 25 May 2016
Application15/604,879Parent of this continuation-in-part · filed 25 May 2017
Application15/605,391Parent of this continuation · filed 25 May 2017
Application15/605,391Parent of this continuation-in-part · filed 25 May 2017
Application62/522,540Us provisional application · filed 20 Jun 2017
Application62/522,150Us provisional application · filed 20 Jun 2017
US 2018/0300381 A1Pre-grant publication · published 18 Oct 2018
US 10,031,956 B2Parent of this continuation-in-part
US 9,262,462 B2Parent of this continuation
Application15/042,297Parent of this continuation
US 8,996,463 B2Parent of this continuation-in-part
Application13/951,987Parent of this continuation-in-part
US 9,792,322 B2Parent of this continuation-in-part
US 8,996,463 B2Parent of this continuation
Application14/672,901Parent of this continuation
US 10,366,100 B2Parent of this continuation
US 11,544,284 B2Related patent
US 2014/0032525 A1Published application
US 2014/0032579 A1Published application
US 2015/0278295 A1Published application
US 2016/0246861 A1Published application
US 2017/0262516 A1Published application
US 2017/0286510 A1Published application
US 10,872,095 B2This patent

From the US filing history. Foreign family members aren’t listed.

Timeline

Citations

Open elsewhere

Building an agent or pulling many patents? Use the API or MCP server instead of scraping pages. Get an API key