Distributed processing management method and distributed processing management apparatus

A non-transitory computer-readable storage medium storing a computer program that causes a computer to perform a procedure comprising:

• extracting a reference item name of a reference item that is referenced in processing from among a plurality of items of each of a plurality of records by analyzing a source file of a processing program describing the processing, the processing being performed on the plurality of records, the plurality of records being distributed and stored in a plurality of servers;
• generating a deletion program describing a process of deleting, from the records to be transmitted, data of a non-reference item that has an item name other than the reference item name;
• generating an insertion program describing a process of inserting, in each of the records with data of the non-reference item deleted therefrom, dummy data in a position where the data of the non-reference item was located;
• and
• causing the plurality of servers to execute the processing on the plurality of records in a distributed manner, based on the processing program, the causing including:
• before transmitting any of the plurality of records, causing the servers to delete data of the non-reference item from each of the records to be transmitted, according to the deletion program,
• causing the servers to transmit the plurality of records with the data of the non-reference item deleted therefrom via a network,
• causing the servers to receive the plurality of records with the data of the non-reference item deleted therefrom, each of the servers receiving a record transmitted from another server via the network, and
• causing the servers to insert the dummy data in a position in each of the received records where the data of the non-reference item was located, based on the insertion program, the received records into which the dummy data is inserted having a same data structure as the plurality of records before deletion of the data of the non-reference item,
• wherein:
• the extracting includes, when the source file specifies the reference item that is referenced in the processing from among a plurality of items that occur repeatedly with the reference item name in each of the plurality of records, by specifying an occurrence number indicating an order of the reference item among the plurality of items in each of the plurality of records, extracting the reference item name with the occurrence number of the reference item added thereto;
• and
• the generating the deletion program includes specifying, as a non-reference item, an item other than the item that occurs in an ordinal position indicated by the occurrence number from among the plurality of items that occur repeatedly with the reference item name.

A distributed processing management apparatus comprising:

• a memory;
• and
• a processor connected to the memory and configured to perform a procedure including:
• extracting a reference item name of a reference item that is referenced in processing from among a plurality of items of each of a plurality of records by analyzing a source file of a processing program describing the processing, the processing being performed on the plurality of records, the plurality of records being distributed and stored in a plurality of servers,
• generating a deletion program describing a process of deleting, from the records to be transmitted, data of a non-reference item that has an item name other than the reference item name,
• generating an insertion program describing a process of inserting, in each of the records with data of the non-reference item deleted therefrom, dummy data in a position where the data of the non-reference item was located, and
• causing the plurality of servers to execute the processing on the plurality of records in a distributed manner, based on the processing program, the causing including:
• before transmitting any of the plurality of records, causing the servers to delete data of the non-reference item from each of the records to be transmitted, according to the deletion program,
• causing the servers to transmit the plurality of records with the data of the non-reference item deleted therefrom via a network,
• causing the servers to receive the plurality of records with the data of the non-reference item deleted therefrom, each of the servers receiving a record transmitted from another server via the network, and
• causing the servers to insert the dummy data in a position in each of the received records where the data of the non-reference item was located, based on the insertion program, the received records into which the dummy data is inserted having a same data structure as the plurality of records before deletion of the data of the non-reference item,
• wherein:
• the extracting includes, when the source file specifies the reference item that is referenced in the processing from among a plurality of items that occur repeatedly with the reference item name in each of the plurality of records, by specifying an occurrence number indicating an order of the reference item among the plurality of items in each of the plurality of records, extracting the reference item name with the occurrence number of the reference item added thereto;
• and
• the generating the deletion program includes specifying, as a non-reference item, an item other than the item that occurs in an ordinal position indicated by the occurrence number from among the plurality of items that occur repeatedly with the reference item name.