公开(公告)号：US20170279654A1

公开(公告)日：2017-09-28

申请号：US15505966

申请日：2015-09-03

Applicant: Hitachi, Ltd.

Inventor： Masafumi KINOSHITA ,  Tatsuhiko MIYATA

IPC: H04L29/06 ,  H04L12/26 ,  H04L29/08 ,  H04L1/00 ,  G06F11/34 ,  G06F9/50

Abstract: A data processing system comprises: at least one each of a plurality of types of data processing module conducting different types of the data processing; data flows through which a series of different types of data processing is conducted on a message and a message subjected to the series of different types of data processing is sent to the destination; and a dispatcher distributes the message and a message subjected to the data processing by the data processing module to a subsequent data processing module, wherein the dispatcher conducts: detecting a specific data processing module in a specific status of being a bottleneck; determining the number of the specific data processing module to resolve the specific status by increasing the number of the specific data processing module; and setting the number of the specific data processing module to the number to resolve the specific status.

公开(公告)号：US20130246541A1

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

申请号：US13718757

申请日：2012-12-18

Applicant: HITACHI, LTD.

Inventor： Izumi KOYANAGI ,  Masafumi KINOSHITA ,  Kunihiko TOUMURA ,  Naoki HARAGUCHI

IPC: H04L12/58

CPC classification number: H04L51/06 ,  H04L51/22

Abstract: A method in which a mail server for receiving mails manages sequence management information that records the sequence of mails stored in a data store server and the times at which a mail server sends the mails to a destination server, wherein the sequence management information is so managed as to satisfy the two conditions: one is to make not greater than a predetermined number the number of entries in any one of respective pieces of the divided sequence management information resulted by dividing the sequence management information into a plurality of pieces, each entry being included in each divided sequence management information piece and defined as a combination of key having the mail body of a certain mail as its value, and the time at which the certain mail is sent to the destination server.

Abstract translation: 一种用于接收邮件的邮件服务器管理记录数据存储服务器中存储的邮件序列的顺序管理信息和邮件服务器将邮件发送到目的地服务器的时间的方法，其中顺序管理信息被如此管理 为了满足以下两个条件：一个是使得将序列管理信息划分为多个片段而得到的分割序列管理信息中的任一个的条目数目不大于预定数目，每个条目被包括 在每个划分的序列管理信息片段中并将其定义为具有某个邮件的邮件正文作为其值的密钥的组合，以及将该特定邮件发送到目的地服务器的时间。

公开(公告)号：US20200019383A1

公开(公告)日：2020-01-16

申请号：US16494471

申请日：2018-08-23

Applicant: Hitachi, Ltd.

Inventor： Hiroaki KONOURA ,  Ken SUGIMOTO ,  Yu NAKATA ,  Masafumi KINOSHITA

IPC: G06F8/30 ,  G06F9/445 ,  G06F16/26

Abstract: The design and development of a data analysis process is assisted and the burden on the user such as a data analyst in data analysis process is reduced. For a data analysis performed by executing each of a data access process, a data analysis process, and an analysis result visualization process, a data analysis process assistance device stores analysis process setting information including setting information for variables commonly used between the respective processes, and plugins corresponding to the respective processes, each of the plugins including basic information that is information on contents of the respective processes, a program code used as a base to generate a template for a program for achieving each of the processes, the variables of the analysis process setting information, and a description related to a variable cross-referenced between the respective processes; and generates the template while ensuring a relationship or consistency between the analysis process setting information and the plugins corresponding to the respective processes.

公开(公告)号：US20220129473A1

公开(公告)日：2022-04-28

申请号：US17420075

申请日：2019-12-18

Applicant: Hitachi, Ltd.

Inventor： Hirofumi INOMATA ,  Masafumi KINOSHITA ,  Hiroaki KONOURA

IPC: G06F16/25 ,  G06F16/27 ,  G06F16/2455 ,  H04L67/1095

Abstract: Each of a plurality of servers includes a shared information storage region for storing information to be shared with other servers. The servers operate so as to match data of the shared information storage regions with each other. A first server manages a first local database. A second server generates query information for accessing the first local database, and stores the query information in the shared information storage region of the second server. The first server acquires the query information from the shared information storage region of the first server, and stores the result with respect to the query information in the shared information storage region of the first server. The second server acquires the result from the shared information storage region of the second server.

公开(公告)号：US20130198302A1

