RESENDING MESSAGES
    1.
    发明申请
    RESENDING MESSAGES 有权
    重新发送消息

    公开(公告)号:US20140325527A1

    公开(公告)日:2014-10-30

    申请号:US13873889

    申请日:2013-04-30

    CPC classification number: G06F9/546 G06F2209/546

    Abstract: A technique for resending messages can include determining if a particular message with a first unique identifier has been received by a recipient task among a number of potential recipient tasks in a distributed streaming system, notifying the number of potential recipient tasks to ignore the particular message with the first unique identifier, and resending the particular message with a second unique identifier.

    Abstract translation: 用于重新发送消息的技术可以包括确定在分布式流传输系统中的多个潜在接收者任务中的接收者任务中是否已经接收到具有第一唯一标识符的特定消息,通知潜在接收者任务的数量以忽略具有 第一唯一标识符,并且重新发送具有第二唯一标识符的特定消息。

    RECOVERING A FAILURE IN A DATA PROCESSING SYSTEM
    2.
    发明申请
    RECOVERING A FAILURE IN A DATA PROCESSING SYSTEM 审中-公开
    恢复数据处理系统中的故障

    公开(公告)号:US20140304545A1

    公开(公告)日:2014-10-09

    申请号:US13857885

    申请日:2013-04-05

    CPC classification number: G06F11/1438 G06F9/46 G06F9/546

    Abstract: A technique of recovering a failure in a data processing system comprises restoring a checkpointed state in a last window, and resending all the input messages received at the second node during the failed window boundary.

    Abstract translation: 恢复数据处理系统中的故障的技术包括恢复最后窗口中的检查点状态,并且在失败的窗口边界期间重新发送在第二节点处接收到的所有输入消息。

    User Defined Functions Including Requests for Analytics by External Analytic Engines
    4.
    发明申请
    User Defined Functions Including Requests for Analytics by External Analytic Engines 审中-公开
    用户定义的函数包括外部分析引擎的分析请求

    公开(公告)号:US20150269234A1

    公开(公告)日:2015-09-24

    申请号:US14219209

    申请日:2014-03-19

    CPC classification number: G06F16/254

    Abstract: Described herein are techniques enabling a query engine to process a query comprising a user defined function. The user defined function can include a request for analytics to be performed by an external analytic engine. The query engine can retrieve data from a database in accordance with the query and send the data and instructions to perform the analytics to the external analytic engine. The query engine can then receive analytic results from the external analytic engine.

    Abstract translation: 这里描述的是使查询引擎能够处理包括用户定义的功能的查询的技术。 用户定义的功能可以包括由外部分析引擎执行的分析请求。 查询引擎可以根据查询从数据库检索数据,并发送数据和指令以对外部分析引擎执行分析。 然后,查询引擎可以从外部分析引擎接收分析结果。

    Resending messages
    6.
    发明授权
    Resending messages 有权
    重新发送消息

    公开(公告)号:US09304839B2

    公开(公告)日:2016-04-05

    申请号:US13873889

    申请日:2013-04-30

    CPC classification number: G06F9/546 G06F2209/546

    Abstract: A technique for resending messages can include determining if a particular message with a first unique identifier has been received by a recipient task among a number of potential recipient tasks in a distributed streaming system, notifying the number of potential recipient tasks to ignore the particular message with the first unique identifier, and resending the particular message with a second unique identifier.

    Abstract translation: 用于重新发送消息的技术可以包括确定在分布式流传输系统中的多个潜在接收者任务中的接收者任务中是否已经接收到具有第一唯一标识符的特定消息,通知潜在接收者任务的数量以忽略具有 第一唯一标识符,并且重新发送具有第二唯一标识符的特定消息。

    Processing Streaming Data With Open Executors
    8.
    发明申请
    Processing Streaming Data With Open Executors 有权
    使用Open Executors处理流数据

    公开(公告)号:US20150205601A1

    公开(公告)日:2015-07-23

    申请号:US14416610

    申请日:2012-10-26

    Abstract: Processing streaming data with open executors includes receiving input data at a computation dataflow station where the computation dataflow station contains a computation file and an open executor that accepts code plug-ins, converting contents of the computation file into a program string with the code plug-ins from a system library, and launching the program string together with the input data to calculate an output with a graphics processing unit.

    Abstract translation: 使用开放式执行器处理流数据包括在计算数据流站接收输入数据,其中计算数据流站包含计算文件和接受代码插件的开放执行器,将计算文件的内容转换成具有代码插件的程序串, 并将程序串与输入数据一起启动,以使用图形处理单元计算输出。

    QUERIES INVOLVING MULTIPLE DATABASES AND EXECUTION ENGINES
    10.
    发明申请
    QUERIES INVOLVING MULTIPLE DATABASES AND EXECUTION ENGINES 审中-公开
    涉及多个数据库和执行机构的疑问

    公开(公告)号:US20160140205A1

    公开(公告)日:2016-05-19

    申请号:US14787302

    申请日:2013-08-29

    CPC classification number: G06F16/283 G06F16/24568 G06F16/2471 G06F16/254

    Abstract: Described herein are techniques for handling a query that uses first data from a first database and second data from a second database. The first database is accessible via a first execution engine, and the second database is accessible via a second execution engine. A sub-query of the query can be sent to the second execution engine for execution on the second database. Streaming results of the sub-query can be received by the first execution engine.

    Abstract translation: 这里描述的是用于处理使用来自第一数据库的第一数据和来自第二数据库的第二数据的查询的技术。 第一个数据库可以通过第一个执行引擎访问,第二个数据库可以通过第二个执行引擎访问。 可以将查询的子查询发送到第二执行引擎以在第二数据库上执行。 子查询的流结果可以由第一执行引擎接收。

Patent Agency Ranking