IP Library › Granted Patent US 11,615,104

Granted Patent B2

US 11,615,104 · App. 16/051,215 · Granted Mar 28, 2023

Subquery generation based on a data ingest estimate of an external data system

Inventors: Sourav Pal (Foster City, CA); Arindam Bhattacharjee (Fremont, CA)

Assignee: Splunk Inc.

G06F16/2471 G06F16/211 G06F16/27 G06F16/951 G06F40/205

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 11,615,104
App. No.: 16/051,215
Granted: Mar 28, 2023
Kind: B2

External Links

USPTO Patent Center↗ Full Patent PDF↗

Abstract

Systems and methods are disclosed for executing a query that includes an indication to process data managed by an external data system. The system identifies the external data system that manages the data to be processed and generates a subquery for the external data system. The system determines a data ingest estimate and uses the data ingest estimate to generate instructions for one or more worker nodes to receive and process results of the subquery from the external data system.

Claims (187)

1. A method, comprising:

receiving, at a data intake and query system, a query identifying a set of data to be processed and a manner of processing the set of data;

determining that the set of data includes at least a subset of data associated with an external data system;

defining, by the data intake and query system, a query processing scheme for obtaining and processing the set of data, wherein defining the query processing scheme comprises:

determining a subquery for the external data system, the subquery identifying the at least a subset of data and a manner of processing the at least a subset of data, wherein determining the subquery comprises:

obtaining search configuration data from the external data system, and

determining the subquery based on the search configuration data,

determining a data ingest estimate for the subquery, wherein the data ingest estimate includes an estimate of an amount of data to be received from the external data system based on the external data system executing the subquery,

determining a partition size based on resources allocated to the query and one or more search parameters of the subquery,

determining a number of partitions based on the partition size and the data ingest estimate, and

generating instructions for one or more worker nodes to receive and to process results of the subquery to form processed results based on the determined number of partitions and to provide the processed results to the data intake and query system; and

executing the query based on the query processing scheme.

2. The method of claim 1 , wherein resources allocated corresponds to a number of processors and an amount of memory allocated for the query.

3. The method of claim 1 , wherein the one or more search parameters of the subquery includes a number of fields used to process events from the external data system.

4. The method of claim 1 , wherein the at least a subset of data is a second subset of data, and the processed results are second processed results, the method further comprising:

determining that the set of data includes a first subset of data associated with the data intake and query system,

wherein defining the query processing scheme, further comprises:

generating a subquery for the data intake and query system, the subquery for the data intake and query system identifying the first subset of data and a manner of processing the first subset of data, and

generating instructions for one or more worker nodes to receive and process results of the subquery for the data intake and query system to form first processed results and to provide the first processed results to the data intake and query system.

5. The method of claim 1 , wherein the at least a subset of data is a second subset of data, and the processed results are second processed results, the method further comprising:

determining that the set of data includes a first subset of data associated with the data intake and query system,

wherein defining the query processing scheme, further comprises:

generating instructions for one or more worker nodes to receive and process results of the subquery for the data intake and query system to generate first processed results, to combine and process the first processed results and the second processed results to form combined processed results and to provide the combined processed results to the data intake and query system.

6. The method of claim 1 , wherein the at least a subset of data is a first subset of data, the processed results are first processed results, and the external data system is a first external data system, the method further comprising:

determining that the set of data includes a second subset of data associated with a second external data system,

wherein defining the query processing scheme, further comprises:

determining a subquery for the second external data system, the subquery for the second external data system identifying the second subset of data and a manner of processing the second subset of data; and

generating instructions for one or more worker nodes to receive and process results of the subquery for the second external data system to form second processed results and to provide the second processed results to the data intake and query system.

7. The method of claim 1 , wherein the data intake and query system and the external data system each independently execute queries other than the query.

8. The method of claim 1 , wherein the data intake and query system and the external data system each independently receive distinct queries other than the query, generate respective subqueries based on the distinct queries, and execute the respective subqueries.

9. The method of claim 1 , wherein the data intake and query system and the external data system each include one or more search heads and one or more indexers.

10. The method of claim 1 , wherein determining that the set of data includes at least the subset of data comprises:

parsing the query;

identifying a search parameter in the query associated with a search of an external data source;

identifying the external data system based on said identifying the search parameter; and

determining access information to access the external data system.

11. The method of claim 1 , wherein determining that the set of data includes at least the subset of data comprises:

parsing the query;

identifying a search parameter in the query that includes an identification of the external data system; and

determining access information to access the external data system based on said identification of the external data system.

12. A method, comprising:

receiving, at a data intake and query system, a query identifying a set of data to be processed and a manner of processing the set of data;

determining that the set of data includes at least a subset of data associated with an external data system, wherein determining that the set of data includes at least the subset of data comprises:

parsing the query,

identifying a search parameter in the query associated with a search of an external data source,

parsing a configuration file based on the search parameter,

identifying the external data system based on said parsing the configuration file, and

determining access information to access the external data system based on said identifying the external data system;