公开(公告)日：2013-08-01

申请号：US13746009

申请日：2013-01-21

Applicant: Hitachi, Ltd.

Inventor： Masafumi KINOSHITA ,  Toshiyuki KAMIYA ,  Takafumi KOIKE

IPC: H04L12/58

CPC classification number: H04L12/58 ,  H04L51/30

Abstract: In a mail gateway, a collection part collects, for each specific information contained in a mail entered into a resending queue, statistical information of the specific information. A provisional queue creation part creates a provisional queue based on the collected number of the statistical information. The provisional queue handles a mail which has a possibility of causing congestion. This can prevent a normal queue from entering into a congestion state. Also in the mail gateway, if the congestion state is brought about in the provisional queue which performs a send of a mail containing the specific information, a mail sort part restricts an entry of a mail into the provisional queue. This can limit an influence of the congestion state only to the provisional queue.

Abstract translation: 在邮件网关中，收集部分针对输入重发队列的邮件中包含的每个特定信息，收集特定信息的统计信息。 临时队列创建部件基于所收集的统计信息的数量创建临时队列。 临时队列处理可能导致拥塞的邮件。 这可以防止正常队列进入拥塞状态。 此外，在邮件网关中，如果在执行包含特定信息的邮件的发送的临时队列中产生拥塞状态，则邮件分类部件将邮件的条目限制为临时队列。 这可以限制拥塞状态对临时队列的影响。

公开(公告)号：US20230315900A1

公开(公告)日：2023-10-05

申请号：US18022357

申请日：2021-08-19

Applicant: Hitachi, Ltd.

Inventor： Hiroaki KONOURA ,  Masafumi KINOSHITA ,  Keisuke SHIRAI

IPC: G06F21/62 ,  G06F16/903

CPC classification number: G06F21/6245 ,  G06F16/90335

Abstract: An information processing system includes first and second computers and first and second bases. The first computer stores, as personal information of a user of a terminal, personal management information including an ID and contact detail of the user, generates personal time-series information with personal information and time added and generates processed time-series information by performing concealment on the personal information in the personal time-series information. The processed time-series information is transmitted to the second computer, which generates search range information for the processed time-series information from a search condition for the processed time-series information for specifying the user at the first base and a message to be transmitted to the user at the first base, and transmits the search range information to the first computer, and the first computer specifies the user by searching for the personal time-series information, with the search condition of the received search range information.

公开(公告)号：US20160261476A1

公开(公告)日：2016-09-08

申请号：US14784626

申请日：2014-04-14

Applicant: HITACHI, LTD.

Inventor： Masafumi KINOSHITA ,  Takafumi KOIKE ,  Izumi MIZUTANI ,  Naoki HARAGUCHI

IPC: H04L12/26 ,  H04L12/58 ,  H04L29/08

CPC classification number: H04L43/0811 ,  H04L43/0817 ,  H04L51/14 ,  H04L51/26 ,  H04L51/30 ,  H04L67/1002 ,  H04L67/26

Abstract: This server for distributing messages quickly detects a performance decline in a downstream server by using a method for keeping, for each distribution-destination server, a threshold such as a connection number and a time interval separate from a response timeout, and determining that performance has declined when the threshold is exceeded. In addition, the present invention improves system availability by identifying a server group in which performance has declined on the basis of a correlation pertaining to inter-server cooperative processing, when a distribution server exhibits a decline in performance, and by the distribution server distributing a message to a server not exhibiting a decline in performance.

Abstract translation: 用于分发消息的该服务器通过使用用于为每个分发目的地服务器保持与响应超时不同的连接号和时间间隔的阈值并且确定性能具有的方法来快速检测下游服务器中的性能下降 当超过阈值时拒绝。 此外，本发明通过基于与服务器间协作处理有关的相关性，在分发服务器呈现性能下降的情况下，通过识别性能已经下降的服务器组来提高系统可用性，并且通过分发服务器分发 向服务器发送消息，不显示性能下降。

公开(公告)号：US20160234129A1

公开(公告)日：2016-08-11

申请号：US15012262

申请日：2016-02-01

Applicant: HITACHI, LTD.

Inventor： Hiroaki KONOURA ,  Masafumi KINOSHITA ,  Takafumi KOIKE ,  Toshiyuki KAMIYA

IPC: H04L12/911 ,  H04L12/24

