公开(公告)号：US08463809B2

公开(公告)日：2013-06-11

申请号：US12562516

申请日：2009-09-18

申请人： Daisuke Ito ,  Shinji Fujiwara ,  Itaru Nishizawa ,  Akinori Asahara

发明人： Daisuke Ito ,  Shinji Fujiwara ,  Itaru Nishizawa ,  Akinori Asahara

IPC分类号： G06F17/30

CPC分类号： G06F17/30516

摘要： In executing query distributed processing in a computer system having a plurality of computers, a query and a sliding window are inherited between different computers. If a tuple having a new principal key value is detected when a query is to be executed, a relevant individual query and a relevant sliding window are inherited between computers, and further a sliding window of a relevant common query is inherited between computers.

摘要翻译： 在具有多个计算机的计算机系统中执行查询分布式处理时，在不同的计算机之间继承查询和滑动窗口。 如果在执行查询时检测到具有新的主键值的元组，则在计算机之间继承相关的单独查询和相关的滑动窗口，并且进一步在计算机之间继承相关通用查询的滑动窗口。

公开(公告)号：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.

公开(公告)号：US07403959B2

公开(公告)日：2008-07-22

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

公开(公告)号：US20060253435A1

公开(公告)日：2006-11-09

申请号：US11485272

申请日：2006-07-13

申请人： Itaru Nishizawa ,  Shinji Fujiwara ,  Kazutomo Ushijima ,  Shigekazu Inohara

发明人： Itaru Nishizawa ,  Shinji Fujiwara ,  Kazutomo Ushijima ,  Shigekazu Inohara

IPC分类号： G06F17/30

CPC分类号： G06F16/24524 ,  G06F16/25 ,  G06F16/27 ,  Y10S707/99952

摘要： In order to realize a practical data warehouse system with the use of a network in a distributed environment, for example, data collectors for creating/managing each replica of server data for clients shown in FIG. 1 are connected to a network. A data collector holds a data request condition given from a user via a client and negotiates with a server which supplies data according to such resources as a storage unit, a CPU, etc., usable by the data collector, thereby the range and quality of the data for which a replica is to be created can be adjusted. For query processing, a part or the whole of a query from a client is processed with the use of a replica created in the data collector. Queries which cannot be processed with any replica in the data collector are transferred to the server. Because a replica created in the data collector can be used to process a query from a client in such a way, the server load can be reduced.

摘要翻译： 为了在分布式环境中实现使用网络的实用数据仓库系统，例如，用于创建/管理图1所示的客户端的服务器数据的每个副本的数据收集器。 1连接到网络。 数据收集器通过客户端保存从用户发出的数据请求条件，并与根据数据收集器可使用的存储单元，CPU等资源提供数据的服务器进行协商，从而达到数据收集器的范围和质量 可以调整要创建副本的数据。 对于查询处理，使用在数据收集器中创建的副本来处理来自客户机的部分或全部查询。 无法用数据收集器中的任何副本处理的查询将传输到服务器。 由于在数据收集器中创建的副本可以用于以这种方式处理来自客户端的查询，所以可以减少服务器负载。

公开(公告)号：US07111019B1

公开(公告)日：2006-09-19

申请号：US09435034

申请日：1999-11-05

申请人： Itaru Nishizawa ,  Shinji Fujiwara ,  Kazutomo Ushijima ,  Shigekazu Inohara

发明人： Itaru Nishizawa ,  Shinji Fujiwara ,  Kazutomo Ushijima ,  Shigekazu Inohara

IPC分类号： G06F12/00 ,  G06F17/30 ,  G06F7/00

CPC分类号： G06F17/30433 ,  G06F17/30557 ,  G06F17/30575 ,  Y10S707/99952

摘要： In order to realize a practical data warehouse system with the use of a network in a distributed environment, for example, data collectors (101 and 102) for creating/managing each replica of server data for clients (103 and 104) as shown in FIG. 1 are connected to a network (113). A data collector holds a data request condition given from a user via a client and negotiates with a server (114, 122) which supplies data according to such resources as a storage unit, a CPU, etc. usable by the data collector, thereby the range and quality of the data for which a replica is to be created can be adjusted. For query processing, a part or the whole of a query from a client is processed with the use of a replica (123) created in the data collector. Queries which cannot be processed with any replica in the data collector are transferred to the server. Because a replica created in the data collector can be used to process a query from a client device such a way, the server load can be reduced.