defining, by the data intake and query system, a query processing scheme for obtaining and processing the set of data, wherein defining the query processing scheme comprises:

determining a subquery for the external data system, the subquery identifying the at least a subset of data and a manner of processing the at least a subset of data,

determining a partition size based on resources allocated to the query and one or more search parameters of the subquery,

determining a number of partitions based on the partition size and the data ingest estimate, and

executing the query based on the query processing scheme.

13. The method of claim 1 , further comprising associating a search identifier with the external data system, wherein the one or more worker nodes process results of the subquery based on the search identifier.

14. The method of claim 12 , wherein:

defining the query processing scheme further comprises associating, by the data intake and query system, a first search identifier with the external data system, and

executing the query comprises:

receiving, by the one or more worker nodes, the results of the subquery, wherein the results of the subquery include a second search identifier assigned to the results of the subquery by the external data system;

mapping the first search identifier to the second search identifier; and

processing the results of the subquery based on said mapping.

15. The method of claim 1 , wherein determining the data ingest estimate comprises identifying the data ingest estimate from a search parameter.

16. The method of claim 1 , wherein determining the data ingest estimate comprises:

determining a processing capability of the external data system; and

determining the data ingest estimate for the subquery based on the processing capability.

17. The method of claim 1 , wherein determining the data ingest estimate comprises:

assigning a worker node of the one or more worker nodes to request a version identifier from the external data system;

receiving the version identifier from the worker node; and

determining the data ingest estimate for the subquery based on the version identifier.

18. A method, comprising:

receiving, at a data intake and query system, a query identifying a set of data to be processed and a manner of processing the set of data;

determining that the set of data includes at least a subset of data associated with an external data system;

defining, by the data intake and query system, a query processing scheme for obtaining and processing the set of data, wherein defining the query processing scheme comprises:

determining a subquery for the external data system, the subquery identifying the at least a subset of data and a manner of processing the at least a subset of data,

wherein determining the data ingest estimate comprises:

assigning a worker node of one or more worker nodes to obtain the data ingest estimate for the subquery, and

communicating the subquery to the worker node, wherein the worker node communicates the subquery to the external data system and receives the data ingest estimate from the external data system,

determining a partition size based on resources allocated to the query and one or more search parameters of the subquery,

determining a number of partitions based on the partition size and the data ingest estimate, and

generating instructions for the one or more worker nodes to receive and to process results of the subquery to form processed results based on the determined number of partitions and to provide the processed results to the data intake and query system; and

executing the query based on the query processing scheme.

19. The method of claim 1 , wherein determining the data ingest estimate comprises:

assigning a worker node of the one or more worker nodes to obtain the data ingest estimate for the subquery; and

communicating the subquery to the worker node, wherein the worker node parses the subquery, communicates at least one search parameter to the external data system, and receives the data ingest estimate from the external data system.

20. The method of claim 19 , wherein defining the query processing scheme, further comprises:

obtaining network access information from at least one worker node of the one or more worker nodes, wherein executing the query comprises communicating the network access information to the external data system.

21. The method of claim 1 , wherein determining the subquery comprises:

determining a processing capability of the external data system; and

generating the subquery based on the processing capability.

22. The method of claim 21 , wherein determining the processing capability of the external data system comprises:

assigning a worker node of the one or more worker nodes to request a version identifier from the external data system; and

receiving the version identifier from the worker node, wherein the subquery is determined based on the version identifier.

23. The method of claim 1 , wherein the subquery includes instructions for the external data system to distribute the results of the subquery to a plurality of worker nodes of the one or more worker nodes.

24. The method of claim 1 , wherein the subquery includes instructions for the external data system to communicate the results of the subquery to only one worker node of the one or more worker nodes, and wherein defining the query processing scheme further comprises generating instructions for the one worker node to distribute the results of the subquery to a plurality of worker nodes of the one or more worker nodes.

25. The method of claim 1 , wherein executing the query comprises:

communicating the subquery to the one or more worker nodes, wherein at least one worker node of the one or more worker nodes communicates the subquery to the external data system, the external data system processes and executes the subquery, and the one or more worker nodes receive and process the results of the subquery to form the processed results; and

receiving the processed results from the one or more worker nodes.

26. The method of claim 1 , wherein executing the query comprises:

communicating the subquery to the external data system using the one or more worker nodes, wherein the external data system processes and executes the subquery using the one or more worker nodes and the one or more worker nodes receive and process the results of the subquery to form the processed results; and

receiving the processed results from the one or more worker nodes.

27. A computing system of a data intake and query system, the computing system comprising:

memory; and

one or more processing devices coupled to the memory and configured to:

receive a query identifying a set of data to be processed and a manner of processing the set of data;

determine that the set of data includes at least a subset of data associated with an external data system wherein to determine the set of data includes at least the subset of data, the one or more processing devices are configured to:

parse the query,

identify a search parameter in the query associated with a search of an external data source,

parse a configuration file based on the search parameter,

identify the external data system based on said parsing the configuration file, and

