IP Library › Granted Patent US 12,651,001
Granted Patent B1
US 12,651,001 · App. 17/444,172 · Granted Jun 9, 2026

Multiple data sources for a data processing pipeline

Inventors: Sanjeev Kulkarni (Los Altos, CA); Zhimin Liang (West Vancouver, CA); Boyang Peng (Mountain View, CA); Dragoljub Profirovic (Coquitlam, CA)
Assignee: Cisco Technology, Inc.
G06F16/252G06F9/4881G06F16/24568G06F16/258
View Patent ↗
Loading inventors, assignments & file history…
Monitor This Case
Get email alerts when status or documents change.
Order Certified Copies
Most orders are placed with the USPTO same day — all within 24 business hours.
Order via The Patent Place →
Pre-filled with this patent's details
Quick Facts
Patent No.
US 12,651,001
App. No.
17/444,172
Granted
Jun 9, 2026
Kind
B1
Abstract

Systems and methods are described for implementation by a streaming data processing system of a processing pipeline that obtains data items from one or more data sources. The one or more data sources may include multiple partitions of a topic or multiple topics. The one or more data sources are defined by a data pattern, a group of tenants, or a process. The implementation of the processing pipeline can include identifying the one or more data sources to obtain data items. The processing pipeline can include a plurality of processing tasks to obtain the data items. The streaming data processing system can utilize a workload coordinator to dynamically assign particular data sources to particular processing tasks. The implementation of the processing pipeline can further include executing the plurality of processing tasks to cause processing tasks to obtain data items from assigned data sources and process the data items.

Claims (20)

1 . A method implemented by a streaming data processing system, the method comprising: obtaining a specification of a data processing pipeline, the data processing pipeline specifying a series of nodes and interconnections between individual nodes within the series, wherein the nodes designate a transformation of data items within the data processing pipeline and wherein the interconnections designate a routing of messages through the data processing pipeline; and implementing the data processing pipeline on the streaming data processing system by execution of a plurality of processing tasks, wherein implementing the data processing pipeline on the streaming data processing system comprises: identifying a plurality of topics of an intake ingestion buffer from which to obtain data items for processing by the data processing pipeline, identifying a processing task of the plurality of processing tasks as a workload coordinator, wherein each of the plurality of processing tasks are assignable to be the workload coordinator, and wherein the workload coordinator dynamically assigns at least one topic of the plurality of topics to each of the plurality of processing tasks of the data processing pipeline configured to retrieve, from a corresponding topic of the plurality of topics, and process a respective data item according to the data processing pipeline, the dynamic assignment based on monitoring data associated with the plurality of topics, using the workload coordinator, generating and storing, in a data store, a first dynamic assignment of a first processing task of the plurality of processing tasks to retrieve, from a first topic of the plurality of topics, and process a first data item, using the workload coordinator, generating and storing, in the data store, a second dynamic assignment of a second processing task of the plurality of processing tasks to retrieve, from a second topic of the plurality of topics, and process a second data item, executing the first processing task to cause the first processing task to obtain the first dynamic assignment from the data store and, based on the first dynamic assignment, retrieve, from the first topic, and process the first data item according to the series of nodes and interconnections specified by the data processing pipeline, and executing the second processing task to cause the second processing task to obtain the second dynamic assignment from the data store and, based on the second dynamic assignment, retrieve, from the second topic, and process the second data item according to the series of nodes and interconnections specified by the data processing pipeline.

2 . The method of claim 1 , wherein the plurality of topics comprises distinct network locations or partitions of at least one distinct network location of the distinct network locations.

3 . The method of claim 1 , wherein identifying the plurality of topics is based at least in part on a data pattern.

4 . The method of claim 1 , wherein the plurality of topics is associated with a plurality of tenants.

5 . The method of claim 1 , wherein implementing the data processing pipeline on the streaming data processing system further comprises, using the workload coordinator, identifying the first data item and the second data item for processing.

6 . The method of claim 1 , further comprising: using the workload coordinator, generating and storing, in the data store, a third dynamic assignment of the processing task identified as the workload coordinator to retrieve, from one or more topics of the plurality of topics, and process one or more data items.

7 . The method of claim 1 , wherein identifying the plurality of topics is based at least in part on a data pattern, wherein the data pattern identifies one or more of a tenant, a namespace, a topic, or a partition.

8 . The method of claim 1 , further comprising validating that a user account is authorized for implementation of the data processing pipeline based at least in part on the user account requesting the implementation of the data processing pipeline.

9 . The method of claim 1 , wherein the plurality of processing tasks comprises a plurality of parallel processing tasks.

10 . The method of claim 1 , further comprising: determining that the first data item has been removed; based on determining that the first data item has been removed, deallocating the first processing task from the first topic; and implementing an updated data processing pipeline on the streaming data processing system, wherein implementing the updated data processing pipeline on the streaming data processing system further comprises: identifying a third topic from which to obtain a third data item for processing by the data processing pipeline, and using the workload coordinator, generating and storing, in the data store, a third dynamic assignment of the first processing task to retrieve, from the third topic, and process the third data item.

