公开(公告)号：US20150169757A1

公开(公告)日：2015-06-18

申请号：US14105078

申请日：2013-12-12

Applicant: Netflix, Inc.

Inventor： Christos Kalantzis ,  Shyam Singh

IPC: G06F17/30

CPC classification number: G06F17/30569 ,  G06F17/30297

Abstract: In an embodiment, a method comprises receiving an input defining organization of one or more universal data elements; generating a universal schema that defines organization of the one or more universal data elements based on the input; associating the universal schema with a specialized plug-in, wherein the specialized plug-in maps the one or more universal data elements with data elements in one or more specialized databases maintained by a specialized data store; receiving, from a computer, a request to receive data stored in the specialized data store and comprising parameters based on the universal schema; transforming the request using the specialized plug-in to produce a specialized query; sending the specialized query to the specialized data store to execute the specialized query; receiving a specialized result set from the specialized data store; sending, to the computer, a result set based on specialized result set.

Abstract translation: 在一个实施例中，一种方法包括接收一个或多个通用数据元素的输入定义组织; 生成基于所述输入来定义所述一个或多个通用数据元素的组织的通用模式; 将通用模式与专用插件相关联，其中专用插件将一个或多个通用数据元素与由专门数据存储器维护的一个或多个专用数据库中的数据元素进行映射; 从计算机接收接收存储在专门数据存储器中的数据的请求，并且包括基于通用模式的参数; 使用专用插件转换请求以产生专门的查询; 将专门的查询发送到专门的数据存储，执行专门的查询; 从专门的数据存储接收专门的结果集; 向计算机发送基于专门的结果集的结果集。

公开(公告)号：US11789926B2

公开(公告)日：2023-10-17

申请号：US14987649

申请日：2016-01-04

Applicant: NETFLIX, INC.

Inventor： Ioannis Papapanagiotou ,  Shailesh Birari ,  Jason Cacciatore ,  Minh Do ,  Christos Kalantzis

IPC: G06F16/23 ,  G06F16/11 ,  G06F16/174 ,  G06F16/178 ,  G06F11/14 ,  H04L9/40

CPC classification number: G06F16/2365 ,  G06F11/1451 ,  G06F16/128 ,  G06F16/178 ,  G06F16/1744 ,  H04L63/0428 ,  G06F2201/835 ,  G06F2201/84

Abstract: In one embodiment, a data reconciliation engine works with data store nodes included in a distributed data store system to ensure consistency between the data store nodes. In operation, the data reconciliation receives a different data snapshot from each of the data store nodes. In response, the data reconciliation engine generates one or more recommendations designed to resolve inconsistencies between the data snapshots. The data reconciliation engine then transmits each recommendation to a different data store node. Because the data reconciliation engine performs many of the resource-intensive operations included in the data reconciliation process, the resources of the data store nodes may focus primarily on processing client requests instead of performing data reconciliation operations. Consequently, unlike conventional data store node based reconciliation applications, the data reconciliation engine may process large volumes of data without unacceptably increasing the time required for the distributed data store system to respond to client requests.

公开(公告)号：US10749921B2

公开(公告)日：2020-08-18

申请号：US15379299

申请日：2016-12-14

Applicant: NETFLIX Inc.

Inventor： Ioannis Papapanagiotou ,  Shailesh Birari ,  Jason Cacciatore ,  Minh Do ,  Christos Kalantzis

IPC: H04L29/08 ,  G06F11/14 ,  H04L29/06 ,  H04L12/861 ,  G06F16/25

Abstract: In various embodiments, a node manager configures a “new” node as a replacement for an “unavailable” node that was previously included in a distributed data store. First, the node manager identifies a source node that stores client data that was also stored in the unavailable node. Subsequently, the node manager configures the new node to operate as a slave of the source node and streams the client data from the source node to the new node. Finally, the node manager configures the new node to operate as one of multiple masters nodes in the distributed data store. Advantageously, by configuring the node to implement a hybrid of a master-slave replication scheme and a master-master replication scheme, the node manager enables the distributed data store to process client requests without interruption while automatically restoring the previous level of redundancy provided by the distributed data store.

公开(公告)号：US09430539B2

公开(公告)日：2016-08-30

申请号：US14105078

申请日：2013-12-12

Applicant: Netflix, Inc.

Inventor： Christos Kalantzis ,  Shyam Singh

IPC: G06F7/00 ,  G06F17/30

CPC classification number: G06F17/30569 ,  G06F17/30297

Abstract: In an embodiment, a method comprises receiving an input defining organization of one or more universal data elements; generating a universal schema that defines organization of the one or more universal data elements based on the input; associating the universal schema with a specialized plug-in, wherein the specialized plug-in maps the one or more universal data elements with data elements in one or more specialized databases maintained by a specialized data store; receiving, from a computer, a request to receive data stored in the specialized data store and comprising parameters based on the universal schema; transforming the request using the specialized plug-in to produce a specialized query; sending the specialized query to the specialized data store to execute the specialized query; receiving a specialized result set from the specialized data store; sending, to the computer, a result set based on specialized result set.

Abstract translation: 在一个实施例中，一种方法包括接收一个或多个通用数据元素的输入定义组织; 生成基于所述输入来定义所述一个或多个通用数据元素的组织的通用模式; 将通用模式与专用插件相关联，其中专用插件将一个或多个通用数据元素与由专门数据存储器维护的一个或多个专用数据库中的数据元素进行映射; 从计算机接收接收存储在专门数据存储器中的数据的请求，并且包括基于通用模式的参数; 使用专用插件转换请求以产生专门的查询; 将专门的查询发送到专门的数据存储，执行专门的查询; 从专门的数据存储接收专门的结果集; 向计算机发送基于专门的结果集的结果集。