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

1. 发明授权

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

2. 发明申请

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

3. 发明申请

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.
摘要翻译：提供一种流数据处理装置，用于处理由包括时间的输入数据组成的流数据，该装置具有：用于接收输入数据的数据输入模块; 用于指定作为数据集的用于按时间顺序处理输入数据的输入数据的项目的第一键; 用于接收流数据定义和查询定义的查询记录器，以及生成处理输入数据的操作者; 以及数据执行模块，用于确定用于处理输入数据并输出结果的操作者; 所述输入模块根据由所述第一密钥指定的项目对每个所述数据集合的接收到的输入数据进行排序，对于每个所述数据集按时间顺序排列所述输入数据，以及生成输入流; 并且数据执行模块与每个数据集的操作者处理输入流。

4. 发明授权

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）通过协同地使用多个流数据处理系统来提高查询处理的性能的机制。

5. 发明申请

US20090271529A1 Stream data processing method and computer systems 有权
标题翻译：流数据处理方法和计算机系统
公开(公告)号：US20090271529A1
公开(公告)日：2009-10-29
申请号：US12230289
申请日：2008-08-27
申请人： Toshihiko Kashiyama , Itaru Nishizawa , Tsuneyuki Imaki
发明人： Toshihiko Kashiyama , Itaru Nishizawa , Tsuneyuki Imaki
IPC分类号： G06F3/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的未确认标志一起被直接输出，而再现所需的中途处理结果与并且当延迟元组到达时，从延迟元组和处理结果恢复元组计算出正确的处理结果。

6. 发明申请

US20060277230A1 Query processing method for stream data processing systems 有权
标题翻译：流数据处理系统的查询处理方法
公开(公告)号：US20060277230A1
公开(公告)日：2006-12-07
申请号：US11195664
申请日：2005-08-03
申请人： 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）通过协同地使用多个流数据处理系统来提高查询处理的性能的机制。

7. 发明授权

US08402015B2 Method for processing stream data and system thereof 有权
标题翻译：流数据处理方法及其系统
公开(公告)号：US08402015B2
公开(公告)日：2013-03-19
申请号：US12542887
申请日：2009-08-18
申请人： Tsuneyuki Imaki , Itaru Nishizawa , Toshihiko Kashiyama
发明人： Tsuneyuki Imaki , Itaru Nishizawa , Toshihiko Kashiyama
IPC分类号： G06F17/30
CPC分类号： G06F17/30463 , G06F17/30442 , G06F17/30516
摘要： The present invention provides a method for processing stream data and a system thereof capable of implementing general data processing including recursive processing with low latency. In the system for processing stream data, a single operator graph is prepared from operator trees of a plurality of queries, an execution order of the operators is determined so that execution of a streaming operator is progressed in one way from an input to an output, the ignition time of an external ignition operator that inputs data from the outside of the system and an internal ignition operator that time-limitedly generates data is monitored, and an operator execution control unit repeats processing that completes the processing in the operator graph at the time according to the determined operator execution order, assuming the operator of the earliest ignition time as a start point.
摘要翻译：本发明提供一种用于处理流数据的方法及其系统，其能够实现包括具有低等待时间的递归处理的一般数据处理。在用于处理流数据的系统中，从多个查询的操作者树中准备单个运算符图，确定运算符的执行顺序，使得流式运算符的执行以一种方式从输入到输出进行，监视从系统外部输入数据的外部点火操作器的点火时间和时间有限地生成数据的内部点火操作器，并且操作者执行控制单元重复在该时刻完成操作者图中的处理的处理根据确定的操作者执行顺序，假定最早点火时间的操作者为起点。

8. 发明授权