11 . The method of claim 1 , further comprising: identifying a pipeline restart of the data processing pipeline; and in response to identifying the pipeline restart of the data processing pipeline, transmitting the first dynamic assignment to the first processing task.

12 . The method of claim 1 , wherein identifying the plurality of topics is based at least in part on a data pattern, the method further comprising: identifying an update of the data pattern, wherein generating and storing the first dynamic assignment and generating and storing the second dynamic assignment is based at least in part on identifying the update of the data pattern.

13 . The method of claim 1 , wherein the data store comprises an index, a global aggregate store, a block storage system, or a global data store.

14 . The method of claim 1 , wherein each topic of the plurality of topics comprises a publish-subscribe topic or an event namespace.

15 . The method of claim 1 , wherein a particular processing task of the plurality of processing tasks: obtains one or more dynamic assignments corresponding to the particular processing task; filters the one or more dynamic assignments based on a processing task index; identifies a set of the data items assigned for processing by the particular processing task based on filtering the one or more dynamic assignments; and processes the set of the data items.

16 . The method of claim 1 , wherein the data items comprise state information or credentials.

17 . Non-transitory computer readable media comprising computer-executable instructions that, when executed by a computing system of a streaming data processing system, cause the computing system to: obtain a specification of a data processing pipeline, the data processing pipeline specifying a series of nodes and interconnections between individual nodes within the series, wherein the nodes designate a transformation of data items within the data processing pipeline and wherein the interconnections designate a routing of messages through the data processing pipeline; and implement the data processing pipeline on the streaming data processing system by execution of a plurality of processing tasks, wherein to implement the data processing pipeline on the streaming data processing system, execution of the computer-executable instructions by the computing system, causes the computing system to: identify a plurality of topics of an intake ingestion buffer from which to obtain data items for processing by the data processing pipeline, identify a processing task of the plurality of processing tasks as a workload coordinator, wherein each of the plurality of processing tasks are assignable to be the workload coordinator, and wherein the workload coordinator dynamically assigns at least one topic of the plurality of topics to each of the plurality of processing tasks of the data processing pipeline configured to retrieve, from a corresponding topic of the plurality of topics, and process a respective data item according to the data processing pipeline, the dynamic assignment based on monitoring data associated with the plurality of topics, use the workload coordinator, generate and store, in a data store, a first dynamic assignment of a first processing task of the plurality of processing tasks to retrieve, from a first topic of the plurality of topics, and process a first data item, use the workload coordinator, generate and store, in the data store, a second dynamic assignment of a second processing task of the plurality of processing tasks to retrieve, from a second topic of the plurality of topics, and process a second data item, execute the first processing task to cause the first processing task to obtain the first dynamic assignment from the data store and, based on the first dynamic assignment, retrieve, from the first topic, and process the first data item according to the series of nodes and interconnections specified by the data processing pipeline, and execute the second processing task to cause the second processing task to obtain the second dynamic assignment from the data store and, based on the second dynamic assignment, retrieve, from the second topic, and process the second data item according to the series of nodes and interconnections specified by the data processing pipeline.

18 . The non-transitory computer readable media of claim 17 , wherein the execution of the computer-executable instructions by the computing system, further causes the computing system to: determine that the first data item has been removed; based on determining that the first data item has been removed, deallocate the first processing task from the first topic; and implement an updated data processing pipeline on the streaming data processing system, wherein to implement the updated data processing pipeline on the streaming data processing system, the execution of the computer-executable instructions by the computing system, causes the computing system to: identify a third topic from which to obtain a third data item for processing by the data processing pipeline, and using the workload coordinator, generate and store, in the data store, a third dynamic assignment of the first processing task to retrieve, from the third topic, and process the third data item.

19 . A computing system of a data ingestion system, the computing system comprising: a streaming data processing system configured to: obtain a specification of a data processing pipeline, the data processing pipeline specifying a series of nodes and interconnections between individual nodes within the series, wherein the nodes designate a transformation of data items within the data processing pipeline and wherein the interconnections designate a routing of messages through the data processing pipeline; and implement the data processing pipeline on the streaming data processing system by execution of a plurality of processing tasks, wherein to implement the data processing pipeline on the streaming data processing system, the streaming data processing system is further configured to: identify a plurality of topics of an intake ingestion buffer from which to obtain data items for processing by the data processing pipeline, identify a processing task of the plurality of processing tasks as a workload coordinator, wherein each of the plurality of processing tasks are assignable to be the workload coordinator, and wherein the workload coordinator dynamically assigns at least one topic of the plurality of topics to each of the plurality of processing tasks of the data processing pipeline configured to retrieve, from a corresponding topic of the plurality of topics, and process a respective data item according to the data processing pipeline, the dynamic assignment based on monitoring data associated with the plurality of topics, use the workload coordinator, generate and store, in a data store, a first dynamic assignment of a first processing task of the plurality of processing tasks to retrieve, from a first topic of the plurality of topics, and process a first data item, use the workload coordinator, generate and store, in the data store, a second dynamic assignment of a second processing task of the plurality of processing tasks to retrieve, from a second topic of the plurality of topics, and process a second data item, execute the first processing task to cause the first processing task to obtain the first dynamic assignment from the data store and, based on the first dynamic assignment, retrieve, from the first topic, and process the first data item according to the series of nodes and interconnections specified by the data processing pipeline, and execute the second processing task to cause the second processing task to obtain the second dynamic assignment from the data store and, based on the second dynamic assignment, retrieve, from the second topic, and process the second data item according to the series of nodes and interconnections specified by the data processing pipeline.

