Data processing method and apparatus, and related device

A data processing apparatus, comprising:

• a processor, and
• a memory, coupled to the processor to store instructions, which when executed by the processor, cause the processor to:
• obtain first event data;
• create a first trigger for the first event data in response to obtaining the first event data, wherein the first trigger indicates first window-expiration time corresponding to the first event data;
• execute, in response to obtaining the first event data, data computing based on event data within a first time window, and obtain a first computation result, wherein the event data within the first time window comprises the first event data, and the first computation result is used to update a computation result in a database;
• output the first computation result;
• execute, when the first window-expiration time indicated by the first trigger arrives, data computing based on event data within a second time window, and obtain a second computation result, wherein the event data within the second time window does not comprise the first event data, a start moment of the second time window is later than a start moment of the first time window, and the second computation result is used to update the computation result in the database;
• and
• output the second compute result.

A non-transitory machine-readable storage medium having instructions stored therein, which when executed by a processor, cause the processor to:

• obtain first event data;
• create a first trigger for the first event data, wherein the first trigger indicates first window-expiration time corresponding to the first event data;
• execute data computing based on event data within a first time window, obtain a first computation result, and output the first computation result, wherein the event data within the first time window comprises the first event data, and the first computation result is used to update a computation result in a database;
• and
• when the first window-expiration time indicated by the first trigger arrives, execute data computing based on event data within a second time window, obtain a second computation result, and output the second computation result, wherein the event data within the second time window does not comprise the first event data, a start moment of the second time window is later than a start moment of the first time window, and the second computation result is used to update the computation result in the database.