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

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.

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.