CPC classification number: H04L47/781 ,  G06F9/546 ,  G06F2209/548

Abstract: Provided is a communication system capable of sending and receiving signals. The communication system includes a plurality of data store servers each including a queue capable of storing signals and a queue management server capable of allocating signals to the plurality of data store servers. The queue management server holds distribution policy information that specifies policies to allocate signals to the plurality of data store servers. The queue management server is configured to determine to allocate a plurality of received signals to one queue in one of the plurality of data store servers based on the distribution policy information when the plurality of signals include in-order guarantee keys indicating that the plurality of signals are in need of in-order guarantee and the in-order guarantee keys of the plurality of signals are identical.

Abstract translation: 提供能够发送和接收信号的通信系统。 通信系统包括多个数据存储服务器，每个数据存储服务器包括能够存储信号的队列和能够向多个数据存储服务器分配信号的队列管理服务器。 队列管理服务器保存分配策略信息，该信息指定向多个数据存储服务器分配信号的策略。 队列管理服务器被配置为当多个信号包括指示多个信号的顺序保证密钥时，基于分发策略信息来确定向多个数据存储服务器之一中的一个队列分配多个接收到的信号 需要按顺序保证，并且多个信号的按顺序保证密钥是相同的。

公开(公告)号：US20160085638A1

公开(公告)日：2016-03-24

申请号：US14893247

申请日：2014-05-23

Applicant: HITACHI, LTD.

Inventor： Izumi MIZUTANI ,  Masafumi KINOSHITA ,  Naoki HARAGUCHI

IPC: G06F11/14

CPC classification number: G06F11/1469 ,  G06F11/0709 ,  G06F11/0766 ,  G06F11/1451 ,  G06F2201/84 ,  H04L43/04

Abstract: A computer system for realizing increased speed of identifying extent of a failure in a messaging system, provided with: a first computer including a message receiving part, a first log output part, and a first memory part configured to store receiving log data; a second computer including a data store management part configured to manage a data store, a first search part configured to search a message that meets a given condition from among messages stored in the data store, a second log output part, and a second memory part configured to store data store log data; a third computer including a message sending part, a third log output part, and a third memory part configured to store sending log data; and a fourth computer including a monitoring part, a log collecting part, and a second search part configured to search for lost message.

Abstract translation: 一种计算机系统，用于实现识别消息收发系统中故障范围的增加速度，该消息系统具有：包括消息接收部分的第一计算机，第一日志输出部分和被配置为存储接收日志数据的第一存储器部分; 第二计算机，包括被配置为管理数据存储的数据存储管理部分，被配置为从存储在数据存储器中的消息中搜索满足给定条件的消息的第一搜索部分，第二对数输出部分和第二存储器部分 配置为存储数据存储日志数据; 第三计算机，包括消息发送部分，第三日志输出部分和被配置为存储发送日志数据的第三存储器部分; 以及包括监视部分，日志收集部分和被配置为搜索丢失消息的第二搜索部分的第四计算机。

公开(公告)号：US20150149603A1

公开(公告)日：2015-05-28

申请号：US14555005

申请日：2014-11-26

Applicant: Hitachi, Ltd.

Inventor： Izumi MIZUTANI ,  Masafumi KINOSHITA ,  Naoki HARAGUCHI

IPC: H04L12/24

CPC classification number: H04L41/0813 ,  H04L41/0866

Abstract: There is provided a distributed processing system including: a data store server for storing data; a data store part for storing data in the data store server; a data acquisition part for obtaining data from the data store server; and an operation manager part for performing configuration change on the whole system. The distributed processing system has a function of managing the configuration content and the configuration order for each device according to the change content, to determine the target and order to be configured based on the managed information by the operation manager part. Further, the distributed processing system has a function of performing a configuration change process on the data store part, the data acquisition part, and the data store server by the operation manager part.

Abstract translation: 提供了一种分布式处理系统，包括：用于存储数据的数据存储服务器; 用于在数据存储服务器中存储数据的数据存储部分; 数据获取部分，用于从数据存储服务器获取数据; 以及用于在整个系统上执行配置改变的操作管理器部件。 分布式处理系统具有根据变更内容管理各设备的配置内容和配置顺序的功能，根据操作管理器部分的管理信息确定要配置的目标和顺序。 此外，分布式处理系统具有由操作管理器部分对数据存储部分，数据获取部分和数据存储服务器进行配置改变处理的功能。