IP Library › Granted Patent US 12,423,309
Granted Patent B2
US 12,423,309 · App. 18/192,136 · Granted Sep 23, 2025

Dynamic query processor for streaming and batch queries

Inventors: Alexander Douglas James (Sammamish, WA); Joseph Gabriel Echeverria (San Francisco, CA); Eric Sammer (San Francisco, CA)
G06F16/24568G06F16/24542G06F16/901G06F16/90335
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,423,309
App. No.
18/192,136
Granted
Sep 23, 2025
Kind
B2
Abstract

Operational machine components of an information technology (IT) or other microprocessor- or microcontroller-permeated environment generate disparate forms of machine data. Network connections are established between these components and processors of data intake and query system (DIQS). The DIQS conducts network transactions on a periodic and/or continuous basis with the machine components to receive disparate data and ingest certain of the data as entries of a data store that is searchable for DIQS query processing. The DIQS may receive queries to process against the received and ingested data via an exposed network interface. In one example embodiment, the DIQS receives a query identifying data to be processed, dynamically generates a query processing scheme based on the state of the data to be processed, such as streaming or at rest, and dynamically communicates the query processing scheme to a query executor based on the state of the data to be processed.

Claims (91)

1. A method, comprising:

identifying, by a query processor, a set of streaming data to be processed;

generating, by the query processor, a first data processing scheme for obtaining and processing the set of streaming data based on a state of the set of streaming data, wherein the first data processing scheme comprises a first plurality of computer-executable instructions for obtaining and processing the set of streaming data;

communicating, by the query processor, the first data processing scheme to a first data processor based on the state of the set of streaming data, wherein execution of the first plurality of computer-executable instructions causes the first data processor to obtain and process the set of streaming data;

identifying, by the query processor, a set of data at rest to be processed;

generating, by the query processor, a second data processing scheme for obtaining and processing the set of data at rest based on a state of the set of data at rest, wherein the second data processing scheme comprises a second plurality of computer-executable instructions, different than the first plurality of computer-executable instructions, for obtaining and processing the set of data at rest; and

communicating, by the query processor, the second data processing scheme to a second data processor based on the state of the set of data at rest, wherein the second data processor is different than the first data processor and execution of the second plurality of computer-executable instructions causes the second data processor to obtain and process the set of data at rest, wherein generating the first data processing scheme for the first data processor and generating the second data processing scheme for the second data processor via the query processor reduces computing resource usage.

2. The method of claim 1 , wherein the first data processing scheme is a first query execution scheme, and generating the first query execution scheme comprises:

parsing a query,

generating a preliminary first data processing scheme based on the parsing, and

applying one or more optimizations to the preliminary first data processing scheme to generate the first query execution scheme.

3. The method of claim 1 , wherein the first data processing scheme is a modified first data processing scheme, and generating the modified first data processing scheme comprises:

parsing a query,

generating a preliminary first data processing scheme based on the parsing, and

generating the modified first data processing scheme based on an application of one or more streaming specific optimizations to the preliminary first data processing scheme.

4. The method of claim 1 , wherein the first data processing scheme is a modified first data processing scheme, and generating the modified first data processing scheme comprises:

parsing a query,

generating a preliminary first data processing scheme based on the parsing, and

generating the modified first data processing scheme based on an application of a set of streaming-specific configurations to the preliminary first data processing scheme, wherein the set of streaming-specific configurations are applied to the preliminary first data processing scheme based on the state of the set of streaming data.

5. The method of claim 1 , wherein the first data processing scheme is a modified first data processing scheme, and generating the modified first data processing scheme comprises:

parsing a query,

generating a preliminary first data processing scheme based on the parsing, and

generating the modified first data processing scheme based on an application of one or more general optimizations and one or more streaming-specific optimizations to the preliminary first data processing scheme, wherein the one or more streaming-specific optimizations are applied based on the state of the set of streaming data.

6. The method of claim 1 , wherein the first data processing scheme is a modified first data processing scheme, and generating the modified first data processing scheme comprises:

parsing a query,

generating a preliminary first data processing scheme based on the parsing, and

generating the modified first data processing scheme based on an application of one or more general optimizations and one or more streaming-specific optimizations to the preliminary first data processing scheme, wherein the one or more streaming-specific optimizations are applied based on the state of the set of streaming data and the one or more general optimizations are applied regardless of the state of the set of streaming data.

7. The method of claim 1 , wherein the first data processing scheme is a modified first data processing scheme, and generating the modified first data processing scheme comprises:

parsing a query,

generating a preliminary first data processing scheme based on the parsing, and

generating the modified first data processing scheme based on an application of a time constraint to one or more commands of the preliminary first data processing scheme, wherein the time constraint is applied based on the state of the set of streaming data.

8. The method of claim 1 , wherein the second data processing scheme is a modified second data processing scheme, and generating the modified second data processing scheme comprises:

parsing a query,

generating a preliminary second data processing scheme based on the parsing, and

generating the modified second data processing scheme based on pushing one or more commands of the preliminary second data processing scheme to an external data store, wherein the one or more commands are pushed to the external data store based on the state of the set of data at rest.

9. A computing system, comprising:

a plurality of data processors including a first data processor and a second data processor, wherein the second data processor is different than the first data processor, wherein the first data processor is configured to process data of a first type and the second data processor is configured to process data of a second type; and

one or more processing devices configured to:

identify, by a query processor, a set of streaming data to be processed;

generate, by the query processor, a first data processing scheme for obtaining and processing the set of streaming data based on a state of the set of streaming data, wherein the first data processing scheme comprises a first plurality of computer-executable instructions for obtaining and processing the set of streaming data;

communicate, by the query processor, the first data processing scheme to the first data processor based on the state of the set of streaming data, wherein execution of the first plurality of computer-executable instructions causes the first data processor to obtain and process the set of streaming data;

identify, by the query processor, a set of data at rest to be processed;

generate, by the query processor a second data processing scheme for obtaining and processing the set of data at rest based on a state of the set of data at rest, wherein the second data processing scheme comprises a second plurality of computer-executable instructions, different than the first plurality of computer-executable instructions, for obtaining and processing the set of data at rest; and

communicate, by the query processor, the second data processing scheme to the second data processor based on the state of the set of data at rest, wherein the second data processor executes the second data processing scheme and execution of the second plurality of computer-executable instructions causes the second data processor to obtain and process the set of data at rest, wherein generating the first processing scheme for the first data processor and generating the second data processing scheme for the second data processor via the query processor reduces computing resource usage.

10. The computing system of claim 9 , wherein the first data processing scheme is a first query execution scheme, and wherein to generate the first query execution scheme, the one or more processing devices are configured to:

parse a query,

generate a preliminary first data processing scheme based on the parsing, and

apply one or more optimizations to the preliminary first data processing scheme to generate the first query execution scheme.

11. The computing system of claim 9 , wherein the first data processing scheme is a modified first data processing scheme, and wherein to generate the modified first data processing scheme, the one or more processing devices are configured to:

parse a query,

generate a preliminary first data processing scheme based on the parsing, and

generate the modified first data processing scheme based on an application of one or more streaming specific optimizations to the preliminary first data processing scheme.

12. The computing system of claim 9 , wherein the first data processing scheme is a modified first data processing scheme and wherein to generate the modified first data processing scheme, the one or more processing devices are configured to:

parse a query,

generate a preliminary first data processing scheme based on the parsing, and

generate the modified first data processing scheme based on an application of a set of streaming-specific configurations to the preliminary first data processing scheme, wherein the set of streaming-specific configurations are applied to the preliminary first data processing scheme based on the state of the set of streaming data.

13. The computing system of claim 9 , wherein the first data processing scheme is a modified first data processing scheme and wherein to generate the modified first data processing scheme, the one or more processing devices are configured to:

parse a query,

generate a preliminary first data processing scheme based on the parsing, and

generate the modified first data processing scheme based on an application of one or more general optimizations and one or more streaming-specific optimizations to the preliminary first data processing scheme, wherein the one or more streaming-specific optimizations are applied based on the state of the set of streaming data.

14. The computing system of claim 9 , wherein the first data processing scheme is a modified first data processing scheme and wherein to generate the modified first data processing scheme, the one or more processing devices are configured to:

parse a query,

generate a preliminary first data processing scheme based on the parsing, and

generate the modified first data processing scheme based on an application of one or more general optimizations and one or more streaming-specific optimizations to the preliminary first data processing scheme, wherein the one or more streaming-specific optimizations are applied based on the state of the set of streaming data and the one or more general optimizations are applied regardless of the state of the set of streaming data.

15. The computing system of claim 9 , wherein the first data processing scheme is a modified first data processing scheme and wherein to generate the modified first data processing scheme, the one or more processing devices are configured to:

parse a query,

generate a preliminary first data processing scheme based on the parsing, and

