Streaming data distributed processing method and device
A method comprises: obtaining service data identifier information of a data record of streaming data, a to-be-processed real-time value of the data record, and a time sequence characteristic of the to-be-processed real-time value of the data record, the identifier information representing service data; obtaining a time sequence characteristic of a processed real-time value of the service data based on a correspondence relationship between the service data identifier information and the time sequence characteristic of the processed real-time value; and comparing the time sequence characteristic of the to-be-processed real-time value and the time sequence characteristic of the processed real-time value, and in response to that the time sequence characteristic of the to-be-processed real-time value is later than the time sequence characteristic of the processed real-time value, updating the time sequence characteristic of the processed real-time value to the time sequence characteristic of the to-be-processed real-time value.
ADVANCED NEW TECHNOLOGIES CO., LTD.
G G G G G
G06F G06F G06F G06F G06F
inventional inventional inventional inventional inventional
Chenglin Liang
Feng Luo