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

1. 发明授权

US08032554B2 Stream data processing method and system 有权
标题翻译：流数据处理方法和系统
公开(公告)号：US08032554B2
公开(公告)日：2011-10-04
申请号：US12537676
申请日：2009-08-07
申请人： Itaru Nishizawa , Tsuneyuki Imaki , Masanori Kawashima , Atsuro Handa
发明人： Itaru Nishizawa , Tsuneyuki Imaki , Masanori Kawashima , Atsuro Handa
IPC分类号： G06F17/30
CPC分类号： G06F17/30516 , G06F17/30489
摘要： Stream data is provided for realizing precise calculation processing to keep a constant memory usage of a query including a time-based window, and to take all of input data into consideration. A stream data processing server sections the time-based window into sub-windows each with a smaller width by a query time resolution change unit, and a query processing engine executes the aggregation processing based on the sub-window when receiving the stream data to generate an aggregation tuple, and calculates the calculation result of the query including the time-based window by aggregation processing on the aggregation tuple.
摘要翻译：流数据被提供用于实现精确的计算处理，以保持包括基于时间的窗口的查询的恒定的存储器使用，并考虑所有输入数据。流数据处理服务器通过查询时间分辨率改变单元将基于时间的窗口分割成具有较小宽度的子窗口，并且当接收到流数据生成时，查询处理引擎基于子窗口执行聚合处理聚合元组，并通过聚合元组上的聚合处理来计算包括基于时间窗口的查询的计算结果。

2. 发明授权

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.
摘要翻译：提供了一种用于使用流数据被插入到窗口中或从窗口中删除时生成的流元组的符号来管理排名信息的机制。用于仅生成排名计算结果的差分信息的机制，根据请求添加排名信息的机制，用于从差分信息生成和输出所有排名信息的接口，用于生成所有排名计算结果的机制，以及界面提供了使用这些机制。

3. 发明申请

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.
摘要翻译：流数据处理系统通过使用多个信息处理装置来限制在分发负载的情况下的通信流量的产生。全局查询分为多个进程。在每个划分的过程中，生成包括相应进程的本地查询，并将每个本地查询设置为彼此不同的查询处理设备。此外，顺序地在多个查询处理装置之间传送流数据，以便在每个查询处理装置中执行本地查询。此时，整个流数据不会在查询处理装置之间依次发送。相应流数据的至少一部分被存储在代理设备中。当从位于紧邻的信息处理装置接收到的数据不包含本地查询的目标数据时，查询处理装置从代理装置读取对应的数据并执行本地查询。

4. 发明授权

US07849227B2 Stream data processing method and computer systems 有权
标题翻译：流数据处理方法和计算机系统
公开(公告)号：US07849227B2
公开(公告)日：2010-12-07
申请号：US12230289
申请日：2008-08-27
申请人： Toshihiko Kashiyama , Itaru Nishizawa , Tsuneyuki Imaki
发明人： Toshihiko Kashiyama , Itaru Nishizawa , Tsuneyuki Imaki
IPC分类号： G06F3/00 , G06F7/00 , G06Q10/00
CPC分类号： G06F17/30477
摘要： Provided is a stream data processing method that can effectively handle delay data. In the stream data processing method of processing data whose lifetime is defined by a window, an operation result excluding a delay tuple is immediately output along with an unconfirmed flag according to delay processing HBT while a midway processing result necessary for reproduction is retained along with the lifetime, and when the delay tuple arrives, a correct processing result is calculated from the delay tuple and the processing result restore tuple.
摘要翻译：提供可以有效处理延迟数据的流数据处理方法。在处理由窗口定义其寿命的数据的流数据处理方法中，除了延迟元组之外的操作结果与根据延迟处理HBT的未确认标志一起被直接输出，而再现所需的中途处理结果与并且当延迟元组到达时，从延迟元组和处理结果恢复元组计算出正确的处理结果。

5. 发明申请

US20100138438A1 Stream data processing control method, stream data processing apparatus, and stream data processing control program 有权
标题翻译：流数据处理控制方法，流数据处理装置和流数据处理控制程序
公开(公告)号：US20100138438A1
公开(公告)日：2010-06-03
申请号：US12457577
申请日：2009-06-16
申请人： Satoshi Torikai , Shinichi Tanaka , Itaru Nishizawa , Tsuneyuki Imaki
发明人： Satoshi Torikai , Shinichi Tanaka , Itaru Nishizawa , Tsuneyuki Imaki
IPC分类号： G06F17/30 , G06F15/16
CPC分类号： G06F17/30516
摘要： Provided is a stream data processing control method of controlling a stream data processing apparatus for receiving data added with time information in time series, and processing the data with a registered query therein, the stream data processing apparatus including the query for processing the data, a window in which the received data is stored, and control management information including a control code for identifying the content of the controlling, the method including the steps of: creating data including the control code based on the control management information; determining whether or not the data stored in the window includes the control code in a case where the received data is stored in the window; and controlling the stream data processing apparatus based on the control code included in the data if the data stored in the window includes the control code.
摘要翻译：提供了一种流数据处理控制方法，用于控制用于接收时间序列中添加有时间信息的数据的流数据处理装置，并且在其中处理具有注册查询的数据，流数据处理装置包括用于处理数据的查询，存储接收到的数据的窗口以及包括用于识别控制内容的控制代码的控制管理信息，所述方法包括以下步骤：基于所述控制管理信息创建包括所述控制代码的数据; 在接收到的数据存储在窗口中的情况下，确定存储在窗口中的数据是否包括控制代码; 以及如果存储在窗口中的数据包括控制代码，则基于包括在数据中的控制代码来控制流数据处理装置。

