Using degree of completeness of real-time data to maximize product revenue

1. A method for maximizing an advertisement revenue implemented by one or more computing devices, the method comprising:

collecting real-time data received by one or more nodes in a distributed system, each collected piece of real-time data being associated with a respective timestamp;

aggregating real-time data that satisfies a same predetermined condition on the one or more nodes to obtain a total amount of real-time data corresponding to the same predetermined condition;

calculating a degree of completeness of the real-time data that satisfies the same predetermined condition, wherein the degree of completeness is used for indicating a ratio between processed real-time data that satisfies the same predetermined condition and the real-time data aggregated on the one or more nodes, and is a basis for indicating a progress about a completion of processing;

adding the degree of completeness for the real-time data that satisfies the same predetermined condition to transform an indicator of the real-time data that satisfies the same predetermined condition into two indicators, the two indicators including a timestamp of the real-time data that satisfies the same predetermined condition and the degree of completeness;

storing the degree of completeness and the timestamp of the real-time data that satisfies the same predetermined condition together in a database; and

changing a current advertisement based at least in part on the degree of completeness and the real-time data that satisfies the same predetermined condition.

2. The method of claim 1 , wherein the degree of completeness is used for indicating a ratio between a total amount of the processed real-time data that satisfies the same predetermined conditions and a total amount of the real-time data aggregated on the one or more nodes.

3. The method of claim 2 , wherein the degree of completeness is used to indicating a proportion of the total amount of real-time data on aggregated the one or more nodes that is occupied by a total amount of real-time data that satisfies the same predetermined condition within a predetermined time period, wherein the real-time data that satisfies the same predetermined condition comprises real-time data collected at a predetermined time, and the predetermined time period is the predetermined time and a time period before the predetermined time.

4. The method of claim 3 , wherein: after collecting the real-time data received by the one or more nodes in the distributed system, the method further comprises obtaining a timestamp of each collected piece of real-time data after collecting the real-time data received by the one or more nodes in the distributed system, wherein the timestamp is used for indicating a time when the respective piece of real-time data is processed.

5. The method of claim 4 , wherein calculating the degree of completeness of the real-time data that satisfies the same predetermined condition comprises using a ratio between a total amount of processed real-time data at a current timestamp and the total amount of the real-time data aggregated on the one or more nodes as the degree of completeness.

6. The method of claim 1 , wherein aggregating the real-time data that satisfies the same predetermined condition on the one or more nodes to obtain the total amount of real-time data corresponding to the same predetermined condition comprises:

obtaining real-time data on each node of the distributed system; and

aggregating pieces of real-time data having a same timestamp that are obtained on each node of the distributed system to obtain a respective total amount of real-time data corresponding to each timestamp.

7. The method of claim 1 , wherein the predetermined condition is used for representing a time at which the real-time data is collected.

8. An apparatus for maximizing an advertisement revenue, the apparatus comprising:

one or more processors;

memory;

a collection module stored in the memory and executable by the one or more processors to collect real-time data received by one or more nodes in a distributed system, each collected piece of real-time data being associated with a respective timestamp;

an aggregation module stored in the memory and executable by the one or more processors to aggregate real-time data that satisfies a same predetermined condition on the one or more nodes to obtain a total amount of real-time data corresponding to the same predetermined condition; and

a calculation module stored in the memory and executable by the one or more processors to:

calculate a degree of completeness of the real-time data that satisfies the same predetermined condition, wherein the degree of completeness is used for indicating a ratio between processed real-time data that satisfies the same predetermined conditions and the real-time data aggregated on the one or more nodes, and is a basis for indicating a progress about a completion of processing;

add the degree of completeness for the real-time data that satisfies the same predetermined condition to transform an indicator of the real-time data that satisfies the same predetermined condition into two indicators, the two indicators including a timestamp of the real-time data that satisfies the same predetermined condition and the degree of completeness;

store the degree of completeness and the timestamp of the real-time data that satisfies the same predetermined condition together in a database; and

changing a current advertisement based at least in part on the degree of completeness and the real-time data that satisfies the same predetermined condition.