摘要翻译： 为了在分布式环境中实现使用网络的实用数据仓库系统，例如，用于创建/管理客户机（103和104）的每个服务器数据副本的数据收集器（101和102），如图 。 1连接到网络（113）。 数据收集器保存从用户经由客户端给出的数据请求条件，并与根据数据收集器可用的诸如存储单元，CPU等的资源提供数据的服务器（114,122）进行协商，由此 可以调整要创建副本的数据的范围和质量。 对于查询处理，使用在数据收集器中创建的副本（123）来处理来自客户端的查询的一部分或全部。 无法用数据收集器中的任何副本处理的查询将传输到服务器。 由于在数据收集器中创建的副本可以用于以这种方式处理来自客户端设备的查询，所以可以减少服务器负载。

公开(公告)号：US06381601B1

公开(公告)日：2002-04-30

申请号：US09469615

申请日：1999-12-22

申请人： Shinji Fujiwara ,  Kazutomo Ushijima ,  Itaru Nishizawa

发明人： Shinji Fujiwara ,  Kazutomo Ushijima ,  Itaru Nishizawa

IPC分类号： G06F1730

CPC分类号： G06F17/30489 ,  Y10S707/954 ,  Y10S707/99937

摘要： In order to realize high speed process for grouping the records having the identical values of one or more columns of the input list, the input list is canned, a hash value is generated using a hash function in which a value of the column as the non-vacant partial aggregation of the columns for the grouping is used as the argument, and it is determined whether two or more records having the hash values exist or not. The input list is scanned again and the calculating process of the aggregation columns is immediately executed for the records having the hash value for which it is determined by the first scanning that there is only one record having the identical hash value, the result of such calculating process is output and the records are defined as the input of the ordinary grouping process for the records which are determined to exist as the two or more records.

摘要翻译： 为了实现用于对具有输入列表的一个或多个列的相同值的记录进行分组的高速处理，输入列表被装入，使用散列函数生成哈希值，其中列的值为非 用于分组的列的消除性部分聚合用作参数，并且确定是否存在具有哈希值的两个或更多个记录。 再次对输入列表进行扫描，并且立即对具有通过第一次扫描确定的散列值的记录执行聚合列的计算处理，即只有一个具有相同散列值的记录，这样计算的结果 处理被输出，并且记录被定义为被确定作为两个或更多个记录存在的记录的普通分组处理的输入。

公开(公告)号：US5890150A

公开(公告)日：1999-03-30

申请号：US12207

申请日：1998-01-23

申请人： Kazutomo Ushijima ,  Shinji Fujiwara ,  Kazuo Masai ,  Yori Takahashi ,  Itaru Nishizawa

发明人： Kazutomo Ushijima ,  Shinji Fujiwara ,  Kazuo Masai ,  Yori Takahashi ,  Itaru Nishizawa

IPC分类号： G06F17/30

CPC分类号： G06F17/30536 ,  Y10S707/99933 ,  Y10S707/99934 ,  Y10S707/99935

摘要： A query issue processing method, a query conversion processing method, and a data control processing method are provided for enhancing the efficiency of random sampling processing for use in a database processing system. In query issue processing 2, a query including random sampling processing is issued. In query conversion processing 8, application sequences of random sampling processing and another query processing are exchanged by considering a sampling unit of the random sampling processing. Further, in record control processing 4, random access to a secondary storage device is reduced, thereby enhancing random sampling processing efficiency. Unlike the conventional query conversion processing not considering the sampling unit, the issuance of the query including random sampling processing and performing query conversion by considering the sampling unit allow random sampling to be applied also to a query including aggregation processing, thereby enhancing the efficiency of queries in a wider range. Reduction in the random access to the secondary storage device further enhances that efficiency.

摘要翻译： 提供了一种查询问题处理方法，查询转换处理方法和数据控制处理方法，用于提高在数据库处理系统中使用的随机抽样处理的效率。 在查询问题处理2中，发出包括随机抽样处理的查询。 在查询转换处理8中，通过考虑随机抽样处理的抽样单位来交换随机抽样处理和另一查询处理的应用程序。 此外，在记录控制处理4中，减少对二次存储装置的随机访问，从而提高随机抽样处理效率。 与不考虑采样单元的常规查询转换处理不同，通过考虑采样单元来执行随机抽样处理和执行查询转换的查询的发布允许随机抽样也适用于包括聚合处理的查询，从而提高查询的效率 在更广泛的范围。 减少对二次存储设备的随机访问进一步提高了该效率。

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

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

公开(公告)号：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.

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