US 11,816,511 B1
Virtual partitioning of a shared message bus
Steven Karis, Redwood City, CA (US); Maxime Petazzoni, San Mateo, CA (US); Matthew William Pound, Reno, NV (US); Charles Smith, Durham, NC (US); and Chengyu Yang, Menlo Park, CA (US)
Assigned to Splunk Inc., San Francisco, CA (US)
Filed by Splunk Inc., San Francisco, CA (US)
Filed on Feb. 28, 2023, as Appl. No. 18/176,381.
Application 18/176,381 is a continuation of application No. 17/033,253, filed on Sep. 25, 2020, granted, now 11,620,164.
Int. Cl. G06F 9/50 (2006.01); G06F 9/48 (2006.01); G06F 9/54 (2006.01); G06F 11/34 (2006.01); G06F 11/36 (2006.01); G06F 16/2455 (2019.01)
CPC G06F 9/5077 (2013.01) [G06F 9/4881 (2013.01); G06F 9/505 (2013.01); G06F 9/5083 (2013.01); G06F 9/542 (2013.01); G06F 11/3466 (2013.01); G06F 11/34 (2013.01); G06F 11/364 (2013.01); G06F 11/3636 (2013.01); G06F 16/24568 (2019.01)] 20 Claims
OG exemplary drawing
 
1. A computer-implemented method for virtual partitioning of data, the method comprising:
receiving a data stream comprising a plurality of traces, each of the plurality of traces comprising a plurality of spans from a plurality of users;
assigning the plurality of traces of the data stream to a plurality of virtual partitions based on each user of the plurality of users, each virtual partition of the plurality of virtual partitions comprising data of a user of the plurality of users;
publishing the plurality of virtual partitions, wherein at least a subset of the plurality of virtual partitions are scheduled on to at least one user partition with a shared topic by the plurality of traces of the data stream, the at least one user partition comprising data from at least one virtual partition of at least one user of the plurality of users;
configuring a plurality of consumer processes for each of the at least one user partition, each consumer process of the plurality of consumer processes including consumer threads processing data for virtual partitions of the subset of the plurality of virtual partitions; and
consuming at least the subset of the plurality of virtual partitions based on the plurality of consumer processes.