US 12,455,915 B2
Distributed entity re-resolution based on streaming updates
Avirup Saha, Kolkata (IN); Balaji Ganesan, Bengaluru (IN); Soma Shekar Naganna, Bangalore (IN); and Sameep Mehta, Bangalore (IN)
Assigned to International Business Machines Corporation, Armonk, NY (US)
Filed by International Business Machines Corporation, Armonk, NY (US)
Filed on Aug. 4, 2022, as Appl. No. 17/880,814.
Prior Publication US 2024/0045896 A1, Feb. 8, 2024
Int. Cl. G06F 16/355 (2025.01); G06F 40/279 (2020.01); G06N 3/042 (2023.01); G06N 5/022 (2023.01); G06N 20/00 (2019.01)
CPC G06F 16/355 (2019.01) [G06F 40/279 (2020.01); G06N 3/042 (2023.01); G06N 5/022 (2013.01); G06N 20/00 (2019.01)] 20 Claims
OG exemplary drawing
 
1. A method, in a data processing system, the method comprising the data processing system:
receiving a knowledge graph data structure comprising data representations of a plurality of first entities specified in a first set of documents, and a corresponding set of initial clusters associated with corresponding ones of the plurality of first entities;
receiving at least one dynamic data stream from at least one source computing system, the at least one dynamic data stream comprising second documents having data specifying second entities referenced by the second documents, wherein each second document is a collection of unstructured textual data; and
automatically, in response to receiving the at least one dynamic data stream:
executing a clustering operation on the second documents based on the set of initial clusters, and document features of the second documents, to provide a set of second document clusters comprising the second documents, wherein the clustering operation is a modified Dirichlet Hawkes Process (DHP) that performs distributed clustering, in parallel, on partitions of the at least one dynamic data stream, across a master compute node and a plurality of slave compute nodes of the data processing system;
determining, for each second document cluster in the one or more second document clusters, whether the second document cluster should be modified based on entities associated with the second document cluster;
executing, for each second document cluster that is determined should be modified, a cluster modification operation on the second document cluster, wherein updated clusters are generated comprising a combination of second document clusters that are modified and second document clusters that are not modified;
dynamically executing entity re-resolution on the plurality of first entities in the knowledge graph data structure based on the second entities associated with the updated clusters to generate an updated knowledge graph data structure;
inputting information associated with the updated knowledge graph data structure into an artificial intelligence computing system and analyzing patterns of the entity re-resolution; and
generating an identity-fraud alert based on analyzing the patterns of the entity re-resolution and based on a determination that an entity is re-resolved a plurality of times over a time period.