MULTI-CORE QUERY PROCESSING USING ASYNCHRONOUS BUFFERS
    3.
    发明申请
    MULTI-CORE QUERY PROCESSING USING ASYNCHRONOUS BUFFERS 有权
    使用异步缓冲区进行多核查询处理

    公开(公告)号:US20110314233A1

    公开(公告)日:2011-12-22

    申请号:US12831795

    申请日:2010-07-07

    IPC分类号: G06F12/00

    摘要: A system may include a buffer monitor configured to monitor buffer content of a buffer being used during processing of a query workflow in which write tasks of the query workflow write data to the buffer and read tasks of the query workflow read data from the buffer, the buffer having a buffer capacity. The system may include a threshold manager configured to compare the buffer content to a low threshold and to a high threshold that are defined relative to the buffer capacity, and a speed controller configured to control a number of the write tasks relative to a number of the read tasks that are currently executing the query workflow, to thereby maintain the buffer content between the low threshold and the high threshold.

    摘要翻译: 系统可以包括缓冲器监视器,其被配置为监视在查询工作流的处理期间使用的缓冲器的缓冲器内容,其中查询工作流的写入任务将数据写入缓冲器并读取查询工作流程从缓冲器读取数据, 具有缓冲器容量的缓冲器。 该系统可以包括阈值管理器,其被配置为将缓冲器内容与相对于缓冲器容量定义的低阈值和高阈值进行比较;以及速度控制器,被配置为相对于多个 读取当前执行查询工作流的任务,从而将缓冲区内容保持在低阈值和高阈值之间。

    Multi-Core Scheduling for Parallel Queries
    4.
    发明申请
    Multi-Core Scheduling for Parallel Queries 有权
    并行查询的多核心调度

    公开(公告)号:US20100312762A1

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

    申请号:US12758604

    申请日:2010-04-12

    IPC分类号: G06F17/30

    CPC分类号: G06F9/505 G06F17/30445

    摘要: An operator manager may be configured to determine a number of available cores and to assign the cores among a plurality of operators of a query, the operators including a running set of operators through which a plurality of query paths exist. The operator manager may include a status monitor configured to determine the number of available cores and to determine the running set of operators, a critical path selector configured to determine a critical path of the query from among the query paths and the running set of operators, and a workload manager configured to assign a first core of the available cores to a running operator of the running set and of the critical path, and to thereafter receive a new critical path from the critical path selector and to assign a second core of the available cores to the running operator of the new critical path.

    摘要翻译: 操作员管理器可以被配置为确定多个可用核心并且在查询的多个运算符之间分配核心,所述运营商包括存在多个查询路径的运行的运行集合。 运营商管理者可以包括配置为确定可用核心数量并且确定运行的运营商集合的状态监视器,关键路径选择器被配置为从查询路径和正在运行的运行集合中确定查询的关键路径, 并且工作负载管理器被配置为将可用核心的第一核心分配给运行集合和关键路径的正在运行的运营商,并且此后从关键路径选择器接收新的关键路径并且分配可用的核心 核心到新的关键路径的运行操作员。

    Multi-core scheduling for parallel queries
    5.
    发明授权
    Multi-core scheduling for parallel queries 有权
    并行查询的多核调度

    公开(公告)号:US08219546B2

    公开(公告)日:2012-07-10

    申请号:US12758604

    申请日:2010-04-12

    IPC分类号: G06F17/30

    CPC分类号: G06F9/505 G06F17/30445

    摘要: An operator manager may be configured to determine a number of available cores and to assign the cores among a plurality of operators of a query, the operators including a running set of operators through which a plurality of query paths exist. The operator manager may include a status monitor configured to determine the number of available cores and to determine the running set of operators, a critical path selector configured to determine a critical path of the query from among the query paths and the running set of operators, and a workload manager configured to assign a first core of the available cores to a running operator of the running set and of the critical path, and to thereafter receive a new critical path from the critical path selector and to assign a second core of the available cores to the running operator of the new critical path.

    摘要翻译: 操作员管理器可以被配置为确定多个可用核心并且在查询的多个运算符之间分配核心,所述运营商包括存在多个查询路径的运行的运行集合。 运营商管理者可以包括配置为确定可用核心数量并且确定运行的运营商集合的状态监视器,关键路径选择器被配置为从查询路径和正在运行的运行集合中确定查询的关键路径, 并且工作负载管理器被配置为将可用核心的第一核心分配给运行集合和关键路径的正在运行的运营商,并且此后从关键路径选择器接收新的关键路径并且分配可用的核心 核心到新的关键路径的运行操作员。

    Mobile Messaging Message Notifications Processing
    6.
    发明申请
    Mobile Messaging Message Notifications Processing 有权
    移动消息通知处理

    公开(公告)号:US20120094637A1

    公开(公告)日:2012-04-19

    申请号:US12905281

    申请日:2010-10-15

    IPC分类号: H04W4/12

    摘要: Described is a pipeline for handling notification messages sent to a mobile messaging message (e.g., SMS or SMTP) recipient, and handling a reply to that notification message, including correlating the notification message with the reply. An engine receives a notification message, and for a notification message to which a reply is possible, maintains state data for use in correlating a received reply with the notification message. The state data includes metadata that indicates that text or code data is expected in any reply. For a reply providing code data, the engine calls a selected URL corresponding to the code. To facilitate message delivery, the engine may format the notification message, including shortening a URL of the message, and/or splitting a longer notification message into shorter notification messages.

    摘要翻译: 描述了用于处理发送到移动消息收发消息(例如,SMS或SMTP)接收者的通知消息以及处理对该通知消息的回复的管道,包括将通知消息与回复相关联。 引擎接收通知消息,并且对于可以进行回复的通知消息,维护用于将接收的回复与通知消息相关联的状态数据。 状态数据包括指示在任何回复中预期文本或代码数据的元数据。 对于提供代码数据的回复,引擎调用与代码相对应的所选URL。 为了便于消息传递,引擎可以格式化通知消息,包括缩短消息的URL,和/或将更长的通知消息分割成更短的通知消息。

    Method and system for a comprehensive analysis of low frequency oscillation
    7.
    发明授权
    Method and system for a comprehensive analysis of low frequency oscillation 有权
    低频振荡综合分析方法与系统

    公开(公告)号:US08898027B2

    公开(公告)日:2014-11-25

    申请号:US12996896

    申请日:2009-09-04

    IPC分类号: G01R23/00 H02J3/24

    CPC分类号: H02J3/24

    摘要: A method and a system for a comprehensive analysis of low frequency oscillation. The method includes: firstly, initiating a wide area measurement system WAMS (71) to perform real-time monitoring; transmitting real-time low frequency oscillation information to a dynamic early-warning system (72) periodically; then converting the low frequency oscillation information received by the dynamic early-warning system (72) into an input file for stability calculation with small disturbance, and performing related calculation; finally, transmitting the calculated result back to the wide area measurement system WAMS (71) and a human-machine system interface for output. The system includes: the wide area measurement system WAMS (71), the dynamic early-warning system (72), a system for stability calculation with small disturbance (73) and an output system (74).

    摘要翻译: 一种综合分析低频振荡的方法和系统。 该方法包括:首先启动广域测量系统WAMS(71)进行实时监控; 周期性地将实时低频振荡信息发送到动态预警系统(72); 然后将由动态预警系统(72)接收的低频振荡信息转换成具有小干扰的用于稳定性计算的输入文件,并执行相关计算; 最后,将计算结果传送回广域测量系统WAMS(71)和人机界面进行输出。 该系统包括:广域测量系统WAMS(71),动态预警系统(72),小干扰稳定计算系统(73)和输出系统(74)。

    Calibration of resource allocation during parallel processing
    8.
    发明授权
    Calibration of resource allocation during parallel processing 有权
    并行处理过程中资源分配的校准

    公开(公告)号:US08612180B2

    公开(公告)日:2013-12-17

    申请号:US12717694

    申请日:2010-03-04

    IPC分类号: G06F9/28

    摘要: A first performance measurement of an executing task may be determined, while the task is executed by a first number of nodes operating in parallel. A second performance measurement of the executing task may be determined, while the task is being executed by a second number of nodes operating in parallel. An overhead factor characterizing a change of a parallelism overhead of executing the task with nodes executing in parallel may then be calculated, relative to a change in a number of the nodes, based on the first performance measurement and the second performance measurement. Then, an optimal number of nodes to operate in parallel to continue executing the task may be determined, based on the overhead factor.

    摘要翻译: 可以确定执行任务的第一性能测量,而任务由并行操作的第一数量的节点执行。 可以确定执行任务的第二性能测量,而任务正由并行操作的第二数量的节点执行。 然后可以基于第一性能测量和第二性能测量来相对于节点数量的改变来计算表征并行执行的节点执行任务的并行性开销变化的开销因素。 然后,可以基于开销因素来确定并行操作以继续执行任务的最佳数量的节点。

    Mobile messaging message notifications processing
    9.
    发明授权
    Mobile messaging message notifications processing 有权
    移动消息通知处理

    公开(公告)号:US08934925B2

    公开(公告)日:2015-01-13

    申请号:US12905281

    申请日:2010-10-15

    IPC分类号: H04W68/00 H04W4/12 H04L12/58

    摘要: Described is a pipeline for handling notification messages sent to a mobile messaging message (e.g., SMS or SMTP) recipient, and handling a reply to that notification message, including correlating the notification message with the reply. An engine receives a notification message, and for a notification message to which a reply is possible, maintains state data for use in correlating a received reply with the notification message. The state data includes metadata that indicates that text or code data is expected in any reply. For a reply providing code data, the engine calls a selected URL corresponding to the code. To facilitate message delivery, the engine may format the notification message, including shortening a URL of the message, and/or splitting a longer notification message into shorter notification messages.

    摘要翻译: 描述了用于处理发送到移动消息收发消息(例如,SMS或SMTP)接收者的通知消息以及处理对该通知消息的回复的管道,包括将通知消息与回复相关联。 引擎接收通知消息,并且对于可以进行回复的通知消息,维护用于将接收的回复与通知消息相关联的状态数据。 状态数据包括指示在任何回复中预期文本或代码数据的元数据。 对于提供代码数据的回复,引擎调用与代码相对应的所选URL。 为了便于消息传递,引擎可以格式化通知消息,包括缩短消息的URL,和/或将更长的通知消息分割成更短的通知消息。

    Multi-core query processing using asynchronous buffers
    10.
    发明授权
    Multi-core query processing using asynchronous buffers 有权
    使用异步缓冲区的多核查询处理

    公开(公告)号:US08650340B2

    公开(公告)日:2014-02-11

    申请号:US12831795

    申请日:2010-07-07

    IPC分类号: G06F3/00 G06F5/00

    摘要: A system may include a buffer monitor configured to monitor buffer content of a buffer being used during processing of a query workflow in which write tasks of the query workflow write data to the buffer and read tasks of the query workflow read data from the buffer, the buffer having a buffer capacity. The system may include a threshold manager configured to compare the buffer content to a low threshold and to a high threshold that are defined relative to the buffer capacity, and a speed controller configured to control a number of the write tasks relative to a number of the read tasks that are currently executing the query workflow, to thereby maintain the buffer content between the low threshold and the high threshold.

    摘要翻译: 系统可以包括缓冲器监视器,其被配置为监视在查询工作流的处理期间使用的缓冲器的缓冲器内容,其中查询工作流的写入任务将数据写入缓冲器并读取查询工作流程从缓冲器读取数据, 具有缓冲器容量的缓冲器。 该系统可以包括阈值管理器,其被配置为将缓冲器内容与相对于缓冲器容量定义的低阈值和高阈值进行比较;以及速度控制器,被配置为相对于多个 读取当前执行查询工作流的任务,从而将缓冲区内容保持在低阈值和高阈值之间。