专利快速检索-快速检索全球专利，免费商用专利数据库-IPRDB

1. 发明申请

US20130086418A1 DATA PROCESSING FAILURE RECOVERY METHOD, SYSTEM AND PROGRAM 有权
标题翻译：数据处理故障恢复方法，系统和程序
公开(公告)号：US20130086418A1
公开(公告)日：2013-04-04
申请号：US13701847
申请日：2010-08-24
申请人： Takao Sakurai , Masashi Egi , Tsuneyuki Imaki
发明人： Takao Sakurai , Masashi Egi , Tsuneyuki Imaki
IPC分类号： G06F11/14
CPC分类号： G06F11/1412 , G06F11/1438 , G06F11/1446 , G06F11/1448 , G06F11/1469 , G06F11/1471 , G06F2201/84
摘要： When reproducing the running state after a failure has occurred in stream data processing, all window operations are used while minimizing the storage amount necessary for obtaining backup data. While an operator is performing stream data processing in response to a query, a query analysis unit analyzes the operator, which holds the running state of the window, etc., and the recovery points of said operator. When obtaining backup data, a backup data management unit manages the capacity necessary to obtain snapshots of the analyzed recovery points, calculates the storage area capacity needed for backing up input data up to each recovery point and the storage area capacity needed to obtain a snapshot for a window that cannot be reproduced in that way, and records the execution state by selecting a recovery point which minimizes the total value of necessary storage capacity.
摘要翻译：当在流数据处理中发生故障之后再现运行状态时，使用所有窗口操作，同时最小化获取备份数据所需的存储量。当操作者响应于查询执行流数据处理时，查询分析单元分析保持窗口的运行状态等的操作者和所述操作者的恢复点。在获取备份数据时，备份数据管理单元管理获取分析的恢复点的快照所需的容量，计算直到每个恢复点备份输入数据所需的存储区容量以及获取快照所需的存储区容量不能以这种方式再现的窗口，并且通过选择使所需存储容量的总值最小化的恢复点来记录执行状态。

2. 发明授权

US09037905B2 Data processing failure recovery method, system and program 有权
标题翻译：数据处理失败恢复方法，系统和程序
公开(公告)号：US09037905B2
公开(公告)日：2015-05-19
申请号：US13701847
申请日：2010-08-24
申请人： Takao Sakurai , Masashi Egi , Tsuneyuki Imaki
发明人： Takao Sakurai , Masashi Egi , Tsuneyuki Imaki
IPC分类号： G06F11/14
CPC分类号： G06F11/1412 , G06F11/1438 , G06F11/1446 , G06F11/1448 , G06F11/1469 , G06F11/1471 , G06F2201/84
摘要： When reproducing the running state after a failure has occurred in stream data processing, all window operations are used while minimizing the storage amount necessary for obtaining backup data. While an operator is performing stream data processing in response to a query, a query analysis unit analyzes the operator, which holds the running state of the window, etc., and the recovery points of said operator. When obtaining backup data, a backup data management unit manages the capacity necessary to obtain snapshots of the analyzed recovery points, calculates the storage area capacity needed for backing up input data up to each recovery point and the storage area capacity needed to obtain a snapshot for a window that cannot be reproduced in that way, and records the execution state by selecting a recovery point which minimizes the total value of necessary storage capacity.
摘要翻译：当在流数据处理中发生故障之后再现运行状态时，使用所有窗口操作，同时最小化获取备份数据所需的存储量。当操作者响应于查询执行流数据处理时，查询分析单元分析保持窗口的运行状态等的操作者和所述操作者的恢复点。在获取备份数据时，备份数据管理单元管理获取分析的恢复点的快照所需的容量，计算直到每个恢复点备份输入数据所需的存储区容量以及获取快照所需的存储区容量不能以这种方式再现的窗口，并且通过选择使所需存储容量的总值最小化的恢复点来记录执行状态。

3. 发明申请

