公开(公告)号：US20060182046A1

公开(公告)日：2006-08-17

申请号：US11060260

申请日：2005-02-16

申请人： Benoit Dageville ,  Bhaskar Ghosh ,  Rushan Chen ,  Thierry Cruanes ,  Mohamed Zait

发明人： Benoit Dageville ,  Bhaskar Ghosh ,  Rushan Chen ,  Thierry Cruanes ,  Mohamed Zait

IPC分类号： H04L12/16 ,  H04Q11/00

CPC分类号： G06F9/4494

摘要： Techniques are provided for performing a parallel aggregation operation on data that resides in a container, such as a relational table. During generation of the execution plan for the operation, it is determined whether partition-wise aggregation should be performed, based on the grouping keys involved in the aggregation and the partition keys used to partition the container. If partition-wise aggregation is to be performed, then the assignments given to the slave processes that are assigned to scan a container are made on a partition-wise basis. The scan slaves themselves may perform full or partial aggregation (depending on whether they are the only scan slaves assigned to the partition). If the scan slaves perform no aggregation, or only partial aggregation, then the scan slaves redistribute the data items to aggregation slaves that are local to the scan slaves.

摘要翻译： 提供了用于对驻留在诸如关系表的容器中的数据执行并行聚合操作的技术。 在生成操作的执行计划时，基于聚合中涉及的分组密钥和用于分区容器的分区密钥，确定是否应该执行分区聚合。 如果要执行分区聚合，则分配给分配给扫描容器的从属进程的分配是以分区方式进行的。 扫描从站本身可以执行完全或部分聚合（取决于它们是否是分配给分区的唯一扫描从站）。 如果扫描从站不执行聚合或仅执行部分聚合，则扫描从站将数据项重新分配到扫描从站本地的聚合从站。

公开(公告)号：US07779008B2

公开(公告)日：2010-08-17

申请号：US11060260

申请日：2005-02-16

申请人： Benoit Dageville ,  Bhaskar Ghosh ,  Rushan Chen ,  Thierry Cruanes ,  Mohamed Zait

发明人： Benoit Dageville ,  Bhaskar Ghosh ,  Rushan Chen ,  Thierry Cruanes ,  Mohamed Zait

IPC分类号： G06F17/30

CPC分类号： G06F9/4494

摘要： Techniques are provided for performing a parallel aggregation operation on data that resides in a container, such as a relational table. During generation of the execution plan for the operation, it is determined whether partition-wise aggregation should be performed, based on the grouping keys involved in the aggregation and the partition keys used to partition the container. If partition-wise aggregation is to be performed, then the assignments given to the slave processes that are assigned to scan a container are made on a partition-wise basis. The scan slaves themselves may perform full or partial aggregation (depending on whether they are the only scan slaves assigned to the partition). If the scan slaves perform no aggregation, or only partial aggregation, then the scan slaves redistribute the data items to aggregation slaves that are local to the scan slaves.

摘要翻译： 提供了用于对驻留在诸如关系表的容器中的数据执行并行聚合操作的技术。 在生成操作的执行计划时，基于聚合中涉及的分组密钥和用于分区容器的分区密钥，确定是否应该执行分区聚合。 如果要执行分区聚合，则分配给分配给扫描容器的从属进程的分配是以分区方式进行的。 扫描从站本身可以执行完全或部分聚合（取决于它们是否是分配给分区的唯一扫描从站）。 如果扫描从站不执行聚合或仅执行部分聚合，则扫描从站将数据项重新分配到扫描从站本地的聚合从站。

公开(公告)号：US20050131878A1

公开(公告)日：2005-06-16

申请号：US10898300

申请日：2004-07-23

申请人： Rushan Chen ,  Bhaskar Ghosh ,  Thierry Cruanes ,  Patrick Amor ,  Benoit Dageville

发明人： Rushan Chen ,  Bhaskar Ghosh ,  Thierry Cruanes ,  Patrick Amor ,  Benoit Dageville

IPC分类号： G06F7/00 ,  G06F17/30

CPC分类号： G06F17/30445 ,  Y10S707/99932 ,  Y10S707/99933 ,  Y10S707/99934

摘要： A query coordinator handles a multiple-server dynamic performance query by sending remote query slaves (1) first information for generating a complete plan for the query, and (2) second information for participating in the dynamic performance view portion of the query. If the slaves on the remote servers are unable to use the first information to generate an equivalent query (for example, if they reside in a database server that has closed the database), then the slaves on the remote servers use the second information to participate in the dynamic performance view portion of the query.

摘要翻译： 查询协调器通过发送远程查询从站来处理多服务器动态性能查询（1）用于生成查询的完整计划的第一信息，以及（2）用于参与查询的动态性能视图部分的第二信息。 如果远程服务器上的从站无法使用第一个信息来生成等效查询（例如，如果它们位于已关闭数据库的数据库服务器中），则远程服务器上的从站将使用第二个信息来参与 在查询的动态性能视图部分。

公开(公告)号：US08086645B2

公开(公告)日：2011-12-27

