US 12,242,897 B2
Key-based aggregation service
Kiran Kumar Palukuri, Bangalore (IN); Pankaj Agrawal, Hyderabad (IN); Naga Raju Barri, Telangana (IN); Jerry Paul Russell, Seattle, WA (US); and Satinder Singh, Delhi (IN)
Assigned to Oracle International Corporation, Redwood Shores, CA (US)
Filed by Oracle International Corporation, Redwood Shores, CA (US)
Filed on Dec. 2, 2022, as Appl. No. 18/061,013.
Application 18/061,013 is a continuation in part of application No. 17/885,169, filed on Aug. 10, 2022.
Claims priority of provisional application 63/402,794, filed on Aug. 31, 2022.
Claims priority of provisional application 63/322,112, filed on Mar. 21, 2022.
Prior Publication US 2023/0297436 A1, Sep. 21, 2023
Int. Cl. G06F 9/50 (2006.01); H04L 9/08 (2006.01)
CPC G06F 9/5061 (2013.01) [H04L 9/08 (2013.01)] 20 Claims
OG exemplary drawing
 
1. A non-transitory computer readable medium comprising instructions which, when executed by one or more hardware processors, causes performance of operations comprising:
subscribing to a particular stream partition of a plurality of stream partitions comprised in a stream;
receiving data from the particular stream partition;
aggregating subsets of the data, from the particular stream partition, based on respective keys associated with the subsets of the data;
determining whether one or more of the subsets of data, associated with a particular key, meet at least one processing criteria, wherein the at least one processing criteria specifies a threshold amount of data;
responsive at least to determining that the one or more of the subsets of data, associated with the particular key, do not meet the threshold amount of data specified in the processing criteria, refraining from processing the one or more of the subsets of data;
receiving additional data from the particular stream partition, wherein the additional data comprises an additional data subset associated with the particular key;
aggregating the additional data subset, associated with the particular key, with the one or more of the subsets of data associated with the particular key to obtain updated aggregated data subsets associated with the particular key;
subsequent to aggregating the additional data subset with the one or more of the subsets of data associated with the particular key: determining whether the updated aggregated data subsets, associated with the particular key, meet the at least one processing criteria; and
responsive at least to determining that the updated aggregated data subsets, associated with the particular key, meet the at least one processing criteria: processing the updated aggregated data subsets associated with the particular key.