ASYNCHRONOUS MULTI-TENANT MODEL INFERENCING ON STREAMING DATABASES

    公开(公告)号:US20230128987A1

    公开(公告)日:2023-04-27

    申请号:US17508857

    申请日:2021-10-22

    IPC分类号: G06N20/00 G06N5/04 G06F16/27

    摘要: A system including one or more processors and one or more non-transitory computer-readable media storing computing instructions configured to run on the one or more processors and perform ingesting streaming events for processing by multiple models; mapping each of the streaming events to a model of the multiple models; storing each of the streaming events in a respective queue in a respective sequence store, such that a respective one of the multiple models retrieves (i) a respective one of the streaming events in the respective sequence store associated with the respective one of the multiple models and (ii) a respective key corresponding to the respective one of the streaming events from a leaf store, to asynchronously perform the respective machine-learning inferencing, wherein the multiple models run independently and in parallel on multi-tenant threads. Other embodiments are disclosed.

    Event-driven identity graph conflation

    公开(公告)号:US11281657B2

    公开(公告)日:2022-03-22

    申请号:US16777692

    申请日:2020-01-30

    摘要: A distributed system including multiple processing nodes. The distributed system can perform certain acts. The acts can include receiving a first conflation event identifying a first node and a second node. The first node can be part of a first set. The first set can include a sole parent node stored at a first processing node of the multiple processing nodes. The second node can be part of a second set. The second set can include a sole parent node stored at a second processing node of the multiple processing nodes. The first and second sets can be disjoint sets. The first conflation event can be received at an event-driven stream application at one of the multiple processing nodes. The acts also can include conflating the first set and the second set into a conflated set. The conflated set can include the first and second nodes. The conflated set can include a sole parent node. Data for each node of the conflated set can be stored at the sole parent node of the conflated set at a processing node of the multiple processing nodes. Other embodiments are disclosed.

    EVENT-DRIVEN IDENTITY GRAPH CONFLATION

    公开(公告)号:US20210240693A1

    公开(公告)日:2021-08-05

    申请号:US16777692

    申请日:2020-01-30

    摘要: A distributed system including multiple processing nodes. The distributed system can perform certain acts. The acts can include receiving a first conflation event identifying a first node and a second node. The first node can be part of a first set. The first set can include a sole parent node stored at a first processing node of the multiple processing nodes. The second node can be part of a second set. The second set can include a sole parent node stored at a second processing node of the multiple processing nodes. The first and second sets can be disjoint sets. The first conflation event can be received at an event-driven stream application at one of the multiple processing nodes. The acts also can include conflating the first set and the second set into a conflated set. The conflated set can include the first and second nodes. The conflated set can include a sole parent node. Data for each node of the conflated set can be stored at the sole parent node of the conflated set at a processing node of the multiple processing nodes. Other embodiments are disclosed.

    Methods and apparatus for data repartitioning

    公开(公告)号:US10936232B1

    公开(公告)日:2021-03-02

    申请号:US16548628

    申请日:2019-08-22

    IPC分类号: G06F3/06

    摘要: This application relates to apparatus and methods for automatically determining and providing digital advertisements to targeted users. In some examples, a computing device receives campaign data identifying items to advertise on a website, and generates campaign user data identifying a user that has engaged all of the items on the website. The computing device may then determine a portion of the users based on a relationship between each user and the campaign user data, and may determine user-item values for each of the items for each user of the portion of users, where each user-item value identifies a relational value between the corresponding user and item. The computing device may then identify one or more of the items to advertise to each user of the portion of users based on the user-item values, and may transmit to a web server an indication of the items to advertise for each user.