System for changing rules for data pipleine reading using trigger data from one or more data connection modules
Provided is an operating method of a system including a first data processing module, a second data processing module, and one or more data connection modules that transfer data between the first data processing module and the second data processing module. In an operational state where the first data processing module and the second data processing module can process data input thereto, the first data processing module inputs trigger data to any of the one or more data connection modules, and in response to the second data processing module receiving the trigger data via the one or more data connection modules, the second data processing module changes a reading rule for reading data from the one or more data connection modules. Also provided are a system and a computer program product.
1. A method of operating a system, the system including a first data processing module, a second data processing module, and one or more data connection modules that transfer data between the first data processing module and the second data processing module, the method comprising:
in an operational state where the first data processing module and the second data processing module can process data input thereto, inputting by the first data processing module trigger data to any of the one or more data connection modules; and
in response to the second data processing module receiving the trigger data via the one or more data connection modules, changing by the second data processing module a reading rule for reading data from the one or more data connection modules;
wherein an early-stage data processing module that processes data is provided in the system before the first data processing module; and
wherein the trigger data is input to the one or more data connection modules form the first data processing module, without passing through the early-stage data processing module.
2. The method according to claim 1 , wherein before the second data processing module receives the trigger data via the one or more data connection modules, the second data processing module is informed in advance concerning the reading rule to be used by the second data processing module in response to the trigger data.
3. The method according to claim 2 , wherein after the first data processing module has input the trigger data to the one or more data connection modules, the first data processing module changes a writing rule for writing data to the one or more data connection modules.
4. A method of operating a system, the system including a first data processing module, a second data processing module, and one or more data connection modules that transfer data between the first data processing module and the second data processing module, the method comprising:
in an operational state where the first data processing module and the second data processing module can process data input thereto, inputting by the first data processing module trigger data to any of the one or more data connection modules;
in response to the second data processing module receiving the trigger data via the one or more data connection modules, changing by the second data processing module a reading rule for reading data from the one or more data connection modules;
in response to the first data processing module being in the operational state, a new data connection module that transfers data between the first data processing module and the second data processing module is added to the one or more existing data connection modules;
the first data processing module inputs the trigger data to the one or more existing data connection modules, and in response to the trigger data having been input, inputs data to the new data connection module; and
the second data processing module reads the data according to the reading rule including the new data connection module as a data reading target, on a condition that the second data processing module has read the trigger data from all of the one or more existing data connection modules.
5. The method according to claim 4 , wherein whether or not to add the new data connection module is determined based on an amount of data accumulated in the one or more existing data connection modules.
6. The method according to claim 4 , wherein whether or not to add the new data connection module is determined based on the data input to the first data processing module.
7. The method according to claim 6 , wherein if the new data connection module is created based on the data input to the first data processing module, data capacity of the new data connection module is controlled based on data input to a driver of the system.
8. The method according to claim 6 , wherein if the new data connection module is created based on the data input to the first data processing module, a type of the new data connection module is controlled based on the data input to the first data processing module.
9. The method according to claim 1 , wherein the first data processing module inputs the trigger data including information concerning the reading rule to the one or more data connection modules.