申请号：US10824887

申请日：2004-04-13

申请人： Bhaskar Ghosh ,  Thierry Cruanes ,  Benoit Dageville ,  Rushan Chen

发明人： Bhaskar Ghosh ,  Thierry Cruanes ,  Benoit Dageville ,  Rushan Chen

IPC分类号： G06F7/00

CPC分类号： G06F17/30445

摘要： Techniques are provided for executing query statements, or portions thereof, in parallel without using slave SQL to communicate to each slave the operations to be performed by the slave. Instead of generating one cursor for the query coordinator (QC) based on the original statement, and separate cursors for each DFO based on the slave SQL, the techniques involve sharing the cursor that is generated from the original statement among the various participants involved in the parallel execution of the operations specified in the original statement.

摘要翻译： 提供了用于并行执行查询语句或其部分的技术，而不使用从属SQL向从机通知由从机执行的操作。 基于原始语句而不是为查询协调器（QC）生成一个游标，并且基于从属SQL为每个DFO分别设置游标，这些技术涉及共享从原始语句生成的游标， 并行执行原始语句中指定的操作。

公开(公告)号：US07203676B2

公开(公告)日：2007-04-10

申请号：US10898300

申请日：2004-07-23

申请人： Rushan Chen ,  Bhaskar Ghosh ,  Thierry Cruanes ,  Patrick A. Amor ,  Benoit Dageville

发明人： Rushan Chen ,  Bhaskar Ghosh ,  Thierry Cruanes ,  Patrick A. Amor ,  Benoit Dageville

IPC分类号： G06F17/30

CPC分类号： G06F17/30445 ,  Y10S707/99932 ,  Y10S707/99933 ,  Y10S707/99934

摘要： A query coordinator handles a multiple-server dynamic performance query by sending remote query slaves (1) first information for generating a complete plan for the query, and (2) second information for participating in the dynamic performance view portion of the query. If the slaves on the remote servers are unable to use the first information to generate an equivalent query (for example, if they reside in a database server that has closed the database), then the slaves on the remote servers use the second information to participate in the dynamic performance view portion of the query.

摘要翻译： 查询协调器通过发送远程查询从站来处理多服务器动态性能查询（1）用于生成查询的完整计划的第一信息，以及（2）用于参与查询的动态性能视图部分的第二信息。 如果远程服务器上的从站无法使用第一个信息来生成等效查询（例如，如果它们位于已关闭数据库的数据库服务器中），则远程服务器上的从站将使用第二个信息来参与 在查询的动态性能视图部分。

公开(公告)号：US20050132383A1

公开(公告)日：2005-06-16

申请号：US10824887

申请日：2004-04-13

申请人： Bhaskar Ghosh ,  Thierry Cruanes ,  Benoit Dageville ,  Rushan Chen

发明人： Bhaskar Ghosh ,  Thierry Cruanes ,  Benoit Dageville ,  Rushan Chen

IPC分类号： G06F7/00 ,  G06F17/30

CPC分类号： G06F17/30445

摘要： Techniques are provided for executing query statements, or portions thereof, in parallel without using slave SQL to communicate to each slave the operations to be performed by the slave. Instead of generating one cursor for the query coordinator (QC) based on the original statement, and separate cursors for each DFO based on the slave SQL, the techniques involve sharing the cursor that is generated from the original statement among the various participants involved in the parallel execution of the operations specified in the original statement.

摘要翻译： 提供了用于并行执行查询语句或其部分的技术，而不使用从属SQL向从机通知由从机执行的操作。 基于原始语句而不是为查询协调器（QC）生成一个游标，并且基于从属SQL为每个DFO分别设置游标，这些技术涉及共享从原始语句生成的游标， 并行执行原始语句中指定的操作。

公开(公告)号：US07958160B2

公开(公告)日：2011-06-07

申请号：US10841991

申请日：2004-05-06

申请人： Bhaskar Ghosh ,  Thierry Cruanes ,  Rushan Chen ,  Shrikanth Shankar

发明人： Bhaskar Ghosh ,  Thierry Cruanes ,  Rushan Chen ,  Shrikanth Shankar

IPC分类号： G06F17/30

CPC分类号： G06F17/30445

摘要： Techniques are provided for generating execution plans for, and executing, database statements that contain filter subqueries. Upon receiving a database statement that contains a filter subquery, the database server builds an execution plan that includes a filter operation that is fed by a subtree that corresponds to the subquery. The database server performs a cost analysis to determine whether (1) the filter operation should be parallelized, and (2) the subquery tree should be parallelized. Techniques are also described for generating plans and executing queries where (1) both the filter operation and the subquery subtree are parallelized, (2) the filter operation is parallelized but the subquery subtree operation is performed serially, and (3) the filter operation is performed serially but the subquery subtree operation is parallelized.