US08095690B2 Machine-readable medium for storing a stream data processing program and computer system 有权
标题翻译：用于存储流数据处理程序和计算机系统的机器可读介质
公开(公告)号：US08095690B2
公开(公告)日：2012-01-10
申请号：US12606641
申请日：2009-10-27
申请人： Toshihiko Kashiyama , Itaru Nishizawa , Tsuneyuki Imaki
发明人： Toshihiko Kashiyama , Itaru Nishizawa , Tsuneyuki Imaki
IPC分类号： G06F3/00 , G06F7/00 , G06Q10/00
CPC分类号： G06Q40/04 , G06Q10/06 , G06Q10/109
摘要： In a stream data processing method in which part of stream data is defined as a processing target and the time control information which indicates the advance of the time is inserted into the stream data, time information of the received stream data is stored in a next ignition time holding area as an ignition time. A processing module for generating the time control information at a time different from the time of reception of the stream data is extracted out of a query that indicates how the stream data is to be processed. Based on the extracted processing module and the time information indicating the time of the reception of the stream data, the ignition time is calculated and stored in the next ignition time holding area. The time generation module inserts the time control information at the ignition time held in the next ignition time holding area.
摘要翻译：在流数据处理方法中，将流数据的一部分定义为处理对象，并将指示时间推进的时间控制信息插入到流数据中，接收的流数据的时间信息被存储在下一个点火时间保持区域作为点火时间。用于在与流数据的接收时间不同的时间产生时间控制信息的处理模块从指示如何处理流数据的查询中提取出来。基于提取的处理模块和指示流数据的接收时间的时间信息，计算点火时间并将其存储在下一个点火时间保持区域中。时间生成模块将时间控制信息插入保持在下一个点火时间保持区域的点火时间。

9. 发明授权

US07949653B2 Stream data processing method and stream data processing system 有权
标题翻译：流数据处理方法和流数据处理系统
公开(公告)号：US07949653B2
公开(公告)日：2011-05-24
申请号：US12035094
申请日：2008-02-21
申请人： Michiko Tanaka , Itaru Nishizawa , Toshihiko Kashiyama , Tsuneyuki Imaki
发明人： Michiko Tanaka , Itaru Nishizawa , Toshihiko Kashiyama , Tsuneyuki Imaki
IPC分类号： G06F17/30 , G06F7/00
CPC分类号： G06F17/30516
摘要： In order to make real time and the avoidance of risk compatible according to the contents of processing by an application, an index ID applying module applies an index computed utilizing streams before and after stream data to the stream data, computes the index again according to a stream that varies every moment, applies an index computed based upon the index of the stream data to the result of the processing of the stream data according to a predetermined procedure and outputs it. An application that receives the result of the processing and the index of the result of the processing switches processing depending upon the index.
摘要翻译：为了使实时和根据应用的处理内容避免风险兼容，索引ID应用模块将流数据之前和之后的流计算的索引应用于流数据，根据一个数据重新计算索引每一时刻变化的流将根据流数据的索引计算的索引根据预定的过程应用到流数据的处理结果，并将其输出。接收处理结果的应用程序和处理结果的索引根据索引进行切换处理。

10. 发明申请

US20100106853A1 MACHINE-READABLE MEDIUM FOR STORING A STREAM DATA PROCESSING PROGRAM AND COMPUTER SYSTEM 有权
标题翻译：用于存储流数据处理程序和计算机系统的机器可读介质
公开(公告)号：US20100106853A1
公开(公告)日：2010-04-29
申请号：US12606641
申请日：2009-10-27
申请人： Toshihiko KASHIYAMA , Itaru Nishizawa , Tsuneyuki Imaki
发明人： Toshihiko KASHIYAMA , Itaru Nishizawa , Tsuneyuki Imaki
IPC分类号： G06F15/16
CPC分类号： G06Q40/04 , G06Q10/06 , G06Q10/109
摘要： In a stream data processing method in which part of stream data is defined as a processing target and the time control information which indicates the advance of the time is inserted into the stream data, time information of the received stream data is stored in a next ignition time holding area as an ignition time. A processing module for generating the time control information at a time different from the time of reception of the stream data is extracted out of a query that indicates how the stream data is to be processed. Based on the extracted processing module and the time information indicating the time of the reception of the stream data, the ignition time is calculated and stored in the next ignition time holding area. The time generation module inserts the time control information at the ignition time held in the next ignition time holding area.
摘要翻译：在流数据处理方法中，将流数据的一部分定义为处理对象，并将指示时间推进的时间控制信息插入到流数据中，接收的流数据的时间信息被存储在下一个点火时间保持区域作为点火时间。用于在与流数据的接收时间不同的时间产生时间控制信息的处理模块从指示如何处理流数据的查询中提取出来。基于提取的处理模块和指示流数据的接收时间的时间信息，计算点火时间并将其存储在下一个点火时间保持区域中。时间生成模块将时间控制信息插入保持在下一个点火时间保持区域的点火时间。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式