US20080255847A1 Meeting visualization system 有权
标题翻译：会议可视化系统
公开(公告)号：US20080255847A1
公开(公告)日：2008-10-16
申请号：US12078520
申请日：2008-04-01
申请人： Norihiko Moriwaki , Nobuo Sato , Tsuneyuki Imaki , Toshihiko Kashiyama , Itaru Nishizawa , Masashi Egi
发明人： Norihiko Moriwaki , Nobuo Sato , Tsuneyuki Imaki , Toshihiko Kashiyama , Itaru Nishizawa , Masashi Egi
IPC分类号： G10L11/00
CPC分类号： G10L21/06 , G10L25/78
摘要： Voice of plural participants during a meeting is obtained and dialogue situations of the participants that change every second are displayed in real time, so that it is possible to provide a meeting visualization system for triggering more positive discussions. Voice data collected from plural voice collecting units associated with plural participants is processed by a voice processing server to extract speech information. The speech information is sequentially input to an aggregation server. A query process is performed for the speech information by a stream data processing unit of the aggregation server, so that activity data such as the accumulation value of speeches of the participants in the meeting is generated. A display processing unit visualizes and displays dialogue situations of the participants by using the sizes of circles and the thicknesses of lines on the basis of the activity data.
摘要翻译：在会议期间获得复数参与者的声音，并且实时显示每秒更改的参与者的对话情况，从而可以提供会议可视化系统以触发更积极的讨论。从与多个参与者相关联的多个语音收集单元收集的语音数据由语音处理服务器处理以提取语音信息。语音信息被顺序地输入到聚合服务器。通过聚合服务器的流数据处理单元对语音信息进行查询处理，从而生成活动数据，例如会议中的参与者的演讲的累积值。显示处理单元通过使用圆的大小和基于活动数据的线的厚度来可视化并显示参与者的对话情况。

4. 发明授权

US08290776B2 Meeting visualization system 有权
标题翻译：会议可视化系统
公开(公告)号：US08290776B2
公开(公告)日：2012-10-16
申请号：US12078520
申请日：2008-04-01
申请人： Norihiko Moriwaki , Nobuo Sato , Tsuneyuki Imaki , Toshihiko Kashiyama , Itaru Nishizawa , Masashi Egi
发明人： Norihiko Moriwaki , Nobuo Sato , Tsuneyuki Imaki , Toshihiko Kashiyama , Itaru Nishizawa , Masashi Egi
IPC分类号： G10L11/00
CPC分类号： G10L21/06 , G10L25/78
摘要： Voice of plural participants during a meeting is obtained and dialogue situations of the participants that change every second are displayed in real time, so that it is possible to provide a meeting visualization system for triggering more positive discussions. Voice data collected from plural voice collecting units associated with plural participants is processed by a voice processing server to extract speech information. The speech information is sequentially input to an aggregation server. A query process is performed for the speech information by a stream data processing unit of the aggregation server, so that activity data such as the accumulation value of speeches of the participants in the meeting is generated. A display processing unit visualizes and displays dialogue situations of the participants by using the sizes of circles and the thicknesses of lines on the basis of the activity data.
摘要翻译：在会议期间获得复数参与者的声音，并且实时显示每秒更改的参与者的对话情况，从而可以提供会议可视化系统以触发更积极的讨论。从与多个参与者相关联的多个语音收集单元收集的语音数据由语音处理服务器处理以提取语音信息。语音信息被顺序地输入到聚合服务器。通过聚合服务器的流数据处理单元对语音信息进行查询处理，从而生成活动数据，例如会议中的参与者的演讲的累积值。显示处理单元通过使用圆的大小和基于活动数据的线的厚度来可视化并显示参与者的对话情况。

5. 发明申请

