IP Library › Granted Patent US 12,645,704
Granted Patent B1
US 12,645,704 · App. 18/818,459 · Granted Jun 2, 2026

Low-latency streaming analytics

Inventors: Alexander William Cruise (Vancouver, CA); Byron Jason Shelden (Coquitlam, CA); Claire Alexandria Tanner Semple (Vancouver, CA)
Assignee: Cisco Technology, Inc.
G06F16/285G06F9/542G06F11/30G06F16/24568G06F16/288G06Q10/10
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,645,704
App. No.
18/818,459
Granted
Jun 2, 2026
Kind
B1
Abstract

Systems and methods are disclosed for implementing a low-latency data stream monitoring system. The data stream monitoring system may obtain raw data from a data source as soon after the data is generated, and may classify the data according to different topics. The topics may be published in a publish-subscribe messaging model, and data enrichment systems may subscribe to the topics to receive data for enrichment. The data enrichment systems may supplement or replace the raw data with additional information, and may further classify or reclassify the enriched data into different topics. The enriched data may then be published to an alert generation system, which may apply various criteria to the enriched data to determine that alerts should be generated, generate the alerts, and publish or transmit the alerts to client devices. Individual data streams, topics, enrichments, criteria, and alarms may be added, removed, or modified as required.

Claims (31)

1 . A method comprising:

iteratively processing a set of messages through a data stream processing system, wherein the data stream processing system processes the set of messages at least partly in parallel, wherein processing the set of messages includes, for an individual message:

providing a modified message from the data stream processing system to the data stream processing system for continued processing including at least evaluation of the modified message by the data stream processing system according to a set of rules, wherein the modified message is generated by modifying content of the individual message; and

providing an output based at least in part on evaluating the modified message according to the set of rules maintained by the data stream processing system.

2 . The method of claim 1 , wherein processing the set of messages at least partly in parallel includes providing the modified message, from the data stream processing system to the data stream processing system for continued processing, in parallel with providing an additional output based at least in part on an evaluation of an additional modified message according to the set of rules maintained by the data stream processing system.

3 . The method of claim 1 , wherein the output comprises an alert that is generated based at least in part on a determination that a first rule of the set of rules has been satisfied.

4 . The method of claim 1 , wherein evaluating the modified message according to the set of rules comprises applying at least a first rule of the set of rules to modified content of the modified message.

5 . The method of claim 1 further comprising generating the modified message.

6 . The method of claim 1 , wherein modifying the content of the individual message comprises replacing at least a portion of the content with data obtained from an external data source.

7 . The method of claim 1 , wherein modifying the content of the individual message comprises enriching the content with data obtained from an external data source.

8 . The method of claim 1 further comprising providing the output from the data stream processing system to the data stream processing system for continued processing.

9 . The method of claim 1 further comprising obtaining the set of rules based at least in part on modified content of the modified message.

10 . The method of claim 1 further comprising associating a topic with the modified message based at least in part on modified content of the modified message.

11 . The method of claim 1 , wherein the individual message is obtained by processing streaming data from a data source.

12 . The method of claim 1 , wherein modifying the content of the individual message comprises transmitting the individual message to a data enrichment system.

13 . The method of claim 1 further comprising determining, based at least in part on the content of the individual message, that data enrichment is available for the individual message.

14 . The method of claim 1 further comprising publishing the modified message to a subscriber.

15 . The method of claim 1 , wherein the output includes at least a portion of the modified message.

16 . The method of claim 1 further comprising determining to provide the output from the data stream processing system to the data stream processing system for continued processing based at least in part on the individual message.

17 . The method of claim 1 further comprising determining to provide the output from the data stream processing system to the data stream processing system for continued processing based at least in part on the modified message.

18 . A system comprising:

a data store including computer-executable instructions; and

a processor configured to execute the computer-executable instructions to:

iteratively process a set of messages through a data stream processing system, wherein the data stream processing system processes the set of messages at least partly in parallel, wherein processing the set of messages includes, for an individual message:

