CPC G06F 16/906 (2019.01) [G06F 12/0802 (2013.01)] | 20 Claims |
1. A method comprising:
receiving first data items at a first processing unit;
generating, by the first processing unit and from at least the first data items, data structures, each data structure representing a respective dataset corresponding to at least a portion of the first data items;
storing the data structures in a memory of a second processing unit;
receiving, at the first processing unit, a query from an injest component communicatively coupled to the first processing unit;
generating, by the first processing unit and from the received query, a query data structure including data representing a set of second data items;
processing concurrently, by the second processing unit, the query data structure against two or more of the data structures stored in the memory of the second processing unit, the processing comprising: for each of the two or more of the data structures, computing, by the second processing unit, a correlation score for the query data structure and the data structure according to a correlation algorithm; and
returning results corresponding to the query determined based on the computed correlation scores from the second processing unit to the first processing unit.
|