US20130346441A1 STREAM DATA PROCESSING SERVER AND A NON-TRANSITORY COMPUTER-READABLE STORAGE MEDIUM STORING A STREAM DATA PROCESSING PROGRAM 有权
标题翻译：流数据处理服务器和非终端计算机可读存储介质存储流数据处理程序
公开(公告)号：US20130346441A1
公开(公告)日：2013-12-26
申请号：US14003838
申请日：2011-07-20
申请人： Tsuneyuki Imaki
发明人： Tsuneyuki Imaki
IPC分类号： G06F17/30
CPC分类号： G06F17/30424 , G06F17/30286 , G06F17/30595 , G06F17/30864 , G06F17/30867 , G06Q30/02 , H04L41/147 , H04N21/6473 , H04N21/8456 , H04N21/8547
摘要： A stream data processing server for processing stream data comprising a stream data processing module for cutting the plurality of pieces of data that are included within a processing range as a target out of the stream data by using a sliding window, and executing analyzing processing for the cut out plurality of pieces of data, the stream data processing module having an approximate expression; the approximate expression calculating module being configured to: determine one of the time stamps of the cut out plurality of pieces of data as a time origin; modify the time stamps of the cut out plurality of pieces of data to relative time values in relation to the determined time origin; and use the modified time stamps and the values of the plurality of pieces of data to calculate the approximate expression.
摘要翻译：一种流数据处理服务器，用于处理流数据，该数据流数据包括流数据处理模块，用于通过使用滑动窗口将包含在处理范围内的多条数据片段作为流数据切割出来，并且执行分析处理切出多条数据，流数据处理模块具有近似表达式; 所述近似表达式计算模块被配置为：确定所述切出的多条数据的时间戳之一作为时间原点; 将多个数据段的时间戳修改为相对于所确定的时间原点的相对时间值; 并使用修改的时间戳和多条数据的值来计算近似表达式。

6. 发明授权

US08335782B2 Ranking query processing method for stream data and stream data processing system having ranking query processing mechanism 有权
标题翻译：具有排序查询处理机制的流数据和流数据处理系统的排序查询处理方法
公开(公告)号：US08335782B2
公开(公告)日：2012-12-18
申请号：US12222413
申请日：2008-08-08
申请人： Itaru Nishizawa , Tsuneyuki Imaki , Toshihiko Kashiyama
发明人： Itaru Nishizawa , Tsuneyuki Imaki , Toshihiko Kashiyama
IPC分类号： G06F7/00 , G06F17/30
CPC分类号： G06F17/30516 , G06F17/3053
摘要： A mechanism for managing ranking information using a sign of a stream tuple generated when stream data is inserted into, or deleted from, a window is provided. A mechanism for generating only the differential information of ranking calculation results, a mechanism for adding ranking information according to a request, an interface for generating and outputting all ranking information from the differential information, a mechanism for generating all ranking calculation results, and an interface for using these mechanisms are provided.
摘要翻译：提供了一种用于使用流数据被插入到窗口中或从窗口中删除时生成的流元组的符号来管理排名信息的机制。用于仅生成排名计算结果的差分信息的机制，根据请求添加排名信息的机制，用于从差分信息生成和输出所有排名信息的接口，用于生成所有排名计算结果的机制，以及界面提供了使用这些机制。

7. 发明申请

US20110040827A1 STREAM DATA PROCESSING METHOD AND APPARATUS 有权
标题翻译：流数据处理方法和装置
公开(公告)号：US20110040827A1
公开(公告)日：2011-02-17
申请号：US12709412
申请日：2010-02-19
申请人： Satoshi Katsunuma , Tsuneyuki Imaki , Shinji Fujiwara
发明人： Satoshi Katsunuma , Tsuneyuki Imaki , Shinji Fujiwara
IPC分类号： G06F15/16 , G06F17/30
CPC分类号： G06F17/30516
摘要： A user specifies a group by a user-defined query. An input order is assured among data of a same group. By outputting data belonging to a same group from the same node, an order inputted for a necessary portion is assured. By outputting data belonging to different groups from another node, processing in plural nodes is achieved to avoid reduction in performance.
摘要翻译：用户通过用户定义的查询指定组。在同一组的数据中确保输入顺序。通过从同一节点输出属于同一组的数据，确保为必要部分输入的顺序。通过从另一个节点输出属于不同组的数据，实现了多个节点的处理，以避免性能下降。

8. 发明申请