20 . The computing system of claim 19 , wherein the streaming data processing system is further configured to: determine that the first data item has been removed; based on determining that the first data item has been removed, deallocate the first processing task from the first topic; and implement an updated data processing pipeline on the streaming data processing system, wherein to implement the updated data processing pipeline on the streaming data processing system, the streaming data processing system is further configured to: identify a third topic from which to obtain a third data item for processing by the data processing pipeline, and using the workload coordinator, generate and store, in the data store, a third dynamic assignment of the first processing task to retrieve, from the third topic, and process the third data item.

Assignments (3)
CHANGE OF NAME Recorded Jul 22, 2025
From: SPLUNK INC.
To: SPLUNK LLC
Reel/Frame 072170/0599 →
ASSIGNMENT OF ASSIGNOR'S INTEREST Recorded Jul 22, 2025
From: SPLUNK LLC
To: CISCO TECHNOLOGY, INC.
Reel/Frame 072173/0058 →
CHANGE OF NAME Recorded Jan 6, 2025
From: SPLUNK INC.
To: SPLUNK LLC
Reel/Frame 069826/0065 →
References Cited (299)
US 6154781A · Bolam et al. · 2000 [cited by applicant]
US 6243713B1 · Nelson et al. · 2001 [cited by applicant]
US 6671795B1 · Marr et al. · 2003 [cited by applicant]
US 6938147B1 · Joy et al. · 2005 [cited by applicant]
US 7685281B1 · Saraiya et al. · 2010 [cited by applicant]
US 7702610B2 · Zane et al. · 2010 [cited by applicant]
US 7788594B1 · Tevanian, Jr. · 2010 [cited by applicant]
US 7895359B2 · Reed et al. · 2011 [cited by applicant]
US 7912839B1 · Asher · 2011 [cited by applicant]
US 7937344B2 · Baum et al. · 2011 [cited by applicant]
US 8065319B2 · Ding · 2011 [cited by applicant]
US 8112425B2 · Baum et al. · 2012 [cited by applicant]
US 8412696B2 · Zhang et al. · 2013 [cited by applicant]
US 8504565B2 · Pitts · 2013 [cited by applicant]
US 8504620B2 · Chi et al. · 2013 [cited by applicant]
US 8589375B2 · Zhang et al. · 2013 [cited by applicant]
US 8589403B2 · Marquardt et al. · 2013 [cited by applicant]
US 8589432B2 · Zhang et al. · 2013 [cited by applicant]
US 8612440B2 · Thang · 2013 [cited by applicant]
US 8667456B1 · Czymontek · 2014 [cited by applicant]
US 8682925B1 · Marquardt et al. · 2014 [cited by applicant]
US 8738587B1 · Bitincka et al. · 2014 [cited by applicant]
US 8738629B1 · Bitincka et al. · 2014 [cited by applicant]
US 8751529B2 · Zhang et al. · 2014 [cited by applicant]
US 8788525B2 · Neels et al. · 2014 [cited by applicant]
US 8788526B2 · Neels et al. · 2014 [cited by applicant]
US 8793225B1 · Bitincka et al. · 2014 [cited by applicant]
US 8826434B2 · Merza · 2014 [cited by applicant]
US 8924476B1 · Granstrom et al. · 2014 [cited by applicant]
US 8983994B2 · Neels et al. · 2015 [cited by applicant]
US 9026903B1 · Michael et al. · 2015 [cited by applicant]
US 9124612B2 · Vasan et al. · 2015 [cited by applicant]
US 9128980B2 · Neels et al. · 2015 [cited by applicant]
US 9128985B2 · Marquardt et al. · 2015 [cited by applicant]
US 9130971B2 · Vasan et al. · 2015 [cited by applicant]
US 9173801B2 · Merza · 2015 [cited by applicant]
US 9185007B2 · Fletcher et al. · 2015 [cited by applicant]
US 9215240B2 · Merza et al. · 2015 [cited by applicant]
US 9248068B2 · Merza · 2016 [cited by applicant]
US 9286413B1 · Coates et al. · 2016 [cited by applicant]
US 9336143B1 · Wallace et al. · 2016 [cited by applicant]
US 9348602B1 · Alapati et al. · 2016 [cited by applicant]
US 9367501B2 · Idziorek et al. · 2016 [cited by applicant]
US 9426045B2 · Fletcher et al. · 2016 [cited by applicant]
US 9426172B2 · Merza · 2016 [cited by applicant]
US 9432396B2 · Merza · 2016 [cited by applicant]
US 9514189B2 · Bitincka et al. · 2016 [cited by applicant]
US 9537692B2 · Kresse et al. · 2017 [cited by applicant]
US 9589012B2 · Neels et al. · 2017 [cited by applicant]
US 9838292B2 · Polychronis · 2017 [cited by applicant]
US 9892020B1 · Ophir et al. · 2018 [cited by applicant]
US 9928379B1 · Hoffer · 2018 [cited by applicant]
US 9990386B2 · Marquardt et al. · 2018 [cited by applicant]
US 10049160B2 · Bitincka et al. · 2018 [cited by applicant]
US 10127258B2 · Lamas et al. · 2018 [cited by applicant]
US 10193822B1 · Bacus et al. · 2019 [cited by applicant]
US 10223176B1 · Chen et al. · 2019 [cited by applicant]
US 10310966B1 · Ge et al. · 2019 [cited by applicant]
US 10360196B2 · Hsiao et al. · 2019 [cited by applicant]
US 10437653B2 · Cyr et al. · 2019 [cited by applicant]
US 10574548B2 · Coates et al. · 2020 [cited by applicant]
US 10614132B2 · Bingham et al. · 2020 [cited by applicant]
US 10691523B2 · Noel et al. · 2020 [cited by applicant]
US 10749782B2 · Turgut et al. · 2020 [cited by applicant]
US 10761813B1 · Echeverria et al. · 2020 [cited by applicant]
US 10775976B1 · Abdul-Jawad et al. · 2020 [cited by applicant]
US 10776355B1 · Batsakis et al. · 2020 [cited by applicant]
US 10776441B1 · Echeverria et al. · 2020 [cited by applicant]
US 10853186B1 · Kumar · 2020 [cited by applicant]
US 10860618B2 · Cruise et al. · 2020 [cited by applicant]
US 10880366B1 · Chen et al. · 2020 [cited by applicant]
US 10884828B2 · Deligia et al. · 2021 [cited by applicant]
US 10885021B1 · Llorca et al. · 2021 [cited by applicant]
US 10936585B1 · Echeverria et al. · 2021 [cited by applicant]
US 10936643B1 · Alspaugh et al. · 2021 [cited by applicant]
US 10984044B1 · Batsakis et al. · 2021 [cited by applicant]
US 10997180B2 · James et al. · 2021 [cited by applicant]
US 10997217B1 · Nielsen et al. · 2021 [cited by applicant]
US 11003714B1 · Batsakis et al. · 2021 [cited by applicant]
US 11048699B1 · Grider et al. · 2021 [cited by applicant]
US 11055135B2 · Popovic et al. · 2021 [cited by applicant]
US 11074107B1 · Nandakumar · 2021 [cited by applicant]
US 11106734B1 · Batsakis et al. · 2021 [cited by applicant]
US 11113353B1 · Echeverria et al. · 2021 [cited by applicant]
US 11194552B1 · Echeverria et al. · 2021 [cited by applicant]
US 11238048B1 · Breeden et al. · 2022 [cited by applicant]
US 11243704B2 · Das et al. · 2022 [cited by applicant]
US 11269939B1 · Sammer et al. · 2022 [cited by applicant]
US 11294941B1 · Sammer et al. · 2022 [cited by applicant]
US 11341257B1 · Cohen et al. · 2022 [cited by applicant]
US 11347747B1 · Paduroiu · 2022 [cited by applicant]
US 11386127B1 · Cruise et al. · 2022 [cited by applicant]
US 11474673B1 · Abdul-Jawad et al. · 2022 [cited by applicant]
US 11614923B2 · Burnett et al. · 2023 [cited by applicant]
US 11615084B1 · Echeverria et al. · 2023 [cited by applicant]
US 11636116B2 · Kulkarni et al. · 2023 [cited by applicant]
US 11645286B2 · James et al. · 2023 [cited by applicant]
US 11650995B2 · Kulkarni et al. · 2023 [cited by applicant]
US 11663219B1 · Profirovic et al. · 2023 [cited by applicant]
US 11687487B1 · Abdul-Jawad et al. · 2023 [cited by applicant]
US 11727039B2 · Cruise et al. · 2023 [cited by applicant]
US 11886440B1 · Breeden et al. · 2024 [cited by applicant]
US 11989592B1 · Kulkarni et al. · 2024 [cited by applicant]
US 12013852B1 · Echeverria et al. · 2024 [cited by applicant]
US 20020040304A1 · Shenoy et al. · 2002 [cited by applicant]
US 20020070968A1 · Austin et al. · 2002 [cited by applicant]
US 20030130993A1 · Mendelevitch et al. · 2003 [cited by applicant]
US 20030217119A1 · Raman et al. · 2003 [cited by applicant]
US 20040017395A1 · Cook · 2004 [cited by applicant]
US 20040054876A1 · Grisenthwaite et al. · 2004 [cited by applicant]
US 20040064818A1 · Alverson et al. · 2004 [cited by applicant]
US 20040225865A1 · Cox et al. · 2004 [cited by applicant]
US 20040230571A1 · Robertson · 2004 [cited by applicant]
US 20050022207A1 · Grabarnik et al. · 2005 [cited by applicant]
US 20050076067A1 · Bakalash et al. · 2005 [cited by applicant]
US 20060069717A1 · Mamou et al. · 2006 [cited by applicant]
US 20070106951A1 · McCormack et al. · 2007 [cited by applicant]
US 20070162490A1 · Rubio et al. · 2007 [cited by applicant]
US 20070168336A1 · Ransil et al. · 2007 [cited by applicant]
US 20070198641A1 · Dorai et al. · 2007 [cited by applicant]
US 20080010337A1 · Hayes et al. · 2008 [cited by applicant]
US 20080021872A1 · Borrillo et al. · 2008 [cited by applicant]
US 20080120322A1 · Liu et al. · 2008 [cited by applicant]
US 20080189332A1 · Winter · 2008 [cited by applicant]
US 20100250504A1 · Balasubramanian et al. · 2010 [cited by applicant]
US 20100318532A1 · Sznajder et al. · 2010 [cited by applicant]
US 20110173184A1 · Kelshikar et al. · 2011 [cited by applicant]
US 20110173200A1 · Yang et al. · 2011 [cited by applicant]
US 20110320391A1 · Chen et al. · 2011 [cited by applicant]
US 20110320550A1 · Lawson et al. · 2011 [cited by applicant]
US 20120079004A1 · Herman · 2012 [cited by applicant]
US 20120089612A1 · Collins et al. · 2012 [cited by applicant]
US 20120123994A1 · Lowry et al. · 2012 [cited by applicant]
US 20120197934A1 · Zhang et al. · 2012 [cited by applicant]
US 20120284331A1 · Kambatla et al. · 2012 [cited by applicant]
US 20120284713A1 · Ostermeyer et al. · 2012 [cited by applicant]
US 20130066674A1 · Vasters · 2013 [cited by applicant]
US 20130160026A1 · Kuesel et al. · 2013 [cited by applicant]
US 20130317919A1 · Raman et al. · 2013 [cited by applicant]
US 20130318236A1 · Coates et al. · 2013 [cited by applicant]
US 20130325916A1 · Pitts · 2013 [cited by applicant]
US 20140149725A1 · Gherman et al. · 2014 [cited by applicant]
US 20140181679A1 · Sarangi et al. · 2014 [cited by applicant]
US 20140297260A1 · Allen · 2014 [cited by applicant]
US 20140324862A1 · Bingham et al. · 2014 [cited by applicant]
US 20140359569A1 · Avadhanula et al. · 2014 [cited by applicant]
US 20150019537A1 · Neels et al. · 2015 [cited by applicant]
US 20150032775A1 · Yang et al. · 2015 [cited by applicant]
US 20150149507A1 · Imaki · 2015 [cited by applicant]
US 20150169714A1 · Imai et al. · 2015 [cited by applicant]
US 20150207857A1 · Horton · 2015 [cited by applicant]
US 20150213631A1 · Vander Broek · 2015 [cited by applicant]
US 20150304879A1 · Dacosta · 2015 [cited by applicant]
US 20150331910A1 · Srinivasan et al. · 2015 [cited by applicant]
US 20150332481A1 · Rosasco · 2015 [cited by applicant]
US 20150379672A1 · Wang · 2015 [cited by applicant]
US 20160048408A1 · Madhu et al. · 2016 [cited by applicant]
US 20160050261A1 · McDaid et al. · 2016 [cited by applicant]
US 20160062736A1 · Stanfill et al. · 2016 [cited by applicant]
US 20160085810A1 · de Castro Alves et al. · 2016 [cited by applicant]
US 20160098432A1 · Madany et al. · 2016 [cited by applicant]
US 20160103659A1 · Tijanic et al. · 2016 [cited by applicant]
US 20160117158A1 · MacCleery et al. · 2016 [cited by applicant]
US 20160140205A1 · Hsu et al. · 2016 [cited by applicant]
US 20160179884A1 · Jerzak · 2016 [cited by applicant]
US 20160203135A1 · Bhattacharjee et al. · 2016 [cited by applicant]
US 20160224459A1 · Liu et al. · 2016 [cited by applicant]
US 20160246834A1 · Regni et al. · 2016 [cited by applicant]
US 20160268013A1 · Markovich et al. · 2016 [cited by applicant]
US 20160286013A1 · Yu et al. · 2016 [cited by applicant]
US 20160291942A1 · Hutchison · 2016 [cited by applicant]
US 20160321109A1 · He et al. · 2016 [cited by applicant]
US 20160342454A1 · Noel et al. · 2016 [cited by applicant]
US 20160364093A1 · Denton et al. · 2016 [cited by applicant]
US 20170006135A1 · Siebel et al. · 2017 [cited by applicant]
US 20170012909A1 · Lieu · 2017 [cited by applicant]
US 20170024912A1 · de Castro Alves et al. · 2017 [cited by applicant]
US 20170046374A1 · Fletcher et al. · 2017 [cited by applicant]
US 20170083588A1 · Lang et al. · 2017 [cited by applicant]
US 20170103103A1 · Nixon et al. · 2017 [cited by applicant]
US 20170104819A1 · Anastasi et al. · 2017 [cited by applicant]
US 20170109378A1 · Brewster et al. · 2017 [cited by applicant]
US 20170124166A1 · Thomas et al. · 2017 [cited by applicant]
US 20170180289A1 · Chiappone et al. · 2017 [cited by applicant]
US 20170199809A1 · Michelsen · 2017 [cited by applicant]
US 20170220685A1 · Yan et al. · 2017 [cited by applicant]
US 20170243132A1 · Sainani et al. · 2017 [cited by applicant]
US 20170351585A1 · Bourbonnais et al. · 2017 [cited by applicant]
US 20170372016A1 · Jiang · 2017 [cited by applicant]
US 20180011655A1 · Gredler et al. · 2018 [cited by applicant]
US 20180041525A1 · Elgressy et al. · 2018 [cited by applicant]
US 20180074752A1 · Nakazono et al. · 2018 [cited by applicant]
US 20180074870A1 · Park et al. · 2018 [cited by applicant]
US 20180089324A1 · Pal et al. · 2018 [cited by applicant]
US 20180113783A1 · Luo et al. · 2018 [cited by applicant]
US 20180189642A1 · Boesch et al. · 2018 [cited by applicant]
US 20180210955A1 · Crabtree · 2018 [cited by examiner]
US 20180246983A1 · Rathod · 2018 [cited by applicant]
US 20180262592A1 · Zandhi et al. · 2018 [cited by applicant]
US 20180284975A1 · Carrier · 2018 [cited by examiner]
US 20180329644A1 · Das et al. · 2018 [cited by applicant]
US 20180332367A1 · Kaitchuck et al. · 2018 [cited by applicant]
US 20190034813A1 · Das et al. · 2019 [cited by applicant]
US 20190065248A1 · Ravindran · 2019 [cited by examiner]
US 20190081759A1 · Wang et al. · 2019 [cited by applicant]
US 20190098106A1 · Mungel et al. · 2019 [cited by applicant]
US 20190109848A1 · Clark et al. · 2019 [cited by applicant]
US 20190155802A1 · Miller et al. · 2019 [cited by applicant]
US 20190213552A1 · Gupta et al. · 2019 [cited by applicant]
US 20190230153A1 · McPhee et al. · 2019 [cited by applicant]
US 20190243683A1 · Botelho · 2019 [cited by examiner]
US 20190349426A1 · Smith et al. · 2019 [cited by applicant]
US 20190355022A1 · Hertel et al. · 2019 [cited by applicant]
US 20190361688A1 · Chigakkagari et al. · 2019 [cited by applicant]
US 20190377816A1 · McCluskey et al. · 2019 [cited by applicant]
US 20190379650A1 · Hale et al. · 2019 [cited by applicant]
US 20190384659A1 · Johannsen et al. · 2019 [cited by applicant]
US 20190384836A1 · Roth et al. · 2019 [cited by applicant]
US 20200012935A1 · Goodsitt et al. · 2020 [cited by applicant]
US 20200034468A1 · Lei et al. · 2020 [cited by applicant]
US 20200050612A1 · Bhattacharjee et al. · 2020 [cited by applicant]
US 20200089529A1 · Brownsword et al. · 2020 [cited by applicant]
US 20200104401A1 · Burnett et al. · 2020 [cited by applicant]
US 20200175040A1 · Faltz et al. · 2020 [cited by applicant]
US 20200225655A1 · Cella et al. · 2020 [cited by applicant]
US 20200265057A1 · Jolfaei · 2020 [cited by applicant]
US 20200274915A1 · Ramon · 2020 [cited by applicant]
US 20200293835A1 · Doni et al. · 2020 [cited by applicant]
US 20200356676A1 · Gorlamandala · 2020 [cited by applicant]
US 20200379892A1 · Velipasaoglu et al. · 2020 [cited by applicant]
US 20200389690A1 · Morris · 2020 [cited by applicant]
US 20210034615A1 · Chen et al. · 2021 [cited by applicant]
US 20210117857A1 · Sriharsha · 2021 [cited by applicant]
US 20210117868A1 · Sriharsha · 2021 [cited by applicant]
US 20210173670A1 · Borra et al. · 2021 [cited by applicant]
US 20210191793A1 · Mccrary · 2021 [cited by examiner]
US 20210200533A1 · Gage et al. · 2021 [cited by applicant]
US 20210224178A1 · Singh et al. · 2021 [cited by applicant]
US 20210232579A1 · Schechter et al. · 2021 [cited by applicant]
US 20210240519A1 · Gitelman · 2021 [cited by examiner]
US 20210303584A1 · Fan et al. · 2021 [cited by applicant]
US 20210365477A1 · Pippin · 2021 [cited by examiner]
US 20210397465A1 · Mellquist et al. · 2021 [cited by applicant]
US 20220121477A1 · Chivukula et al. · 2022 [cited by applicant]
US 20220150514A1 · Miller et al. · 2022 [cited by applicant]
US 20220245156A1 · Kulkarni et al. · 2022 [cited by applicant]
US 20230015926A1 · Cruise · 2023 [cited by applicant]
US 20230244673A1 · James · 2023 [cited by applicant]
US 20230342380A1 · Cruise · 2023 [cited by applicant]
US 20230385288A1 · Kulkarni · 2023 [cited by applicant]
CN 106991011A · 2017 [cited by applicant]
CN 112612605A · 2021 [cited by examiner]
DE 60002200T2 · 2004 [cited by applicant]
WO WO2019195969 · 2019 [cited by applicant]
WO WO2021222395 · 2021 [cited by applicant]
WO WO2022164925 · 2022 [cited by applicant]
Anonymous, “StreamSets 3.15.x release notes,” Apr. 28, 2020, XP055819684, retrieved from the internet: URL:https://docs.streamsets.com/datacollector/3.15.x/releasenotes/SDC_RN_3.15.x.pdf[retrieved on Jun. 30, 2021]. [cited by applicant]
Anonymous, “StreamSets Docs—Databricks Query,” Apr. 28, 2020, XP055819677, retrieved from the internet: URL:https://docs.streamsets.com/portal/#controlhub/3.15.x/onpremhelp/datacollector/UserGuide/Executors/DatabricksQu… [cited by applicant]
Anonymous, “StreamSets Docs—Dataflow Triggers,” Apr. 28, 2010, XP055819664, retrieved from the internet: URL:https://docs.streamsets.com/portal/#controlhum/3.15.x/onpremhelp/datacollector/UserGuide/Event_Handling/EventF… [cited by applicant]
Anonymous, “StreamSets Docs—Destinations,” Apr. 28, 2020, XP055819673, retrieved from the internet: URL:https://docs.streamsets.com/portal/#controlhub/3.15.x/onpremhelp/datacollector/UserGuide/Destinations/Destinations_… [cited by applicant]
Anonymous, “StreamSets Docs—Google Pub/Sub Publisher,” Apr. 28, 2020, XP055819675, retrieved from the internet: URL:https://docs.streamsets.com/portal/#controlhub/3.15.x/onpremhelp/datacollector/UserGuide/Destinations/P… [cited by applicant]
Anonymous, “StreamSets Docs—Pipeline Designer UI,” Apr. 28, 2020, XP055819666, retrieved from the internet: URL:https://docs.streamsets.com/portal/#controlhub/3.15.x/onpremhelp/datacollector/UserGuide/Pipeline_Configura… [cited by applicant]
Anonymous, “StreamSets Docs—Simple and Bulk Edid Mode,” Apr. 28, 2020, XP055819681, retrieved from the internet: URL:https://docs.streamsets.com/portal/#controlhub/3.15.x/onpremhelp/datacollector/UserGuide/Pipeline_Conf… [cited by applicant]
Atkinson, Harmonizing Textual and Graphical Visualizations of Domain Specific Models, 2013, pp. 1-10, http://www.dsmforum.org/events/gmid13/papers/p32_atkinson.pdf (Year: 2013). [cited by applicant]
Bakliwal, A Comprehensive Guide to Apache Flink Ecosystem Components, Feb. 18, 2017, 8 pages, retrieved from: https://www.linkedin.com/pulse/comprehensive-guide-apache-flink-ecosystem-components-bakliwal/. [cited by applicant]
Bitincka, Ledion et al., “Optimizing Data Analysis with a Semi-structured Time Series Database,” self-published, first presented at “Workshop on Managing Systems via Log Analysis and Machine Learning Techniques (SLAML)”… [cited by applicant]
Carraso, David, “Exploring Splunk,” published by CITO Research, New York, NY, Apr. 2012. [cited by applicant]
Hayden, et al., “Kitsune: Efficient, general-purpose dynamic software updating for C.” Proceedings of the ACM international conference on Object oriented programming systems languages and applications. 2012. [cited by applicant]
International Search Report and Written Opinion, re PCT Application No. PCT/US2021/029623, mailed Jul. 8, 2021. [cited by applicant]
International Preliminary Report on Patentability, re PCT Application No. PCT/US2021/029623, issued Oct. 27, 2022. [cited by applicant]
International Search Report and Written Opinion, re PCT Application No. PCT/US2022/013937, mailed Apr. 19, 2022. [cited by applicant]
International Written Opinion, re PCT Application No. PCT/US2022/013937, mailed Jan. 3, 2023. [cited by applicant]
International Preliminary Report on Patentability, re PCT Application No. PCT/US2022/013937, mailed Mar. 20, 2023. [cited by applicant]
Keystone Real-time Stream Processing Platform, The Netflix Tech Blog, Sep. 10, 2013, retrieved from https://netflixtechblog.com/keystone-real-time-stream-processing-platform-a3ee651812a?gi=71cc12ef6b89. [cited by applicant]
Lopes, et al., “Bonsai: an event-based framework from processing and controlling data streams,” Frontiers in Neuroinformatics, [Online] vol. 9, Apr. 8, 2015, XP055819723, retrieved from the internet: URL:https://www.fro… [cited by applicant]
Mahapatra, Tanmaya , High-Level Graphical Programming for Big Data Applications, 2019, pp. 1-215. http://mediatum.ub.tum.de/doc/1524977/41093.pdf (Year: 2019). [cited by applicant]
Makris, et al., “Immediate Multi-Threaded Dynamic Software Updates Using Stack Reconstruction,” USENIX annual technical conference. vol. 2009. [cited by applicant]
Metzger, Kafka + Flink: A Practical, How-To Guide, Sep. 2, 2015,16 pages, retrieved from: https://www.ververica.com/blog/kafka-flink-a-practical-how-to. [cited by applicant]
Netflix Keystone SPaaS: Real-time Stream Processing as a Service—ABD320—re:Invent 2017 clip slide, retrieved from https://www.slideshare.net/AmazonWebServices/netflix-keystone-spaas-realtime-stream-processing-as-a-servi… [cited by applicant]
SLAML 10 Reports, Workshop On Managing Systems via Log Analysis and Machine Learning Techniques. ;login: Feb. 2011—Conference Reports—vol. 36, No. 1, pp. 104-110. [cited by applicant]
Splunk Cloud User Manual 8.0.2004—splunk> turn data in doing—copyright 2020 Splunk Inc.—in 66 pages—Retrieved from Splunk Documentation <URL: https://docs.splunk.com/Documentation> on May 20, 2020. [cited by applicant]
Splunk Enterprise Overview 8.0.0—splunk > turn data into doing—copyright 2020 Splunk Inc.—in 17 pages—Retrieved from Splunk Documentation <URL: https://docs.splunk.com/Documentation> on May 20, 2020. [cited by applicant]
Splunk Quick Reference Guide, updated 2019, available online at https://www.splunk.com/pdfs/solution-guides/splunk-quick-reference-guide.pdf, retrieved May 20, 2020. [cited by applicant]
U.S. Appl. No. 16/945,657, filed Jul. 31, 2020, Abdul-Jawad et al. [cited by applicant]
U.S. Appl. No. 17/199,318, filed Mar. 11, 2021, Abdul-Jawad et al. [cited by applicant]
U.S. Appl. No. 17/239,384, filed Apr. 23, 2021, Profirovic et al. [cited by applicant]
U.S. Appl. No. 17/444,157, filed Jul. 30, 2021, Cannon et al. [cited by applicant]
U.S. Appl. No. 17/444,170, filed Jul. 30, 2021, Grier et al. [cited by applicant]
U.S. Appl. No. 17/476,323, filed Sep. 15, 2021, Ma et al. [cited by applicant]
U.S. Appl. No. 17/589,441, filed Jan. 31, 2022, Breeden et al. [cited by applicant]
U.S. Appl. No. 18/190,815, filed Mar. 27, 2023. [cited by applicant]
U.S. Appl. No. 18/192,136, filed Mar. 29, 2023, James et al. [cited by applicant]
U.S. Appl. No. 18/304,770, filed Apr. 21, 2023, Kulkarni et al. [cited by applicant]
Ware Myers, Skating Out the Graphics Display Pipeline, 1984. [cited by applicant]
Wiener, et al.: “Industry Paper: Managing Geo-Distributed Stream Processing Pipelines for the IIoT with StreamPipes Edge Extensions,” In the 14th ACM Internatioal Conference on Distributed and Event-based Systems (DEBS … [cited by applicant]
Wu, Building Stream Processing as a Service (SPaaS), retried on Apr. 9, 2020 from https://cdn.oreillystatic.com/en/assets/1/event/281/Building%20stream%20processing%20as%20a%20service%20at%20Netflix%20Presentation.pdf. [cited by applicant]
Zhang et al., “Coupling Browse and Search in Highly Interactive User Interfaces: A Study of the Relation Browser,” Published in UNC.Edu; 2004. [cited by applicant]
U.S. Appl. No. 18/343,420, filed Jun. 28, 2023, Cruise et al. [cited by applicant]
U.S. Appl. No. 18/656,424, filed May 6, 2024, Echeverria et al. [cited by applicant]