公开(公告)号：US08893131B2

公开(公告)日：2014-11-18

申请号：US12101443

申请日：2008-04-11

Applicant: Raghu Ramakrishnan ,  Erik Vee ,  Ramana Yerneni ,  Utkarsh Srivastava ,  Brian Frank Cooper ,  Adam Silberstein

Inventor： Raghu Ramakrishnan ,  Erik Vee ,  Ramana Yerneni ,  Utkarsh Srivastava ,  Brian Frank Cooper ,  Adam Silberstein

IPC: G06F9/46 ,  G06F15/16 ,  G06F7/00 ,  G06F17/30 ,  G06F9/50

CPC classification number: G06F17/30339 ,  G06F9/505 ,  G06F9/5083

Abstract: In a large-scale transaction such as the bulk loading of new records into an ordered, distributed database, a transaction limit such as an insert limit may be chosen, partitions on overfull storage servers may be designated to be moved to underfull storage servers, and the move assignments may be based, at least in part on the degree to which a storage server is underfull and the move and insertion costs of the partitions to be moved.

Abstract translation: 在大规模交易中，例如将新记录批量加载到有序的分布式数据库中，可以选择诸如插入限制的交易限制，可以指定过度存储服务器上的分区被移动到不充分的存储服务器，以及 移动分配可以至少部分地基于存储服务器欠充电的程度以及要移动的分区的移动和插入成本。

公开(公告)号：US08489674B2

公开(公告)日：2013-07-16

申请号：US12722411

申请日：2010-03-11

Applicant: Utkarsh Hriday Srivastava ,  Benjamin Clay Reed ,  Yang Zhang ,  Erwin Sing Tam ,  Brian Frank Cooper

Inventor： Utkarsh Hriday Srivastava ,  Benjamin Clay Reed ,  Yang Zhang ,  Erwin Sing Tam ,  Brian Frank Cooper

IPC: G06F15/16

CPC classification number: G06Q50/00 ,  G06Q10/00 ,  H04L51/00

Abstract: In one embodiment, a first one of a plurality of message processors receives a request with respect to a topic, and determines whether the first message processor itself is currently responsible for the topic. If so, then the first message processor services the request. If not, then the first message processor determines whether any of the other ones of the message processors is currently responsible for the topic. If so, then the request is redirected to another message processor to be serviced. If not, then the first message processor selects one of the message processors to be responsible for the topic and to service the request.

Abstract translation: 在一个实施例中，多个消息处理器中的第一个接收关于主题的请求，并且确定第一消息处理器本身当前是否负责该主题。 如果是这样，则第一个消息处理器服务该请求。 如果不是，则第一消息处理器确定消息处理器中的任何一个消息处理器当前是否负责该主题。 如果是这样，那么请求被重定向到另一个消息处理器进行服务。 如果不是，则第一消息处理器选择一个消息处理器来负责该主题并服务该请求。

公开(公告)号：US10275347B2

公开(公告)日：2019-04-30

申请号：US12719510

申请日：2010-03-08

Applicant: Brian Frank Cooper

Inventor： Brian Frank Cooper

IPC: G06F12/00 ,  G06F12/08 ,  G06F16/00

Abstract: Methods, systems and computer program products are provided for managing at least one cache for a database. In one method, an operation record is inserted in an operations log for each write operation to the database. The operation record includes a Log Sequence Number (LSN). At least one cache is updated using operation records in the operations log. To update a cache, unapplied operations in the operations log for the cache are identified using an applied LSN associated with the cache. The applied LSN denotes an LSN of a last operation applied to the cache. The unapplied operations are then applied to the cache and the applied LSN is updated with an LSN corresponding to the last unapplied operation of the unapplied operations that were applied to the cache during updating the cache.

公开(公告)号：US20110196866A1

公开(公告)日：2011-08-11

申请号：US12702954

申请日：2010-02-09

Applicant: Brian Frank Cooper

Inventor： Brian Frank Cooper

IPC: G06F17/30 ,  G06F21/00

CPC classification number: G06F17/30595 ,  Y10S707/973

Abstract: Methods and apparatus are described for partitioning native tables in a database cluster into logical tables. Each logical table is mapped into a unique portion of the native table by an intermediary server. Clients access a logical table as an ordinary, full-fledged database table through the intermediary server, which translates queries on the logical table into queries on the corresponding portion of the native table. The mapping may use the application name, logical table name, and a version number to create a native table key for each key in the logical table. A data structure storing these mappings may be stored at the intermediary server or in a native table in the database. This approach affords clients quick and flexible access to the database with better data integrity and security than native tables allow.