6. 发明申请

US20080256146A1 Query processing method for stream data processing systems 有权
公开(公告)号：US20080256146A1
公开(公告)日：2008-10-16
申请号：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.

7. 发明申请

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.
摘要翻译：在会议期间获得复数参与者的声音，并且实时显示每秒更改的参与者的对话情况，从而可以提供会议可视化系统以触发更积极的讨论。从与多个参与者相关联的多个语音收集单元收集的语音数据由语音处理服务器处理以提取语音信息。语音信息被顺序地输入到聚合服务器。通过聚合服务器的流数据处理单元对语音信息进行查询处理，从而生成活动数据，例如会议中的参与者的演讲的累积值。显示处理单元通过使用圆的大小和基于活动数据的线的厚度来可视化并显示参与者的对话情况。

8. 发明申请

US20070288459A1 Stream data processing method cooperable with reference external data 有权
标题翻译：流数据处理方法与参考外部数据配合使用
公开(公告)号：US20070288459A1
公开(公告)日：2007-12-13
申请号：US11502474
申请日：2006-08-11
申请人： Toshihiko Kashiyama , Itaru Nishizawa , Tsuneyuki Imaki
发明人： Toshihiko Kashiyama , Itaru Nishizawa , Tsuneyuki Imaki
IPC分类号： G06F17/30
CPC分类号： G06F17/30286
摘要： Provided is a stream data processing method cooperable with external data in real time. By providing a stream predict cache corresponding to a hierarchical cache of relation data predicted as being a data matching target with stream data, the number of accesses to a database is reduced to improve performance. Data to be stored in the stream predict cache is determined based on a characteristic of the stream data input by a user or monitoring information obtained by monitoring the stream data.
摘要翻译：提供与外部数据实时配合的流数据处理方法。通过提供与预测为具有流数据的数据匹配目标的关系数据的分级缓存相对应的流预测缓存，减少对数据库的访问次数以提高性能。基于由用户输入的流数据的特性或通过监视流数据获得的监视信息来确定要存储在流预测缓存中的数据。

9. 发明授权

US08495082B2 Stream data processing method cooperable with reference external data 有权
标题翻译：流数据处理方法与参考外部数据配合使用
公开(公告)号：US08495082B2
公开(公告)日：2013-07-23
申请号：US11502474
申请日：2006-08-11
申请人： Toshihiko Kashiyama , Itaru Nishizawa , Tsuneyuki Imaki
发明人： Toshihiko Kashiyama , Itaru Nishizawa , Tsuneyuki Imaki
IPC分类号： G06F17/30
CPC分类号： G06F17/30286
摘要： Provided is a stream data processing method cooperable with external data in real time. By providing a stream predict cache corresponding to a hierarchical cache of relation data predicted as being a data matching target with stream data, the number of accesses to a database is reduced to improve performance. Data to be stored in the stream predict cache is determined based on a characteristic of the stream data input by a user or monitoring information obtained by monitoring the stream data.
摘要翻译：提供与外部数据实时配合的流数据处理方法。通过提供与预测为具有流数据的数据匹配目标的关系数据的分级缓存相对应的流预测缓存，减少对数据库的访问次数以提高性能。基于由用户输入的流数据的特性或通过监视流数据获得的监视信息来确定要存储在流预测缓存中的数据。

10. 发明授权

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.
摘要翻译：在会议期间获得复数参与者的声音，并且实时显示每秒更改的参与者的对话情况，从而可以提供会议可视化系统以触发更积极的讨论。从与多个参与者相关联的多个语音收集单元收集的语音数据由语音处理服务器处理以提取语音信息。语音信息被顺序地输入到聚合服务器。通过聚合服务器的流数据处理单元对语音信息进行查询处理，从而生成活动数据，例如会议中的参与者的演讲的累积值。显示处理单元通过使用圆的大小和基于活动数据的线的厚度来可视化并显示参与者的对话情况。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式