US20070022092A1 Stream data processing system and stream data processing method 失效
标题翻译：流数据处理系统和流数据处理方法
公开(公告)号：US20070022092A1
公开(公告)日：2007-01-25
申请号：US11359540
申请日：2006-02-23
申请人： Itaru Nishizawa , Tsuneyuki Imaki
发明人： Itaru Nishizawa , Tsuneyuki Imaki
IPC分类号： G06F17/30
CPC分类号： G06F17/30516 , Y10S715/968
摘要： A stream data processing system restrains the generation of communication traffic in the case of distributing loads by using a plurality of information processing devices. The global query is divided into a plurality of processes. At every divided process, a local query which includes the corresponding process is generated and each local query is set to a query processing device different from each other. In addition, the stream data is transmitted among a plurality of query processing devices in order so as to execute the local query in each query processing device. At this time, the entire stream data does not transmitted among the query processing devices in order. At least a part of the corresponding stream data is stored in a proxy device. When data received from an information processing device located in immediately before does not include the target data of the local query, the query processing device reads the corresponding data from the proxy device and executes the local query.
摘要翻译：流数据处理系统通过使用多个信息处理装置来限制在分发负载的情况下的通信流量的产生。全局查询分为多个进程。在每个划分的过程中，生成包括相应进程的本地查询，并将每个本地查询设置为彼此不同的查询处理设备。此外，顺序地在多个查询处理装置之间传送流数据，以便在每个查询处理装置中执行本地查询。此时，整个流数据不会在查询处理装置之间依次发送。相应流数据的至少一部分被存储在代理设备中。当从位于紧邻的信息处理装置接收到的数据不包含本地查询的目标数据时，查询处理装置从代理装置读取对应的数据并执行本地查询。

9. 发明申请

US20130226909A1 Stream Data Processing Method and Device 审中-公开
标题翻译：流数据处理方法和设备
公开(公告)号：US20130226909A1
公开(公告)日：2013-08-29
申请号：US13824873
申请日：2010-10-06
申请人： Satoshi Katsunuma , Tsuneyuki Imaki , Itaru Nishizawa , Keiro Muro
发明人： Satoshi Katsunuma , Tsuneyuki Imaki , Itaru Nishizawa , Keiro Muro
IPC分类号： G06F17/30
CPC分类号： G06F16/248 , G06F16/24568
摘要： Provided is a stream data processing device for processing stream data composed of input data that includes time, the device having: a data input module for receiving the input data; a first key for designating, as data sets, the items of the input data for processing the input data in chronological order; a query recorder for receiving a stream data definition and a query definition, and generating an operator to process the input data; and a data executing module for determining the operator for processing the input data and outputting results; the input module sorting the received input data for each of the data sets according to the item designated by the first key, sorting the input data in chronological order for each of the data sets, and generating an input stream; and the data executing module processing the input stream with the operator for each of the data sets.
摘要翻译：提供一种流数据处理装置，用于处理由包括时间的输入数据组成的流数据，该装置具有：用于接收输入数据的数据输入模块; 用于指定作为数据集的用于按时间顺序处理输入数据的输入数据的项目的第一键; 用于接收流数据定义和查询定义的查询记录器，以及生成处理输入数据的操作者; 以及数据执行模块，用于确定用于处理输入数据并输出结果的操作者; 所述输入模块根据由所述第一密钥指定的项目对每个所述数据集合的接收到的输入数据进行排序，对于每个所述数据集按时间顺序排列所述输入数据，以及生成输入流; 并且数据执行模块与每个数据集的操作者处理输入流。

10. 发明授权

US07958108B2 Query processing method for stream data processing systems 有权
标题翻译：流数据处理系统的查询处理方法
公开(公告)号：US07958108B2
公开(公告)日：2011-06-07
申请号：US12213042
申请日：2008-06-13
申请人： Itaru Nishizawa , Tsuneyuki Imaki , Shinji Fujiwara
发明人： Itaru Nishizawa , Tsuneyuki Imaki , Shinji Fujiwara
IPC分类号： G06F17/30
CPC分类号： G06F17/30516 , Y10S707/99955
摘要： A stream data processing system capable of highly reliable and highly usable real time data processing, is provided with: (1) a mechanism of copying some or all of stream data, and archiving the stream data in a non-volatile memory to allow real time data and archive data to be used seamlessly; and (2) a mechanism of improving the performance of query processings by using a plurality of stream data processing systems cooperatively.
摘要翻译：具有高可靠性和高可用性的实时数据处理的流数据处理系统具有：（1）复制部分或全部流数据的机制，以及在非易失性存储器中存储流数据以允许实时无缝地使用数据和归档数据; 和（2）通过协同地使用多个流数据处理系统来提高查询处理的性能的机制。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式