determine access information to access the external data system based on said identifying the external data system;

define a query processing scheme for obtaining and processing the set of data, wherein to define the query processing scheme, the one or more processing devices are configured to:

determine a subquery for the external data system, the subquery identifying the at least a subset of data and a manner of processing the at least a subset of data,

determine a partition size based on resources allocated to the query and one or more search parameters of the subquery,

determine a number of partitions based on the partition size and the data ingest estimate, and

generate instructions for one or more worker nodes to receive and process results of the subquery to form processed results based on the determined number of partitions and to provide the processed results to the data intake and query system; and

initiate execution of the query based on the query processing scheme.

28. Non-transitory computer readable media comprising computer-executable instructions that, when executed by a computing system of a data intake and query system, cause the computing system to:

receive a query identifying a set of data to be processed and a manner of processing the set of data;

determine that the set of data includes at least a subset of data associated with an external data system, wherein to determine the set of data includes at least the subset of data, the computer-executable instructions cause the computing system to:

parse the query,

identify a search parameter in the query associated with a search of an external data source,

parse a configuration file based on the search parameter,

identify the external data system based on said parsing the configuration file, and

determine access information to access the external data system based on said identifying the external data system;

define a query processing scheme for obtaining and processing the set of data, wherein to define the query processing scheme the computer-executable instructions cause the computing system to:

determine a subquery for the external data system, the subquery identifying the at least a subset of data and a manner of processing the at least a subset of data,

determine a partition size based on resources allocated to the query and one or more search parameters of the subquery,

determine a number of partitions based on the partition size and the data ingest estimate, and

initiate execution of the query based on the query processing scheme.

29. A computing system of a data intake and query system, the computing system comprising:

memory; and

one or more processing devices coupled to the memory and configured to:

receive a query identifying a set of data to be processed and a manner of processing the set of data;

determine that the set of data includes at least a subset of data associated with an external data system;

define a query processing scheme for obtaining and processing the set of data, wherein to define the query processing scheme, the one or more processing devices are configured to:

determine a subquery for the external data system, the subquery identifying the at least a subset of data and a manner of processing the at least a subset of data,

determine a data ingest estimate for the subquery, wherein the data ingest estimate includes an estimate of an amount of data to be received from the external data system based on the external data system executing the subquery, wherein to determine the data ingest estimate the one or more processing devices are configured to:

assign a worker node of one or more worker nodes to obtain the data ingest estimate for the subquery, and

communicate the subquery to the worker node, wherein the worker node communicates the subquery to the external data system and receives the data ingest estimate from the external data system,

determine a partition size based on resources allocated to the query and one or more search parameters of the subquery,

determine a number of partitions based on the partition size and the data ingest estimate, and

generate instructions for the one or more worker nodes to receive and process results of the subquery to form processed results based on the determined number of partitions and to provide the processed results to the data intake and query system; and

initiate execution of the query based on the query processing scheme.

30. Non-transitory computer readable media comprising computer-executable instructions that, when executed by a computing system of a data intake and query system, cause the computing system to:

receive a query identifying a set of data to be processed and a manner of processing the set of data;

determine that the set of data includes at least a subset of data associated with an external data system;

define a query processing scheme for obtaining and processing the set of data, wherein to define the query processing scheme the computer-executable instructions cause the computing system to:

determine a subquery for the external data system, the subquery identifying the at least a subset of data and a manner of processing the at least a subset of data,

determine a data ingest estimate for the subquery, wherein the data ingest estimate includes an estimate of an amount of data to be received from the external data system based on the external data system executing the subquery, wherein to determine the data ingest estimate, the computer-executable instructions cause the computing system to:

assign a worker node of one or more worker nodes to obtain the data ingest estimate for the subquery, and

communicate the subquery to the worker node, wherein the worker node communicates the subquery to the external data system and receives the data ingest estimate from the external data system,

determine a partition size based on resources allocated to the query and one or more search parameters of the subquery,

determine a number of partitions based on the partition size and the data ingest estimate, and

initiate execution of the query based on the query processing scheme.

31. A computing system of a data intake and query system, the computing system comprising:

memory; and

one or more processing devices coupled to the memory and configured to:

receive a query identifying a set of data to be processed and a manner of processing the set of data;

determine that the set of data includes at least a subset of data associated with an external data system;

define a query processing scheme for obtaining and processing the set of data, wherein to define the query processing scheme, the one or more processing devices are configured to:

determine a subquery for the external data system, the subquery identifying the at least a subset of data and a manner of processing the at least a subset of data, wherein to determine the subquery, the one or more processing devices are configured to:

obtain search configuration data from the external data system, and

determine the subquery based on the search configuration data,

determine a partition size based on resources allocated to the query and one or more search parameters of the subquery,

determine a number of partitions based on the partition size and the data ingest estimate, and

initiate execution of the query based on the query processing scheme.

32. Non-transitory computer readable media comprising computer-executable instructions that, when executed by a computing system of a data intake and query system, cause the computing system to: