会员体验
专利管家(专利管理)
工作空间(专利管理)
风险监控(情报监控)
数据分析(专利分析)
侵权分析(诉讼无效)
联系我们
交流群
官方交流:
QQ群: 891211   
微信请扫码    >>>
现在联系顾问~
热词
    • 3. 发明申请
    • COMPUTER SYSTEM FOR PROCESSING STREAM DATA
    • 用于处理流数据的计算机系统
    • US20110040746A1
    • 2011-02-17
    • US12715289
    • 2010-03-01
    • Atsuro HandaKazuho TanakaSatoru WatanabeTomohiro HanaiKazunori Tamura
    • Atsuro HandaKazuho TanakaSatoru WatanabeTomohiro HanaiKazunori Tamura
    • G06F17/30
    • G06F16/24568
    • It is provided a computer system for processing stream data, in which queries that are set in advance are executed to output a result. The queries include a first query, a second query and a third query. The first query is executed to output a first intermediate result. The second query is executed to output a second intermediate result. The third query is executed with inputting the first intermediate result and the second intermediate result to output the result. The computer system extracts first contribution information including part of the first stream data contribute to the first intermediate result, extracts second contribution information including part of the first stream data contribute to the second intermediate result, extracts third contribution information including part of the first stream data contribute to the result, and holds relation between the result and the third contribution information.
    • 提供了一种用于处理流数据的计算机系统,其中执行预先设置的查询以输出结果。 查询包括第一个查询,第二个查询和第三个查询。 执行第一个查询以输出第一个中间结果。 执行第二查询以输出第二中间结果。 通过输入第一中间结果和第二中间结果来执行第三查询以输出结果。 计算机系统提取包括贡献于第一中间结果的第一流数据的一部分的第一贡献信息,提取包括贡献于第二中间结果的第一流数据的部分的第二贡献信息,提取包括第一流数据的一部分的第三贡献信息 对结果做出贡献,并将结果与​​第三个贡献信息保持关系。
    • 4. 发明申请
    • FAILURE RECOVERY METHOD, COMPUTER SYSTEM, AND STORAGE MEDIUM RECORDED FAILURE RECOVERY PROGRAM FOR A STREAM DATA PROCESSING SYSTEM
    • 数据处理系统的故障恢复方法,计算机系统和存储介质记录故障恢复程序
    • US20100232286A1
    • 2010-09-16
    • US12644973
    • 2009-12-22
    • Noriaki TAKAHASHISatoru WatanabeTomohiro Hanai
    • Noriaki TAKAHASHISatoru WatanabeTomohiro Hanai
    • H04L12/26
    • G06F11/2097G06F11/2038G06F11/2048G06F2201/835
    • Provided is a failure recovery method for switching to a standby system if a failure occurs in an active system, which allows reduction of loads on the standby system and a network. A computer system, which receives data to which timestamp information is appended in a chronological order and processes the received data by registered queries, includes the active system for processing the received data and the standby system for processing the received data instead of the active system upon occurrence of a failure. The active system processes the received data by the respective queries according to a predefined sequence, and transmits results obtained from the received data by the respective queries to the standby system as intermediate data on a query basis at a predetermined timing. The standby system restores the data by processing the received data and the intermediate data if a failure occurs in the active system.
    • 提供了如果在活动系统中发生故障而切换到备用系统的故障恢复方法,这允许减少备用系统和网络上的负载。 接收按时间顺序接收时间戳信息的数据并通过注册查询处理接收到的数据的计算机系统包括用于处理接收到的数据的活动系统和用于处理接收到的数据而不是主动系统的备用系统 发生故障。 活动系统根据预定义的顺序对相应查询处理接收到的数据,并且在预定的定时将基于各个查询的接收数据获得的结果作为中间数据在查询的基础上发送到备用系统。 如果在活动系统中发生故障,则备用系统通过处理接收到的数据和中间数据来恢复数据。
    • 5. 发明授权
    • Failure recovery method, computer system, and storage medium recorded failure recovery program for a stream data processing system
    • 故障恢复方法,计算机系统和存储介质记录了流数据处理系统的故障恢复程序
    • US08369207B2
    • 2013-02-05
    • US12644973
    • 2009-12-22
    • Noriaki TakahashiSatoru WatanabeTomohiro Hanai
    • Noriaki TakahashiSatoru WatanabeTomohiro Hanai
    • G06F11/00
    • G06F11/2097G06F11/2038G06F11/2048G06F2201/835
    • Provided is a failure recovery method for switching to a standby system if a failure occurs in an active system, which allows reduction of loads on the standby system and a network. A computer system, which receives data to which timestamp information is appended in a chronological order and processes the received data by registered queries, includes the active system for processing the received data and the standby system for processing the received data instead of the active system upon occurrence of a failure. The active system processes the received data by the respective queries according to a predefined sequence, and transmits results obtained from the received data by the respective queries to the standby system as intermediate data on a query basis at a predetermined timing. The standby system restores the data by processing the received data and the intermediate data if a failure occurs in the active system.
    • 提供了如果在活动系统中发生故障而切换到备用系统的故障恢复方法,这允许减少备用系统和网络上的负载。 接收按时间顺序接收时间戳信息的数据并通过注册查询处理接收到的数据的计算机系统包括用于处理接收到的数据的活动系统和用于处理接收到的数据而不是主动系统的备用系统 发生故障。 活动系统根据预定义的顺序对相应查询处理接收到的数据,并且在预定的定时将基于各个查询的接收数据获得的结果作为中间数据在查询的基础上发送到备用系统。 如果在活动系统中发生故障,则备用系统通过处理接收到的数据和中间数据来恢复数据。
    • 6. 发明授权
    • Processing method, and computer for fault recovery
    • 处理方法和故障恢复计算机
    • US08276019B2
    • 2012-09-25
    • US12536601
    • 2009-08-06
    • Satoru WatanabeTomohiro Hanai
    • Satoru WatanabeTomohiro Hanai
    • G06F11/00
    • G06F11/1471G06F11/1438
    • A computer for the stream data processing system includes a query recovery point management table. A recovery point management section determines a recovery point for the stream data processing system by identifying an oldest one of input tuples used for generating output tuples, which are managed, or an earlier tuple through the use of a query recovery point stored in the query recovery point management table, and transmits the determined recovery point for the stream data processing system to an additional computer. The additional computer stores the last-received recovery point for the stream data processing system in a checkpoint file. When the computer for the stream data processing system recovers from a fault, the additional computer transmits the data succeeding the stored recovery point to the computer for the stream data processing system.
    • 用于流数据处理系统的计算机包括查询恢复点管理表。 恢复点管理部分通过使用存储在查询恢复中的查询恢复点来识别用于生成被管理的输出元组的最旧的输入元组或者较早的元组来确定流数据处理系统的恢复点 点管理表,并将确定的流数据处理系统的恢复点发送到附加计算机。 附加计算机将流数据处理系统的最后接收的恢复点存储在检查点文件中。 当流数据处理系统的计算机从故障中恢复时,附加计算机将存储的恢复点之后的数据发送到用于流数据处理系统的计算机。
    • 7. 发明授权
    • Method and device for guaranteeing performance in stream data processing
    • 用于保证流数据处理性能的方法和设备
    • US09247025B2
    • 2016-01-26
    • US13820048
    • 2011-01-26
    • Takao SakuraiTomohiro Hanai
    • Takao SakuraiTomohiro Hanai
    • G06F15/16H04L29/06H04L12/811H04L12/835H04L12/801
    • H04L67/42H04L47/10H04L47/12H04L47/30H04L47/38
    • A method and device for guaranteeing performance of stream data processing wherein a latency guarantee and a processing accuracy guarantee are possible while ensuring a real-time property. An execution system determination unit evaluates an amount of data currently present in a queue of an input data reception unit, calculation time, and the processing accuracy. Then, during a query process, if the amount of data in the queue increases for some reason, and is likely to be larger than the requested latency, the execution system determination unit changes the system to a calculation system by which the latency can be reduced within a range that a final quality can be allowed, on the basis of the evaluation result. Under the condition that the accuracy is reduced, if the latency is likely to be greatly lower than the requested latency, the system changes to a calculation system having a higher processing accuracy.
    • 一种用于保证流数据处理的性能的方法和装置,其中在确保实时性的同时,等待时间保证和处理精度保证是可能的。 执行系统确定单元评估当前存在于输入数据接收单元的队列中的数据量,计算时间和处理精度。 然后,在查询处理期间,如果由于某些原因队列中的数据量增加并且可能大于所请求的等待时间,则执行系统确定单元将系统改变为可以减少等待时间的计算系统 在评估结果的基础上,在可以允许最终质量的范围内。 在准确性降低的条件下,如果延迟可能远低于所请求的延迟,则系统改变为具有较高处理精度的计算系统。
    • 9. 发明授权
    • System and method for adding a standby computer into clustered computer system
    • 将备用计算机添加到群集计算机系统中的系统和方法
    • US08195777B2
    • 2012-06-05
    • US12071774
    • 2008-02-26
    • Tomohiro HanaiNorihiro HaraTsunehiko Baba
    • Tomohiro HanaiNorihiro HaraTsunehiko Baba
    • G06F15/177
    • G06F15/16
    • There is provided a method of adding a new computer as a standby computer to a computer system that includes an active computer for performing service processing and a standby computer for storing replica of data stored in the active computer. The replica of the data stored in the standby computer is updated when the data stored in the active computer is updated. The method comprising the steps of: selecting the standby computer from the computer system; transferring the replica of the data stored in the selected standby computer to the new computer; and transferring update information on data updated in the active computer after the transferring the replica of the data is started, to the new computer.
    • 提供了一种将新计算机作为备用计算机添加到包括用于执行服务处理的活动计算机和用于存储存储在活动计算机中的数据的备用计算机的计算机系统的方法。 当更新存储在活动计算机中的数据时,更新存储在备用计算机中的数据的副本。 该方法包括以下步骤:从计算机系统中选择备用计算机; 将存储在所选待机计算机中的数据的副本传送到新计算机; 并且在将数据的副本传送到新的计算机之后,传送关于在活动计算机中更新的数据的更新信息。