DYNAMIC PARTITIONING OF DATA FOR DATA-PARALLEL APPLICATIONS
    11.
    发明申请
    DYNAMIC PARTITIONING OF DATA FOR DATA-PARALLEL APPLICATIONS 有权
    用于数据并行应用的数据的动态分区

    公开(公告)号:US20110208872A1

    公开(公告)日:2011-08-25

    申请号:US12712986

    申请日:2010-02-25

    CPC classification number: G06F9/505

    Abstract: Dynamic data partitioning is disclosed for use with a multiple node processing system that consumes items from a data stream of any length and independent of whether the length is undeclared. Dynamic data partitioning takes items from the data stream when a thread is idle and assigns the taken items to an idle thread, and it varies the size of data chunks taken from the stream and assigned to a thread to efficiently distribute work loads among the nodes. In one example, data chunk sizes taken from the beginning of the data stream are relatively smaller than data chunk sizes taken towards the middle or end of the data stream. Dynamic data partitioning employs a growth function where chunks have a size related to single aligned cache lines and efficiently increases the size of the data chunks to occasionally double the amount of data assigned to concurrent threads.

    Abstract translation: 公开了与多节点处理系统一起使用的动态数据分区,其从任何长度的数据流消耗项目,并且与长度是否未声明无关。 动态数据分区在线程空闲时从数据流中获取项目,并将所获取的项目分配给空闲线程,并且将从流中分配给分配给线程的数据块的大小变化,从而有效地在节点之间分配工作负载。 在一个示例中,从数据流的开头获取的数据块大小相对于数据流的中间或结尾所采取的数据块大小相对较小。 动态数据分区使用增长函数,其中块与单个对齐的高速缓存行相关联,并有效地增加数据块的大小,以偶尔将分配给并发线程的数据量加倍。

    HASH PARTITIONING STREAMED DATA
    12.
    发明申请
    HASH PARTITIONING STREAMED DATA 有权
    HASH分区流数据

    公开(公告)号:US20110154359A1

    公开(公告)日:2011-06-23

    申请号:US12642233

    申请日:2009-12-18

    CPC classification number: G06F9/5033 G06F2209/5018

    Abstract: The present invention extends to methods, systems, and computer program products for partitioning streaming data. Embodiments of the invention can be used to hash partition a stream of data and thus avoids unnecessary memory usage (e.g., associated with buffering). Hash partitioning can be used to split an input sequence (e.g., a data stream) into multiple partitions that can be processed independently. Other embodiments of the invention can be used to hash repartition a plurality of streams of data. Hash repartitioning converts a set of partitions into another set of partitions with the hash partitioned property. Partitioning and repartitioning can be done in a streaming manner at runtime by exchanging values between worker threads responsible for different partitions.

    Abstract translation: 本发明扩展到用于划分流数据的方法,系统和计算机程序产品。 本发明的实施例可用于对数据流进行散列分区,从而避免不必要的存储器使用(例如,与缓冲相关联)。 散列分区可用于将输入序列(例如,数据流)拆分成可独立处理的多个分区。 本发明的其他实施例可用于对多个数据流重新分区。 哈希重新分区将一组分区转换为具有哈希分区属性的另一组分区。 在运行时可以通过在负责不同分区的工作线程之间交换值来进行分区和重新分区。

    QUERY PROCESSING USING ARRAYS
    13.
    发明申请
    QUERY PROCESSING USING ARRAYS 审中-公开
    使用阵列进行查询处理

    公开(公告)号:US20100250613A1

    公开(公告)日:2010-09-30

    申请号:US12413814

    申请日:2009-03-30

    CPC classification number: G06F16/24539

    Abstract: A method of processing a query includes receiving a language integrated query including at least one operator, and operating on an input array with the at least one operator. An output array is generated by the at least one operator based on the operation on the input array.

    Abstract translation: 一种处理查询的方法包括:接收包括至少一个运算符的语言集成查询,以及使用所述至少一个运算符对输入阵列进行操作。 基于输入阵列上的操作,由至少一个运算符产生输出数组。

    CONTROLLING PARALLELIZATION OF RECURSION USING PLUGGABLE POLICIES
    14.
    发明申请
    CONTROLLING PARALLELIZATION OF RECURSION USING PLUGGABLE POLICIES 有权
    使用可扩展政策控制并行化恢复

    公开(公告)号:US20090320005A1

    公开(公告)日:2009-12-24

    申请号:US12132614

    申请日:2008-06-04

    CPC classification number: G06F8/45

    Abstract: A parallelism policy object provides a control parallelism interface whose implementation evaluates parallelism conditions that are left unspecified in the interface. User-defined and other parallelism policy procedures can make recommendations to a worker program for transitioning between sequential program execution and parallel execution. Parallelizing assistance values obtained at runtime can be used in the parallelism conditions on which the recommendations are based. A consistent parallelization policy can be employed across a range of parallel constructs, and inside recursive procedures.

    Abstract translation: 并行策略对象提供了一个控制并行接口,其实现评估了界面中未指定的并行条件。 用户定义和其他并行性策略程序可以向工作程序提出在顺序程序执行和并行执行之间转换的建议。 在运行时获得的并行化辅助值可以在建议所基于的并行条件中使用。 在一系列并行构造和内部递归过程中可以采用一致的并行化策略。

    CONFIGURABLE PARTITIONING FOR PARALLEL DATA
    15.
    发明申请
    CONFIGURABLE PARTITIONING FOR PARALLEL DATA 有权
    用于并行数据的可配置分区

    公开(公告)号:US20090319992A1

    公开(公告)日:2009-12-24

    申请号:US12132613

    申请日:2008-06-04

    CPC classification number: G06F8/00

    Abstract: A data partitioning interface provides procedure headings to create data partitions for processing data elements in parallel, and for obtaining data elements to process, without specifying the organizational structure of a data partitioning. A data partitioning implementation associated with the data partitioning interface provides operations to implement the interface procedures, and may also provide dynamic partitioning to facilitate load balancing.

    Abstract translation: 数据分区界面提供用于创建用于并行处理数据元素的数据分区的过程标题,并且用于获取要处理的数据元素,而不指定数据分区的组织结构。 与数据分区接口相关联的数据分区实现提供了实现接口过程的操作,并且还可以提供动态分区以便于负载平衡。

    Parallel processing of an ordered data stream
    17.
    发明授权
    Parallel processing of an ordered data stream 有权
    并行处理有序数据流

    公开(公告)号:US08996556B2

    公开(公告)日:2015-03-31

    申请号:US12479242

    申请日:2009-06-05

    CPC classification number: G06F17/30516 G06F17/30224

    Abstract: 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.

    Abstract translation: 一种并行处理有序输入数据流的方法,包括多个输入数据元素和相应的多个顺序密钥,用于指示输入数据元素的排序,其中每个订单密钥与输入数据元素之一相关联,包括处理 所述输入数据流与多个工作单元并行地进行,从而生成多组输出数据元素。 多组输出数据元素被存储在多个缓冲器中,每个缓冲器与其中一个工作单元相关联。 通过以基于订单密钥的顺序从缓冲器输出所选择的输出数据元素,输出数据流被处理时输出有序的输出数据流。

    Configurable partitioning of parallel data for parallel processing
    18.
    发明授权
    Configurable partitioning of parallel data for parallel processing 有权
    并行处理的并行数据的可配置分区

    公开(公告)号:US08806426B2

    公开(公告)日:2014-08-12

    申请号:US12132613

    申请日:2008-06-04

    CPC classification number: G06F8/00

    Abstract: A data partitioning interface provides procedure headings to create data partitions for processing data elements in parallel, and for obtaining data elements to process, without specifying the organizational structure of a data partitioning. A data partitioning implementation associated with the data partitioning interface provides operations to implement the interface procedures, and may also provide dynamic partitioning to facilitate load balancing.

    Abstract translation: 数据分区界面提供用于创建用于并行处理数据元素的数据分区的过程标题,并且用于获取要处理的数据元素,而不指定数据分区的组织结构。 与数据分区接口相关联的数据分区实现提供了实现接口过程的操作,并且还可以提供动态分区以便于负载平衡。

    Controlling parallelization of recursion using pluggable policies
    19.
    发明授权
    Controlling parallelization of recursion using pluggable policies 有权
    使用可插拔策略控制递归的并行化

    公开(公告)号:US08719803B2

    公开(公告)日:2014-05-06

    申请号:US12132614

    申请日:2008-06-04

    CPC classification number: G06F8/45

    Abstract: A parallelism policy object provides a control parallelism interface whose implementation evaluates parallelism conditions that are left unspecified in the interface. User-defined and other parallelism policy procedures can make recommendations to a worker program for transitioning between sequential program execution and parallel execution. Parallelizing assistance values obtained at runtime can be used in the parallelism conditions on which the recommendations are based. A consistent parallelization policy can be employed across a range of parallel constructs, and inside recursive procedures.

    Abstract translation: 并行策略对象提供了一个控制并行接口,其实现评估了界面中未指定的并行条件。 用户定义和其他并行性策略程序可以向工作程序提出在顺序程序执行和并行执行之间转换的建议。 在运行时获得的并行化辅助值可以在建议所基于的并行条件中使用。 在一系列并行构造和内部递归过程中可以采用一致的并行化策略。

    Automatic optimization for programming of many-core architectures
    20.
    发明授权
    Automatic optimization for programming of many-core architectures 有权
    自动优化多核架构的编程

    公开(公告)号:US08627018B2

    公开(公告)日:2014-01-07

    申请号:US13300464

    申请日:2011-11-18

    CPC classification number: G06F11/3471 G06F11/3409

    Abstract: The present invention extends to methods, systems, and computer program products for automatically optimizing memory accesses by kernel functions executing on parallel accelerator processors. A function is accessed. The function is configured to operate over a multi-dimensional matrix of memory cells through invocation as a plurality of threads on a parallel accelerator processor. A layout of the memory cells of the multi-dimensional matrix and a mapping of memory cells to global memory at the parallel accelerator processor are identified. The function is analyzed to identify how each of the threads access the global memory to operate on corresponding memory cells when invoked from the kernel function. Based on the analysis, the function altered to utilize a more efficient memory access scheme when performing accesses to the global memory. The more efficient memory access scheme increases coalesced memory access by the threads when invoked over the multi-dimensional matrix.

    Abstract translation: 本发明扩展到用于通过在并行加速器处理器上执行的内核功能自动优化存储器访问的方法,系统和计算机程序产品。 访问一个功能。 该功能被配置为通过调用作为并行加速器处理器上的多个线程在多维矩阵的存储器单元上进行操作。 识别多维矩阵的存储单元的布局以及在并行加速器处理器处的存储单元与全局存储器的映射。 分析该功能以识别当从内核功能调用时,每个线程如何访问全局存储器以对相应的存储器单元进行操作。 基于分析,当执行对全局存储器的访问时,功能被改变以利用更有效的存储器访问方案。 当通过多维矩阵调用时,更有效的存储器访问方案增加了线程的合并的存储器访问。

Patent Agency Ranking