Computer system and method for setting a stream data processing system

A computer system, comprising:

• a plurality of computers;
• and
• a management computer configured to assign a plurality of divided queries including at least one query to the plurality of computers,
• wherein the plurality of computers each include:
• a first processor;
• a first memory coupled to the first processor, and which stores instructions that, when executed by the first processor, causes the first processor to execute stream data processing based on the divided queries assigned thereto;
• and
• a first interface coupled to the first processor, for coupling to an external apparatus,
• wherein the first memory
• wherein the management computer includes:
• a second processor;
• a second memory coupled to the second processor;
• and
• a second interface coupled to the second processor, for coupling to an external apparatus;
• wherein the second memory stores instructions that, when executed by the second processor, cause the second processor to execute:
• a parameter input module configured to receive an analysis scenario including a plurality of queries for achieving the stream data processing, and division information for dividing the analysis scenario into the plurality of divided queries, and
• a query analysis module configured to analyze the analysis scenario and generate a query graph indicating a structure of the plurality of queries included in the analysis scenario,
• wherein the query analysis module is configured to:
• specify, based on the analysis scenario and the division information, at least one of the plurality of divided queries that requires flow control for achieving consistency between a generation order of pieces of data to be processed by the at least one query and a reception order of the pieces of data;
• and
• set the flow control for the plurality of computers to each of which the at least one of the plurality of divided queries that requires the flow control is to be assigned in a case where the at least one of the plurality of divided queries that requires the flow control is to be assigned to each of the plurality of computers
• wherein the at least one query includes at least one operator,
• wherein the second memory further stores operator type information including at least one entry in which a type of the at least one operator is associated with a first flag indicating whether the flow control is required, and
• wherein the query analysis module is further configured to:
• refer to the operator type information to retrieve a first divided query including one of the plurality of queries that includes an operator that requires the flow control;
• and
• specify the first divided query as the one of the plurality of divided queries that requires the flow control.