摘要翻译： 提供了技术来生成包含过滤器子查询的数据库语句的执行计划和执行。 在收到包含过滤器子查询的数据库语句之后，数据库服务器构建一个执行计划，其中包含由子查询对应的子树进行的过滤操作。 数据库服务器执行成本分析来确定（1）是否应该并行化过滤器操作，以及（2）子查询树应该并行化。 还描述了用于生成计划和执行查询的技术，其中（1）过滤器操作和子查询子树都被并行化，（2）过滤操作并行化，但是子查询子树操作被串行执行，并且（3）过滤器操作 串行执行子查询子树操作并行化。

公开(公告)号：US20050131877A1

公开(公告)日：2005-06-16

申请号：US10841991

申请日：2004-05-06

申请人： Bhaskar Ghosh ,  Thierry Cruanes ,  Rushan Chen ,  Shrikanth Shankar

发明人： Bhaskar Ghosh ,  Thierry Cruanes ,  Rushan Chen ,  Shrikanth Shankar

IPC分类号： G06F7/00 ,  G06F17/30

CPC分类号： G06F17/30445

摘要： Techniques are provided for generating execution plans for, and executing, database statements that contain filter subqueries. Upon receiving a database statement that contains a filter subquery, the database server builds an execution plan that includes a filter operation that is fed by a subtree that corresponds to the subquery. The database server performs a cost analysis to determine whether (1) the filter operation should be parallelized, and (2) the subquery tree should be parallelized. Techniques are also described for generating plans and executing queries where (1) both the filter operation and the subquery subtree are parallelized, (2) the filter operation is parallelized but the subquery subtree operation is performed serially, and (3) the filter operation is performed serially but the subquery subtree operation is parallelized.

摘要翻译： 提供了技术来生成包含过滤器子查询的数据库语句的执行计划和执行。 在收到包含过滤器子查询的数据库语句之后，数据库服务器构建一个执行计划，其中包含由子查询对应的子树进行的过滤操作。 数据库服务器执行成本分析来确定（1）是否应该并行化过滤器操作，以及（2）子查询树应该并行化。 还描述了用于生成计划和执行查询的技术，其中（1）过滤器操作和子查询子树都被并行化，（2）过滤操作并行化，但是子查询子树操作被串行执行，并且（3）过滤器操作 串行执行子查询子树操作并行化。

公开(公告)号：US07089356B1

公开(公告)日：2006-08-08

申请号：US10302207

申请日：2002-11-21

申请人： Rushan Chen ,  Bhaskar Ghosh

发明人： Rushan Chen ,  Bhaskar Ghosh

IPC分类号： G06F12/06

CPC分类号： G06F17/30445

摘要： A method is described for parallel processing of sequence operations, in which contention for the sequence operation is reduced among multiple parallel processes. Contention is reduced by caching sequence values locally for each parallel process. Each process accesses the sequence operation, or an instance level cache of sequence values, in a batched manner, thereby returning a block of unique sequence values instead of a single sequence value. The block of sequence values, or at least information that indicates a range of sequence values that define the block, is then cached locally in association with a given process of the multiple processes. Hence, future requests for sequence values from the given process are serviced from the local cache, rather than having to access the sequence operation and risk contention for the operation with other processes.

摘要翻译： 描述了用于并行处理序列操作的方法，其中在多个并行进程中减少了对顺序操作的争用。 通过为每个并行进程本地缓存序列值来减少争用。 每个进程以批量方式访问序列操作或序列值的实例级高速缓存，从而返回唯一序列值的块而不是单个序列值。 序列值块或至少指示定义块的序列值范围的信息随后与多个进程的给定进程相关联地本地缓存。 因此，来自给定进程的对序列值的未来请求从本地缓存服务，而不是必须访问序列操作和与其他进程的操作的风险争用。

公开(公告)号：US20130339473A1

公开(公告)日：2013-12-19

申请号：US13829119

申请日：2013-03-14

申请人： Daniel McCaffrey ,  Michael Fan ,  Rushan Chen

发明人： Daniel McCaffrey ,  Michael Fan ,  Rushan Chen

IPC分类号： H04L12/863

CPC分类号： H04L47/62 ,  H04L49/90 ,  H04L67/22

摘要： Real time analytics via stream processing is described. A stream reader receives a stream of messages and batches the messages in a message queue. A stream writer accesses the messages from the message queue, aggregates the messages from a time window based on a hierarchy of an attribute to generate a set of event data for the time window, stores the set of event data in a memory cache cluster, and stores a key corresponding to the set of event data in a key buffer queue. A stream aggregator accesses the key from the key buffer queue, retrieves the set of data in the time window corresponding to the key from the memory cache cluster, and performs a process on the retrieved set of data.

摘要翻译： 描述通过流处理的实时分析。 流读取器接收消息流并在消息队列中分批消息。 流写入器从消息队列访问消息，基于属性的层次结构从时间窗口聚合消息以生成时间窗口的事件数据集，将事件数据集存储在存储器高速缓存集群中，以及 将与该组事件数据相对应的密钥存储在密钥缓冲器队列中。 流聚合器从密钥缓冲区队列中访问密钥，从存储器缓存集群中检索对应于密钥的时间窗口中的数据集，并对检索到的数据集进行处理。