Native federation view suggestion

• US 9,864,786 B2
• Filed: 11/10/2014
• Issued: 01/09/2018
• Est. Priority Date: 11/10/2014
• Status: Active Grant

• Current Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Original Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Inventors: Nguyen, Filip, Elias, Filip
• Primary Examiner(s): Morrison, Jay
• Assistant Examiner(s): Hoang, Ken
• Application Number:
  US14/537,356
• Publication Number:
  US 20160132566A1
• Time in Patent Office: 1,156 Days
• Field of Search: 709224, 709203, 709204, 709206, 709221, 707722, 707706, 707748, 707754, 707691, 707710, 707734, 707737, 707740, 707741, 707767, 707769, 707770, 707776, 705 44, 705 1415, 705 1441, 705 1454, 705345, 705 723, 706 12, 706 46, 706 47
• CPC Class Codes: G06F 16/248 Presentation of query results

Abstract

Methods, systems, and computer program products for monitoring activity of data sources relating to data queries and data query responses, detecting events in the monitored activity, generating activity reports relating to the detected events; and analyzing the activity reports to determine view suggestions that may be used to optimize a federation engine.

Claims

1. A federated system, comprising:

at least one processor in communication with a memory;

a first data source that receives a query from a federation engine, determines a response to the query, and generates one or more events corresponding to the response;

a first model monitor that monitors the first data source, detects an event of the one or more events corresponding to the response, and generates an activity report associated with the event;

a second model monitor that monitors a second data source and detects one or more events associated with the second data source; and

a view detector communicatively coupled to the first model monitor and the second model monitor, the view detector executable by the at least one processor to;

receive the activity report from the first model monitor in an event stream;

analyze the activity report and one or more other activity reports to detect similar activity reports, the analyzing including detecting the similar activity reports within a time window that is expanded by a pre-configured amount of time until a threshold is reached;

generate an n-tuple based on the similar activity reports;

order in the n-tuple either (i) the detected similar activity reports or (ii) identifiers of the detected similar activity reports;

analyze the n-tuple and one or more other n-tuples to detect similar n-tuples; and

generate a view suggestion based on the similar n-tuples, wherein the view suggestion comprises a suggestion to define a federated view at the federation engine, and wherein the defined federated view includes cached data from the first data source and the second data source.

2. The federated system of claim 1, wherein the first activity report is a tuple comprising the following components:

a data store identifier, a protocol identifier, a file identifier or a database identifier, a model monitor identifier, a size of the response from the first data source to the query, and a timestamp.

3. The federated system of claim 1, wherein the n-tuple is associated with at least one conditionality, wherein the at least one conditionality represents a relation between size components of the detected similar activity reports that are ordered in the n-tuple.

4. The federated system of claim 1, wherein the view suggestion is generated based on the similar n-tuples being located within a pre-configured time interval.

5. The federated system of claim 3, wherein the conditionality is a ratio or a percentage.

6. The federated system of claim 1, wherein the view suggestion is presented to one or more users.

7. The federated system of claim 1, wherein the one or more events corresponding to the response are at least one of the following event types:

(i) file input and output activity; and

(ii) network activity.

8. A computer-implemented method comprising:

monitoring query response activity of a data source, wherein the query response activity comprises at least one of the following;

(i) file input;

(ii) file output; and

(iii) network traffic;

parsing the query response activity of the data source to detect an event and one or more event components associated with the event;

generating an activity report for the event comprising at least one of the one or more event components;

analyzing the activity report and one or more other activity reports to detect similar activity reports, the analyzing including detecting the similar activity reports within a time window that is incrementally expanded by a pre-configured amount of time until the time window reaches a threshold amount of time; and

generating a view suggestion based on the detected similar activity reports, wherein the view suggestion comprises a suggestion to define a federated view that includes aggregated data from the data source and a second data source.

9. The method of claim 8, wherein the activity report is a tuple comprising the following components:

a data store identifier, a protocol identifier, a file or database identifier, an originator identifier, a size of the response from the data source to the query, and a timestamp.

10. The method of claim 8, wherein the view suggestion is associated with at least one conditionality, wherein the at least one conditionality represents a relation between size components of the detected similar activity reports.

11. The method of claim 8, wherein the view suggestion is presented to one or more users.

12. The method of claim 8, wherein the one or more events are at least one of the following event types:

(i) JDBC related file input or output activity; and

(ii) outbound HTTP network traffic.

13. The method of claim 8, further comprising:

generating an n-tuple based on the detected similar activity reports;

analyzing the n-tuple and one or more other n-tuples to detect similar n-tuples; and

generating the view suggestion based on the detected similar n-tuples.

14. The method of claim 13, wherein the view suggestion is generated based on the detected similar n-tuples being associated with one or more timestamps indicating that the detected similar n-tuples represent events that occurred within a pre-configured time interval.

15. A non-transitory computer-readable medium comprising computer-readable instructions, executable by at least one processor perform operations comprising:

monitoring activity of a data source;

parsing the activity of the data source to detect one or more events, wherein an event of the one or more events corresponds to a response from the data source to a query received from a federation engine;

generating an activity report for the first event;

sending the activity report from a model monitor to a view detector;

analyzing the activity report and one or more other activity reports to detect similar activity reports, the analyzing including detecting the similar activity reports within a time window that is incrementally expanded until a threshold is reached;

generating an n-tuple based on the detected similar activity reports, wherein the detected similar activity reports or identifiers representing the detected similar activity reports are ordered in the n-tuple in ascending or descending time wise succession;

analyzing the n-tuple and one or more other n-tuples to detect whether the n-tuple and the one or more other n-tuples are similar and occur within a pre-defined time interval; and

generating a view suggestion based on the detected similar n-tuples, wherein the view suggestion comprises a suggestion to define a federated view that includes aggregated data from the data source and a second data source.

16. The medium of claim 15, wherein the activity report is a tuple comprising the following components:

a data store identifier, a protocol identifier, a file or database identifier, a model monitor identifier, a size of the response from the data source to the query, and a timestamp.

17. The medium of claim 15, wherein the view suggestion is associated with at least one conditionality, wherein the at least one conditionality represents a relation between size components of the detected similar activity reports.

18. The medium of claim 15, wherein the view suggestion is presented to one or more users.

19. The medium of claim 15, wherein the one or more events are determined to relate to file input and output activity.

20. The medium of claim 15, wherein the one or more events are determined to relate to network activity.