Incremental data processing
AssigneeYahoo Assets LLC
InventorsBernardo de Seabra, Rahul Ravindran
Life of this patent
Estimating the term…
Abstract
Event logs in a video advertisement insertion network are processed to remove duplicate entries. One or more ad servers are continuously generating new event entries and writing them to a database. The entries are randomized such that generated time contiguous entries are distributed over multiple storage locations, thereby facilitating resource scaling and a uniform use of storage and computing resources. The distributed entries are read from the storage locations using sequential reads of chunks of the entries and processed to remove duplicate entries.
Claims20
A computer-implemented method, comprising:
- receiving multiple event records including a first event record and a second event record;
- generating, for the first event record, a first salt value;
- generating, for the second event record, a second salt value;
- distributing, based on at least the first salt value and the second salt value, the multiple event records over storage locations;
- and
- generating unique events in a video advertisement delivery network associated with the storage locations based on a comparison of a first number of events logged at an ad server with a second number of events generated for billing by a billing system.
A computer program product comprising a non-transitory computer-readable program medium having code stored thereon, the code when executed, causing one or more processors to implement a method comprising:
- receiving multiple event records including a first event record and a second event record, wherein the first event record comprises at least one of a first event identification, a first event generation time stamp or a first event description field, and the second event record comprises at least one of a second event identification, a second event generation time stamp or a second event description field;
- generating, for the first event record, a first salt value;
- generating, for the second event record, a second salt value;
- distributing, based on at least the first salt value and the second salt value, the multiple event records over storage locations;
- and
- generating unique events in an advertisement delivery network associated with the storage locations based on a comparison of a first number of events logged at an ad server with a second number of events generated for billing by a billing system.
A communication system, comprising:
- one or more processors that communicate event records over a transport network;
- and
- a de-duplication mechanism that receives the event records from the transport network, wherein the de-duplication mechanism includes:
- a randomizer module that randomizes the event records to generate randomized event records;
- a distribution module that distributes the randomized event records to multiple computer platforms;
- a chunking module that reads a subset of the event records on at least one of the multiple computer platforms;
- and
- a comparator module that identifies one or more duplicate entries based on unique event identifiers, wherein each unique event identifier comprises a salt value generated as a function of an event identification for a corresponding event record.
Dependencies are inferred from the claim text.