providing a modified message from the data stream processing system to the data stream processing system for continued processing including at least evaluation of the modified message by the data stream processing system according to a set of rules, wherein the modified message is generated by modifying content of the individual message; and

providing an output based at least in part on the evaluation of the modified message according to the set of rules maintained by the data stream processing system.

19 . The system of claim 18 , wherein the computer-executable instructions further cause the processor to identify the set of rules based at least in part on the modified message.

20 . One or more non-transitory computer-readable media comprising computer-executable instructions that, when executed by a computing system, cause the computing system to:

iteratively process a set of messages through a data stream processing system, wherein the data stream processing system processes the set of messages at least partly in parallel, wherein processing the set of messages includes, for an individual message:

providing a modified message from the data stream processing system to the data stream processing system for continued processing including at least evaluation of the modified message by the data stream processing system according to a set of rules, wherein the modified message is generated by modifying content of the individual message; and

providing an output based at least in part on the evaluation of the modified message according to the set of rules maintained by the data stream processing system.

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 →
Continuity (4)
Continuation 18343420 · Jun 28, 2023
Continuation 17811849 · Jul 11, 2022
Continuation 17114283 · Dec 7, 2020
Continuation 15715077 · Sep 25, 2017
References Cited (344)
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 8374986B2 · Indeck et al. · 2013 [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 11226885B1 · Gasser et al. · 2022 [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 12105740B2 · Cruise 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 · 2003 [cited by examiner]
US 20030217119A1 · Raman et al. · 2003 [cited by applicant]
US 20040015344A1 · Shimomura et al. · 2004 [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 · 2007 [cited by examiner]
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 20080310267A1 · Hattori et al. · 2008 [cited by applicant]
US 20090105879A1 · Ng-Thow-Hing · 2009 [cited by examiner]
US 20090196186A1 · Lidstrom et al. · 2009 [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 20130166965A1 · Brochu 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 examiner]
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 20150317572A1 · Balasubramanian · 2015 [cited by applicant]
US 20150331910A1 · Srinivasan et al. · 2015 [cited by applicant]
US 20150332481A1 · Rosasco · 2015 [cited by applicant]
US 20150341739A1 · Jin et al. · 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 20160078455A1 · O'Donnell 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 20160140596A1 · Green et al. · 2016 [cited by applicant]
US 20160170994A1 · Soderberg et al. · 2016 [cited by applicant]
US 20160179884A1 · Jerzak · 2016 [cited by applicant]
US 20160203135A1 · Bhattacharjee et al. · 2016 [cited by applicant]
US 20160212099A1 · Zou 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 20170214573A1 · Linsky et al. · 2017 [cited by applicant]
US 20170220685A1 · Yan et al. · 2017 [cited by applicant]
US 20170243132A1 · Sainani et al. · 2017 [cited by applicant]
US 20170265020A1 · Dewangan 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 20180032908A1 · Nagaraju et al. · 2018 [cited by applicant]
US 20180034715A1 · Nagaraju 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 20180089287A1 · Haggie 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 20180121963A1 · Hwang et al. · 2018 [cited by applicant]
US 20180189642A1 · Boesch et al. · 2018 [cited by applicant]
US 20180210955A1 · Crabtree et al. · 2018 [cited by applicant]
US 20180246983A1 · Rathod · 2018 [cited by applicant]
US 20180262592A1 · Zandhi et al. · 2018 [cited by applicant]
US 20180284975A1 · Carrier et al. · 2018 [cited by applicant]
US 20180310889A1 · Ten Kate · 2018 [cited by applicant]
US 20180329644A1 · Das et al. · 2018 [cited by applicant]
US 20180332367A1 · Kaitchuck · 2018 [cited by examiner]
US 20180341992A1 · Bostick et al. · 2018 [cited by applicant]
US 20180376416A1 · Khanna · 2018 [cited by applicant]
US 20190034813A1 · Das et al. · 2019 [cited by applicant]
US 20190065248A1 · Ravindran et al. · 2019 [cited by applicant]
US 20190081759A1 · Wang et al. · 2019 [cited by applicant]
US 20190095510A1 · Cruise 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 20190146960A1 · Beedgen 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 applicant]
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 20200019638A1 · Dilova et al. · 2020 [cited by applicant]
US 20200034468A1 · Lei · 2020 [cited by examiner]
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 20200142810A1 · Zingade 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 applicant]
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 et al. · 2021 [cited by applicant]
US 20210303584A1 · Fan et al. · 2021 [cited by applicant]
US 20210342125A1 · Burnett et al. · 2021 [cited by applicant]
US 20210365477A1 · Pippin et al. · 2021 [cited by applicant]
US 20210397465A1 · Mellquist et al. · 2021 [cited by applicant]
US 20220004557A1 · James et al. · 2022 [cited by applicant]
US 20220121477A1 · Chivukula et al. · 2022 [cited by applicant]
US 20220150514A1 · Miller et al. · 2022 [cited by applicant]
US 20220245115A1 · Kulkarni et al. · 2022 [cited by applicant]
US 20220245156A1 · Kulkarni et al. · 2022 [cited by applicant]
US 20220247695A1 · Kulkarni et al. · 2022 [cited by applicant]
US 20230015926A1 · Cruise et al. · 2023 [cited by applicant]
US 20230244673A1 · James · 2023 [cited by applicant]
US 20230342380A1 · Cruise et al. · 2023 [cited by applicant]
US 20230385288A1 · Kulkarni · 2023 [cited by applicant]
CN 106991011A · 2017 [cited by applicant]
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/Destin ations/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_Configuar… [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/175,518, filed Feb. 12, 2021, Echeverria 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/236,925, filed Apr. 21, 2021, James 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,152, filed Jul. 30, 2021, Cannon 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/444,172, 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. 17/811,849, filed Jul. 11, 2022, Cruise 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]
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]
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]
Abdul-Jawad B., et al., “Visual Previews for Programming an Iterative Publish-Subscribe Message Processing System,” U.S. Appl. No. 16/148,703, filed Oct. 1, 2018, 292 Pages. [cited by applicant]
Co-Pending U.S. Appl. No. 15/715,077, filed Sep. 25, 2017, “Low-Latency Streaming Analytics,” 148 Pages. [cited by applicant]
Cruise A.W., et al., “System and Method for Centralized Analytics for Edge Devices with Enrichment Pushdown,” Co-Pending U.S. Appl. No. 16/264,526, filed Jan. 31, 2019, Prosecution History (102150.0007P), 86 Pages. [cited by applicant]
Cruise A.W., et al., “System and Method for Centralized Analytics for Edge Devices with Enrichment Pushdown,” Co-Pending U.S. Appl. No. 17/148,478, filed Jan. 13, 2020, Prosecution History (102150.0007P2), 85 Pages. [cited by applicant]
Echeverria J.G., et al., “Assisted Visual Programming for Iterative Publish-Subscribe Message Processing System,” U.S. Appl. No. 16/148,736, filed Oct. 1, 2018, 292 Pages. [cited by applicant]
Echeverria J.G., et al., “Unified Data Processing Across Streaming and Indexed Data Sets,” U.S. Appl. No. 16/177,234, filed Oct. 31, 2018, 309 Pages. [cited by applicant]
Echeverria J.G., et al., “Visual Programming for Iterative Publish-Subscribe Message Processing System,” U.S. Appl. No. 16/148,840, filed Oct. 1, 2018, 293 Pages. [cited by applicant]
Sammer E., et al., “Iterative Message-Based Data Processing Including Streaming Analytics,” U.S. Appl. No. 15/967,581, filed Apr. 30, 2018, 278 Pages. [cited by applicant]
Sammer E., et al., “Message-Based Data Ingestion to a Data Intake and Query System,” U.S. Appl. No. 16/000,688, filed Jun. 5, 2018, 242 Pages. [cited by applicant]
Varghese B., et al., “Feasibility of Fog Computing,” Jan. 19, 2017, https://arxiv.org/pdf/1701.05451, 8 pages. [cited by applicant]