9. The apparatus of claim 8 , wherein the degree of completeness is used for indicating a ratio between a total amount of the processed real-time data that satisfies the same predetermined conditions and a total amount of the real-time data aggregated on the one or more nodes.

10. The apparatus of claim 9 , wherein the completeness is used to indicating a proportion of the total amount of real-time data on aggregated the one or more nodes that is occupied by a total amount of real-time data that satisfies the same predetermined condition within a predetermined time period, wherein the real-time data that satisfies the same predetermined condition comprises real-time data collected at a predetermined time, and the predetermined time period is the predetermined time and a time period before the predetermined time.

11. The apparatus of claim 10 , further comprising an acquisition module configured to obtain a timestamp of each collected piece of real-time data after collecting the real-time data, where the timestamp is used for indicating a time for processing the respective piece of real-time data.

12. The apparatus of claim 11 , wherein the calculation module is further configured to use a ratio between a total amount of processed real-time data at a current timestamp and the total amount of the real-time data aggregated on the one or more nodes as the degree of completeness.

13. The apparatus of claim 8 , wherein the aggregation module comprises:

an acquisition unit configured to obtain real-time data on each node of the distributed system; and

an aggregation unit configured to aggregate pieces of real-time data having a same timestamp that are obtained on each node of the distributed system, and obtain a respective total amount of real-time data corresponding to each timestamp.

14. The apparatus of claim 8 , wherein the predetermined condition is used for representing a time at which the real-time data is collected.

15. One or more computer readable media storing executable instructions that, when executed by one or more processors of a system for maximizing an advertisement revenue, cause the one or more processors to perform acts comprising:

collecting real-time data received by one or more nodes in a distributed system, each collected piece of real-time data being associated with a respective timestamp;

aggregating real-time data that satisfies a same predetermined condition on the one or more nodes to obtain a total amount of real-time data corresponding to the same predetermined condition;

calculating a degree of completeness of the real-time data that satisfies the same predetermined condition, wherein the degree of completeness is used for indicating a ratio between processed real-time data that satisfies the same predetermined condition and the real-time data aggregated on the one or more nodes, and is a basis for indicating a progress about a completion of processing;

adding the degree of completeness for the real-time data that satisfies the same predetermined condition to transform an indicator of the real-time data that satisfies the same predetermined condition into two indicators, the two indicators including a timestamp of the real-time data that satisfies the same predetermined condition and the degree of completeness;

storing the degree of completeness and the timestamp of the real-time data that satisfies the same predetermined condition together in a database; and

changing a current advertisement based at least in part on the degree of completeness and the real-time data that satisfies the same predetermined condition.

16. The one or more computer readable media of claim 15 , wherein the degree of completeness is used for indicating a ratio between a total amount of the processed real-time data that satisfies the same predetermined conditions and a total amount of the real-time data aggregated on the one or more nodes.

17. The one or more computer readable media of claim 16 , wherein the degree of completeness is used to indicating a proportion of the total amount of real-time data on aggregated the one or more nodes that is occupied by a total amount of real-time data that satisfies the same predetermined condition within a predetermined time period, wherein the real-time data that satisfies the same predetermined condition comprises real-time data collected at a predetermined time, and the predetermined time period is the predetermined time and a time period before the predetermined time.

18. The one or more computer readable media of claim 17 , wherein: after collecting the real-time data received by the one or more nodes in the distributed system, the method further comprises obtaining a timestamp of each collected piece of real-time data after collecting the real-time data received by the one or more nodes in the distributed system, wherein the timestamp is used for indicating a time when the respective piece of real-time data is processed.

19. The one or more computer readable media of claim 18 , wherein calculating the degree of completeness of the real-time data that satisfies the same predetermined condition comprises using a ratio between a total amount of processed real-time data at a current timestamp and the total amount of the real-time data aggregated on the one or more nodes as the degree of completeness.

20. The one or more computer readable media of claim 15 , wherein aggregating the real-time data that satisfies the same predetermined condition on the one or more nodes to obtain the total amount of real-time data corresponding to the same predetermined condition comprises:

obtaining real-time data on each node of the distributed system; and

aggregating pieces of real-time data having a same timestamp that each node of the distributed system to obtain a respective total amount of real-time data corresponding to each timestamp.