generate the modified first data processing scheme based on an application of a time constraint to one or more commands of the preliminary first data processing scheme, wherein the time constraint is applied based on the state of the set of streaming data.

16. The computing system of claim 9 , wherein the first data processing scheme is a modified first data processing scheme and wherein to generate the modified first data processing scheme, the one or more processing devices are configured to:

parse a query,

generate a preliminary second data processing scheme based on the parsing, and

generate a modified second data processing scheme based on pushing one or more commands of the preliminary second data processing scheme to an external data store, wherein the one or more commands are pushed to the external data store based on the state of the set of data at rest.

17. Non-transitory computer-readable media comprising computer-executable instructions that, when executed by a computing system, cause the computing system to:

identify, by a query processor, a set of streaming data to be processed;

generate, by the query processor, a first data processing scheme for obtaining and processing the set of streaming data based on a state of the set of streaming data, wherein the first data processing scheme comprises a first plurality of computer-executable instructions for obtaining and processing the set of streaming data;

communicate, by the query processor, the first data processing scheme to a first data processor based on the state of the set of streaming data, wherein execution of the first plurality of computer-executable instructions causes the first data processor to obtain and process the set of streaming data;

identify, by the query processor, a set of data at rest to be processed;

generate, by the query processor, a second data processing scheme for obtaining and processing the set of data at rest based on a state of the set of data at rest, wherein the second data processing scheme comprises a second plurality of computer-executable instructions, different than the first plurality of computer-executable instructions, for obtaining and processing the set of data at rest; and

communicate, by the query processor, the second data processing scheme to a second data processor based on the state of the set of data at rest, wherein the second data processor is different than the first data processor and execution of the second plurality of computer-executable instructions causes the second data processor to obtain and process the set of data at rest, wherein generating the first data processing scheme for the first data processor and generating the second data processing scheme for the second data processor via the query processor reduces computing resource usage.

18. The non-transitory computer-readable media of claim 17 , wherein the first data processing scheme is a modified first data processing scheme, and wherein to generate the modified first data processing scheme, the computer-executable instructions further cause the computing system to:

parse a query,

generate a preliminary first data processing scheme based on the parsing, and

generate the modified first data processing scheme based on an application of one or more general optimizations and one or more streaming-specific optimizations to the preliminary first data processing scheme, wherein the one or more streaming-specific optimizations are applied based on the state of the set of streaming data and the one or more general optimizations are applied regardless of the state of the set of streaming data.

19. The non-transitory computer-readable media of claim 17 , wherein the first data processing scheme is a modified first data processing scheme, and wherein to generate the modified first data processing scheme, the computer-executable instructions further cause the computing system to:

parse a query,

generate a preliminary first data processing scheme based on the parsing, and

generate the modified first data processing scheme based on an application of a time constraint to one or more commands of the preliminary first data processing scheme, wherein the time constraint is applied based on the state of the set of streaming data.

20. The non-transitory computer-readable media of claim 17 , wherein the second data processing scheme is a modified second data processing scheme, and wherein to generate the modified second data processing scheme, the computer-executable instructions further cause the computing system to:

parse a query,

generate a preliminary second data processing scheme based on the parsing, and

generate the modified second data processing scheme based on pushing one or more commands of the preliminary second data processing scheme to an external data store, wherein the one or more commands are pushed to the external data store based on the state of the set of data at rest.

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 (3)
Continuation 17236925 · Apr 21, 2021
Continuation 15885645 · Jan 31, 2018
Related Publication 20230244673A1 · Aug 3, 2023
References Cited (300)
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 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 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 20160299947A1 · Pangeni · 2016 [cited by examiner]
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 et al. · 2018 [cited by applicant]
US 20180262592A1 · Zandhi et al. · 2018 [cited by applicant]
US 20180284975A1 · Carrier et al. · 2018 [cited by applicant]
US 20180329644A1 · Das et al. · 2018 [cited by applicant]
US 20180332367A1 · Kaitchuck et al. · 2018 [cited by applicant]
US 20180349404A1 · Noh · 2018 [cited by examiner]
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 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 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 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 · 2023 [cited by applicant]
US 20230342380A1 · Cruise · 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]
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/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,161, 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]
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]
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/EventHandling/EventFr… [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_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]
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]
U.S. Appl. No. 18/656,424, filed May 6, 2024, Echeverria et al. [cited by applicant]
U.S. Appl. No. 18/818,459, filed Aug. 28, 2024, Echeverria et al. [cited by applicant]