-
公开(公告)号:US20120331475A1
公开(公告)日:2012-12-27
申请号:US13165421
申请日:2011-06-21
申请人: Igor Ostrovsky , Joseph E. Hoag , Stephen H. Toub , Mike Liddell
发明人: Igor Ostrovsky , Joseph E. Hoag , Stephen H. Toub , Mike Liddell
IPC分类号: G06F9/46
CPC分类号: G06F12/023 , G06F3/0608 , G06F3/061 , G06F3/0631 , G06F3/0673 , G06F9/5016 , G06F2212/1016 , G06F2212/1044
摘要: Dynamically allocated thread storage in a computing device is disclosed. The dynamically allocated thread storage is configured to work with a process including two or more threads. Each thread includes a statically allocated thread-local slot configured to store a table. Each table is configured to include a table slot corresponding with a dynamically allocated thread-local value. A dynamically allocated thread-local instance corresponds with the table slot.
摘要翻译: 公开了在计算设备中动态分配的线程存储。 动态分配的线程存储被配置为使用包括两个或更多个线程的进程。 每个线程包括一个静态分配的线程本地插槽,用于存储一个表。 每个表被配置为包括与动态分配的线程本地值相对应的表时隙。 动态分配的线程本地实例对应于表槽。
-
公开(公告)号:US09354932B2
公开(公告)日:2016-05-31
申请号:US13165421
申请日:2011-06-21
申请人: Igor Ostrovsky , Joseph E. Hoag , Stephen H. Toub , Mike Liddell
发明人: Igor Ostrovsky , Joseph E. Hoag , Stephen H. Toub , Mike Liddell
CPC分类号: G06F12/023 , G06F3/0608 , G06F3/061 , G06F3/0631 , G06F3/0673 , G06F9/5016 , G06F2212/1016 , G06F2212/1044
摘要: Dynamically allocated thread storage in a computing device is disclosed. The dynamically allocated thread storage is configured to work with a process including two or more threads. Each thread includes a statically allocated thread-local slot configured to store a table. Each table is configured to include a table slot corresponding with a dynamically allocated thread-local value. A dynamically allocated thread-local instance corresponds with the table slot.
摘要翻译: 公开了在计算设备中动态分配的线程存储。 动态分配的线程存储被配置为使用包括两个或更多个线程的进程。 每个线程包括一个静态分配的线程本地插槽,用于存储一个表。 每个表被配置为包括与动态分配的线程本地值相对应的表时隙。 动态分配的线程本地实例对应于表槽。
-
3.
公开(公告)号:US09229788B2
公开(公告)日:2016-01-05
申请号:US12732552
申请日:2010-03-26
申请人: Stephen H. Toub , Joseph E. Hoag , Huseyin S. Yildiz , Danny S. Shih , Mike Liddell , John Duffy
发明人: Stephen H. Toub , Joseph E. Hoag , Huseyin S. Yildiz , Danny S. Shih , Mike Liddell , John Duffy
CPC分类号: G06F9/522
摘要: A method of performing a wait operation includes creating a first plurality of tasks and a continuation task. The continuation task represents a second plurality of tasks. The continuation task and each of the tasks in the first plurality have an associated wait handle. The wait handles for the first plurality of tasks and the continuation task are stored in an array. A wait operation is performed on the array, thereby waiting for at least one of the tasks in the first and second pluralities to complete.
摘要翻译: 执行等待操作的方法包括创建第一多个任务和连续任务。 继续任务表示第二个多个任务。 继续任务和第一组中的每个任务具有相关联的等待句柄。 第一个多任务和连续任务的等待句柄存储在一个数组中。 在阵列上执行等待操作,从而等待第一和第二多个中的至少一个任务完成。
-
4.
公开(公告)号:US20110239217A1
公开(公告)日:2011-09-29
申请号:US12732552
申请日:2010-03-26
申请人: Stephen H. Toub , Joseph E. Hoag , Huseyin S. Yildiz , Danny S. Shih , Mike Liddell , John Duffy
发明人: Stephen H. Toub , Joseph E. Hoag , Huseyin S. Yildiz , Danny S. Shih , Mike Liddell , John Duffy
IPC分类号: G06F9/46
CPC分类号: G06F9/522
摘要: A method of performing a wait operation includes creating a first plurality of tasks and a continuation task. The continuation task represents a second plurality of tasks. The continuation task and each of the tasks in the first plurality have an associated wait handle. The wait handles for the first plurality of tasks and the continuation task are stored in an array. A wait operation is performed on the array, thereby waiting for at least one of the tasks in the first and second pluralities to complete.
摘要翻译: 执行等待操作的方法包括创建第一多个任务和连续任务。 继续任务表示第二个多个任务。 继续任务和第一组中的每个任务具有相关联的等待句柄。 第一个多任务和连续任务的等待句柄存储在一个数组中。 在阵列上执行等待操作,从而等待第一和第二多个中的至少一个任务完成。
-
公开(公告)号:US08266172B2
公开(公告)日:2012-09-11
申请号:US12418136
申请日:2009-04-03
申请人: Igor Ostrovsky , John Duffy , Mike Liddell , Edward G. Essey , Stephen H. Toub
发明人: Igor Ostrovsky , John Duffy , Mike Liddell , Edward G. Essey , Stephen H. Toub
IPC分类号: G06F7/00
CPC分类号: G06F17/30445
摘要: A method of analyzing a data parallel query includes receiving a user-specified data parallel query that includes a plurality of query operators. An operator type for each of the query operators is identified based on a type of parallel input data structure the operator operates on and a type of parallel output data structure the operator outputs. It is determined whether the query is a prohibited query based on the identified operator types.
摘要翻译: 分析数据并行查询的方法包括接收包括多个查询运算符的用户指定的数据并行查询。 基于操作员操作的并行输入数据结构的类型和操作员输出的并行输出数据结构的类型来识别每个查询运算符的运算符类型。 基于所识别的运算符类型来确定查询是否是禁止查询。
-
公开(公告)号:US20100257191A1
公开(公告)日:2010-10-07
申请号:US12418136
申请日:2009-04-03
申请人: Igor Ostrovsky , John Duffy , Mike Liddell , Edward G. Essey , Stephen H. Toub
发明人: Igor Ostrovsky , John Duffy , Mike Liddell , Edward G. Essey , Stephen H. Toub
IPC分类号: G06F17/30
CPC分类号: G06F17/30445
摘要: A method of analyzing a data parallel query includes receiving a user-specified data parallel query that includes a plurality of query operators. An operator type for each of the query operators is identified based on a type of parallel input data structure the operator operates on and a type of parallel output data structure the operator outputs. It is determined whether the query is a prohibited query based on the identified operator types.
摘要翻译: 分析数据并行查询的方法包括接收包括多个查询运算符的用户指定的数据并行查询。 基于操作员操作的并行输入数据结构的类型和操作员输出的并行输出数据结构的类型来识别每个查询运算符的运算符类型。 基于所识别的运算符类型来确定查询是否是禁止查询。
-
公开(公告)号:US20100185840A1
公开(公告)日:2010-07-22
申请号:US12357850
申请日:2009-01-22
申请人: John Duffy , Stephen H. Toub , Huseyin S. Yildiz , Mike Liddell
发明人: John Duffy , Stephen H. Toub , Huseyin S. Yildiz , Mike Liddell
IPC分类号: G06F9/38
CPC分类号: G06F9/3865 , G06F9/4488 , G06F9/4812 , G06F11/1402 , G06F2209/481
摘要: A method of handling an exception in a parallel system includes constructing a task object, executing a method with the task object, and catching an exception with the task object during execution of the method. The exception is propagated in response to the task object becoming inaccessible without the exception having been observed.
摘要翻译: 在并行系统中处理异常的方法包括:在执行该方法期间,构建一个任务对象,执行一个具有该任务对象的方法,以及在该任务对象中捕获一个异常。 异常被传播以响应任务对象变得无法访问,而没有被观察到例外。
-
公开(公告)号:US20120066250A1
公开(公告)日:2012-03-15
申请号:US12882168
申请日:2010-09-14
IPC分类号: G06F17/30
CPC分类号: G06F17/30445
摘要: Embodiments are directed to implementing custom operators in a query for a parallel query engine and to generating a partitioned representation of a sequence of query operators in a parallel query engine. A computer system receives a portion of partitioned input data at a parallel query engine, where the parallel query engine is configured to process data queries in parallel, and where the queries include a sequence of built-in operators. The computer system incorporates a custom operator into the sequence of built-in operators for a query and accesses the sequence of operators to determine how the partitioned input data is to be processed. The custom operator is accessed in the same manner as the built-in operators. The computer system also processes the sequence of operators including both the built-in operators and at least one custom operator according to the determination indicating how the data is to be processed.
摘要翻译: 实施例涉及在并行查询引擎的查询中实现自定义运算符并且在并行查询引擎中生成查询运算符序列的分区表示。 计算机系统在并行查询引擎处接收分割的输入数据的一部分,其中并行查询引擎被配置为并行处理数据查询,并且查询包括一系列内置运算符。 计算机系统将定制运算符合并到用于查询的内置运算符序列中,并访问运算符序列以确定如何处理分区输入数据。 以与内置运算符相同的方式访问定制运算符。 计算机系统还根据指示如何处理数据的确定来处理包括内置运算符和至少一个定制运算符的运算符序列。
-
公开(公告)号:US08521721B2
公开(公告)日:2013-08-27
申请号:US12882168
申请日:2010-09-14
CPC分类号: G06F17/30445
摘要: Embodiments are directed to implementing custom operators in a query for a parallel query engine and to generating a partitioned representation of a sequence of query operators in a parallel query engine. A computer system receives a portion of partitioned input data at a parallel query engine, where the parallel query engine is configured to process data queries in parallel, and where the queries include a sequence of built-in operators. The computer system incorporates a custom operator into the sequence of built-in operators for a query and accesses the sequence of operators to determine how the partitioned input data is to be processed. The custom operator is accessed in the same manner as the built-in operators. The computer system also processes the sequence of operators including both the built-in operators and at least one custom operator according to the determination indicating how the data is to be processed.
摘要翻译: 实施例涉及在并行查询引擎的查询中实现自定义运算符并且在并行查询引擎中生成查询运算符序列的分区表示。 计算机系统在并行查询引擎处接收分割的输入数据的一部分,其中并行查询引擎被配置为并行处理数据查询,并且查询包括一系列内置运算符。 计算机系统将定制运算符合并到用于查询的内置运算符序列中,并访问运算符序列以确定如何处理分区输入数据。 以与内置运算符相同的方式访问定制运算符。 计算机系统还根据指示如何处理数据的确定来处理包括内置运算符和至少一个定制运算符的运算符序列。
-
公开(公告)号:US08996556B2
公开(公告)日:2015-03-31
申请号:US12479242
申请日:2009-06-05
申请人: Igor Ostrovsky , John Duffy , Mike Liddell
发明人: Igor Ostrovsky , John Duffy , Mike Liddell
IPC分类号: G06F17/30
CPC分类号: G06F17/30516 , G06F17/30224
摘要: A method of parallel processing an ordered input data stream that includes a plurality of input data elements and a corresponding plurality of order keys for indicating an ordering of the input data elements, with each order key associated with one of the input data elements, includes processing the input data stream in a parallel manner with a plurality of worker units, thereby generating a plurality of sets of output data elements. The plurality of sets of output data elements is stored in a plurality of buffers, with each buffer associated with one of the worker units. An ordered output data stream is output while the input data stream is being processed by outputting selected output data elements from the buffers in an order that is based on the order keys.
摘要翻译: 一种并行处理有序输入数据流的方法,包括多个输入数据元素和相应的多个顺序密钥,用于指示输入数据元素的排序,其中每个订单密钥与输入数据元素之一相关联,包括处理 所述输入数据流与多个工作单元并行地进行,从而生成多组输出数据元素。 多组输出数据元素被存储在多个缓冲器中,每个缓冲器与其中一个工作单元相关联。 通过以基于订单密钥的顺序从缓冲器输出所选择的输出数据元素,输出数据流被处理时输出有序的输出数据流。
-
-
-
-
-
-
-
-
-