Abstract translation: 描述了将数据库集群中的本机表分成逻辑表的方法和装置。 每个逻辑表被中介服务器映射到本地表的唯一部分。 客户端通过中介服务器将逻辑表作为普通的成熟数据库表进行访问，该服务器将逻辑表上的查询转换为本机表的相应部分的查询。 映射可以使用应用程序名称，逻辑表名称和版本号来为逻辑表中的每个键创建本机表密钥。 存储这些映射的数据结构可以存储在数据库中的中间服务器或本地表中。 这种方法为客户端提供了比本机表允许的更好的数据完整性和安全性的快速灵活访问数据库。

公开(公告)号：US08554944B2

公开(公告)日：2013-10-08

申请号：US13423087

申请日：2012-03-16

Applicant: Adam Eli Silberstein ,  Brian Frank Cooper ,  Raghunath Ramakrishnan ,  Jeffrey Terrace

Inventor： Adam Eli Silberstein ,  Brian Frank Cooper ,  Raghunath Ramakrishnan ,  Jeffrey Terrace

IPC: G06F15/16

CPC classification number: H04L67/22 ,  G06F17/30557 ,  H04L67/26

Abstract: In one embodiment, for each one of one or more content producers, access a content-producing rate at which the content producer produces one or more items of content; and for each one of one or more content consumers, access a content-consuming rate at which the content consumer consumes one or more items of content. For each one of a plurality of consumer-producer pairs, wherein the consumer-producer pair comprises one of the content consumers and one of the content producers, and the content consumer follows the content producer, select between a push strategy and a pull strategy for delivering one or more items of content from the content producer to the content consumer based on the content-consuming rate of the content consumer and the content-producing rate of the content producer.

Abstract translation: 在一个实施例中，对于一个或多个内容制作者中的每一个，访问内容制作者产生一个或多个内容项的内容生成速率; 并且对于一个或多个内容消费者中的每一个，访问内容消费者消费一个或多个内容项的内容消费率。 对于多个消费者 - 生产者对中的每一个，其中消费者 - 生产者对包括内容消费者之一和内容制作者之一，并且内容消费者遵循内容制作者，在推送策略和拉动策略之间进行选择 基于内容消费者的内容消费率和内容制作者的内容生成率，将一个或多个内容从内容制作者提供给内容消费者。

公开(公告)号：US20120179782A1

公开(公告)日：2012-07-12

申请号：US13423087

申请日：2012-03-16

Applicant: Adam Eli Silberstein ,  Brian Frank Cooper ,  Raghunath Ramakrishnan ,  Jeffrey Terrace

Inventor： Adam Eli Silberstein ,  Brian Frank Cooper ,  Raghunath Ramakrishnan ,  Jeffrey Terrace

IPC: G06F15/16

CPC classification number: H04L67/22 ,  G06F17/30557 ,  H04L67/26

Abstract: In one embodiment, for each one of one or more content producers, access a content-producing rate at which the content producer produces one or more items of content; and for each one of one or more content consumers, access a content-consuming rate at which the content consumer consumes one or more items of content. For each one of a plurality of consumer-producer pairs, wherein the consumer-producer pair comprises one of the content consumers and one of the content producers, and the content consumer follows the content producer, select between a push strategy and a pull strategy for delivering one or more items of content from the content producer to the content consumer based on the content-consuming rate of the content consumer and the content-producing rate of the content producer.

Abstract translation: 在一个实施例中，对于一个或多个内容制作者中的每一个，访问内容制作者产生一个或多个内容项的内容生成速率; 并且对于一个或多个内容消费者中的每一个，访问内容消费者消费一个或多个内容项的内容消费率。 对于多个消费者 - 生产者对中的每一个，其中消费者 - 生产者对包括内容消费者之一和内容制作者之一，并且内容消费者遵循内容制作者，在推送策略和拉动策略之间进行选择 基于内容消费者的内容消费率和内容制作者的内容生成率，将一个或多个内容从内容制作者提供给内容消费者。

公开(公告)号：US20110225229A1

公开(公告)日：2011-09-15

申请号：US12722411

申请日：2010-03-11

Applicant: Utkarsh Hriday Srivastava ,  Benjamin Clay Reed ,  Yang Zhang ,  Erwin Sing Tam ,  Brian Frank Cooper

Inventor： Utkarsh Hriday Srivastava ,  Benjamin Clay Reed ,  Yang Zhang ,  Erwin Sing Tam ,  Brian Frank Cooper

IPC: G06F15/16

CPC classification number: G06Q50/00 ,  G06Q10/00 ,  H04L51/00

Abstract: In one embodiment, a first one of a plurality of message processors receives a request with respect to a topic, and determines whether the first message processor itself is currently responsible for the topic. If so, then the first message processor services the request. If not, then the first message processor determines whether any of the other ones of the message processors is currently responsible for the topic. If so, then the request is redirected to another message processor to be serviced. If not, then the first message processor selects one of the message processors to be responsible for the topic and to service the request.

