Yahoo! Inc.

Oath Inc.

Yahoo Assets LLC

Verizon Media Inc.

Michael Natkovich

Joshua Walters

Akshai Sarma

Miao Chen

Niru Appikatala

Ravi Sankuratri

The present teaching relates to streaming data querying and providing query results. In one example, a query is received for events happening after receipt of the query. A plurality of data records are obtained, where each of the data records corresponds to an event happening after receipt of the query. For each of the plurality of data records, it is determined whether the data record matches the query. Based on the determining, one or more query results are determined and provided as a response to the query.

Method and system for querying streaming data

The present teaching generally relates to detecting data bucket discrepancies associated with online experiments. In a non-limiting embodiment, a monitoring layer may be generated within an online experimentation platform that includes at least a first layer, and where a first online experiment is associated with the first layer, the monitoring layer includes a monitoring layer data bucket, and the first layer includes at least a first data bucket. First data representing user activity associated with a first plurality of identifiers may be obtained, the user activity being associated with the first layer. Second data representing at least one user engagement parameter may be generated, and a first discrepancy between the first and second data may be determined. The first discrepancy indicating a first amount of identifiers that include a first metadata tag associated with the first layer and lack a second metadata tag associated with the monitoring layer.

Method and system for detecting gaps in data buckets for A/B experimentation

Users may interact with a multitude of content on content sources. Content sources may desire to identify sessions that the user created. As provided herein, a user interacting with a content source may be identified. Source data and session data regarding the user interaction may be extracted. A data pipeline may be generated based upon the source data and the session data. The data pipeline may be sessionized into a single data feed based upon a finished current events interval (e.g., sessions that are activated and terminated during a first interval), a finished last events interval (e.g., sessions that are activated during the first interval and terminated during a second interval), a second finished current events interval (e.g., sessions that are activated and terminated during the second interval), and/or a second finished last events interval (e.g., sessions that are activated during the second interval and terminated during a third interval).

Data sessionization

In one embodiment, data generated via a map process and/or reduce process may be obtained. A request message may be sent to a server, where the request message indicates a request for a location in storage at which the data is to be stored. Upon receiving the location from the server, the data may be copied to the location in the storage. A commit message may be sent to the server, where the commit message indicates that the data has been copied to the location. In addition, the data may be deleted.

Growing community of inventors

San Francisco, CA, United States of America

Michael Natkovich