Abstract translation: 在一个实施例中，多个消息处理器中的第一个接收关于主题的请求，并且确定第一消息处理器本身当前是否负责该主题。 如果是这样，则第一个消息处理器服务该请求。 如果不是，则第一消息处理器确定消息处理器中的任何一个消息处理器当前是否负责该主题。 如果是这样，那么请求被重定向到另一个消息处理器进行服务。 如果不是，则第一消息处理器选择一个消息处理器来负责该主题并服务该请求。

公开(公告)号：US20110213894A1

公开(公告)日：2011-09-01

申请号：US12714876

申请日：2010-03-01

Applicant: Adam Eli Silberstein ,  Brian Frank Cooper ,  Raghunath Ramakrishnan ,  Jeffrey Terrace

Inventor： Adam Eli Silberstein ,  Brian Frank Cooper ,  Raghunath Ramakrishnan ,  Jeffrey Terrace

IPC: G06F15/16

CPC classification number: H04L67/22 ,  G06F17/30557 ,  H04L67/26

Abstract: In one embodiment, for each one of one or more content producers, access a content-producing rate at which the content producer produces one or more items of content; and for each one of one or more content consumers, access a content-consuming rate at which the content consumer consumes one or more items of content. For each one of a plurality of consumer-producer pairs, wherein the consumer-producer pair comprises one of the content consumers and one of the content producers, and the content consumer follows the content producer, select between a push strategy and a pull strategy for delivering one or more items of content from the content producer to the content consumer based on the content-consuming rate of the content consumer and the content-producing rate of the content producer.

Abstract translation: 在一个实施例中，对于一个或多个内容制作者中的每一个，访问内容制作者产生一个或多个内容项的内容生成速率; 并且对于一个或多个内容消费者中的每一个，访问内容消费者消费一个或多个内容项的内容消费率。 对于多个消费者 - 生产者对中的每一个，其中消费者 - 生产者对包括内容消费者之一和内容制作者之一，并且内容消费者遵循内容制作者，在推送策略和拉动策略之间进行选择 基于内容消费者的内容消费率和内容制作者的内容生成率，将一个或多个内容从内容制作者提供给内容消费者。

公开(公告)号：US08005917B2

公开(公告)日：2011-08-23

申请号：US12242018

申请日：2008-09-30

Applicant: Brian Frank Cooper

Inventor： Brian Frank Cooper

IPC: G06F15/167

CPC classification number: G06F17/3089 ,  G06F11/2041 ,  G06F11/2046 ,  G06F11/2097 ,  G06Q10/107 ,  H04L51/30 ,  H04L67/26 ,  H04L67/2809

Abstract: A system includes a leader server capable of communicating with a plurality of follower servers and a network. The leader server is configured to determine when a message received from a client connected to the network has been committed to main memory in a majority of the leader and follower servers. The leader server and each of the follower servers that committed the message to main memory retain the message in main memory until requested to remove the message from main memory by a delivery agent or an archiver.

Abstract translation: 系统包括能够与多个跟随服务器和网络通信的领导服务器。 领导服务器被配置为确定从连接到网络的客户端接收到的消息何时已经在大多数领导者和跟随服务器中被提交给主存储器。 领先服务器和向主存储器提交消息的每个跟随服务器将消息保留在主存储器中，直到由传送代理或归档器从主存储器移除消息。

公开(公告)号：US20100082728A1

公开(公告)日：2010-04-01

申请号：US12242018

申请日：2008-09-30

Applicant: Brian Frank Cooper

Inventor： Brian Frank Cooper

IPC: G06F15/16 ,  G06F17/30

CPC classification number: G06F17/3089 ,  G06F11/2041 ,  G06F11/2046 ,  G06F11/2097 ,  G06Q10/107 ,  H04L51/30 ,  H04L67/26 ,  H04L67/2809

Abstract: A system includes a leader server capable of communicating with a plurality of follower servers and a network. The leader server is configured to determine when a message received from a client connected to the network has been committed to main memory in a majority of the leader and follower servers. The leader server and each of the follower servers that committed the message to main memory retain the message in main memory until requested to remove the message from main memory by a delivery agent or an archiver.

Abstract translation: 系统包括能够与多个跟随服务器和网络通信的领导服务器。 领导服务器被配置为确定从连接到网络的客户端接收到的消息何时已经在大多数领导者和跟随服务器中被提交给主存储器。 领先服务器和向主存储器提交消息的每个跟随服务器将消息保留在主存储器中，直到由传送代理或归档器从主存储器移除消息。