Stream sharing for event data within an enterprise network

• US 8,538,981 B2
• Filed: 11/19/2009
• Issued: 09/17/2013
• Est. Priority Date: 11/20/2008
• Status: Active Grant

• Current Assignee: SAP SE
• Original Assignee: SAP AG (SAP SE)
• Inventors: Navas, Julio
• Primary Examiner(s): LY, CHEYNE D
• Application Number:
  US12/622,396
• Publication Number:
  US 20100125574A1
• Time in Patent Office: 1,398 Days
• Field of Search: 707/602, 707/607, 707/608, 707/609, 707/648, 707/705, 707/821, 707/769
• US Class Current: 707/769
• CPC Class Codes: G06F 16/2255 Hash tables
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 16/2471 Distributed queries
• CPC Class Codes: G06Q 10/10 Office automation; Time management

Abstract

Merging of query elements in an enterprise system is described. The enterprise system receives queries, which may each be broken down into query components. The enterprise system identifies query components that are related to identical event information from a data source of the enterprise. The enterprise system sends a single query to the data source for the event information, receives the response, and sends the response to the query sources.

Claims

1. A computer-implemented method comprising:

receiving multiple query components from multiple query sources requesting information about one or more events in an enterprise system having multiple separate data sources distributed among separate enterprise nodes, where each event includes a change in a structured data object, the data sources being separate enterprise subsystems that generate the changes;

identifying two query components related to common event information from one of the data sources;

sending a single query component to an enterprise node local to the one data source of the enterprise system that generates the common event information;

sending each other query component to enterprise nodes local to data sources that generate event information related to the other query components;

receiving a response to the single query component from the enterprise node local to the one data source; and

sending the response to each query source to provide the event information as a partial event query response.

2. The method of claim 1, wherein receiving the multiple query components comprises receiving query components from query sources having different levels of security access with respect to common event information;

and

wherein sending the single query component for the common event information further comprises indicating the different levels of security access with respect to the common event information.

3. The method of claim 1, wherein receiving the multiple query components comprises receiving query components from query sources having different levels of security access with respect to common event information;

and

wherein sending the single query component for the common event information further comprises requesting access to the common query component according to a highest level of security access among the different levels of security access.

4. The method of claim 3, further comprising:

filtering the response to the single query component from the one data source; and

sending data to the query sources in accordance with the level of security access associated with each respective query source.

5. The method of claim 4, wherein filtering the response to the single query component comprises row level filtering the response in accordance with a row level filter that indicates the level of security access associated with each respective query source.

6. The method of claim 1, wherein sending the single query component comprises:

forwarding a query component to a neighboring node of the enterprise system that has a query component for the common event information and that generates a request to the one data source; and

wherein receiving the response to the single query comprises;

receiving the response from the neighboring node of the enterprise.

7. The method of claim 1, wherein receiving the response comprises:

receiving real-time and non real-time event information in response to a query component.

8. The method of claim 1, further comprising:

parsing one of the query components into multiple subcomponents, where at least one of the subcomponents is related to common event information as another received query component.

9. A computer-readable storage medium tangibly embodying content stored thereon to provide instructions, which when executed, cause a processor of an enterprise node to perform operations, including:

receiving multiple query components from multiple query sources requesting information about one or more events in an enterprise system having multiple separate data sources distributed among separate enterprise nodes, where each event includes a change in a structured data object, the data sources being separate enterprise subsystems that generate the changes;

identifying two query components related to common event information from one of the data sources;

sending a single query component to an enterprise node local to the one data source of the enterprise system that generates the common event information;

sending each other query component to enterprise nodes local to data sources that generate event information related to the other query components;

receiving a response to the single query component from the enterprise node local to the one data source; and

sending the response to each query source to provide the event information as a partial event query response.

10. The computer readable storage medium of claim 9, wherein the content to provide instructions for receiving the multiple query components comprises content to provide instructions for receiving query components from query sources having different levels of security access with respect to common event information;

and

wherein the content to provide instructions for sending the single query component for the common event information further comprises content to provide instructions for indicating the different levels of security access with respect to the common event information.

11. The computer readable storage medium of claim 9, wherein the content to provide instructions for receiving the multiple query components comprises content to provide instructions for receiving query components from query sources having different levels of security access with respect to common event information;

and

wherein the content to provide instructions for sending the single query component for the common event information further comprises content to provide instructions for requesting access to the common query component according to a highest level of security access among the different levels of security access.

12. The computer readable storage medium of claim 11, further comprising content to provide instructions for

filtering the response to the single query component from the one data source;

and

sending data to the query sources in accordance with the level of security access associated with each respective query source.

13. The computer readable storage medium of claim 12, wherein the content to provide instructions for filtering the response to the single query component comprises content to provide instructions for row level filtering the response in accordance with a row level filter that indicates the level of security access associated with each respective query source.

14. The computer readable storage medium of claim 9, wherein the content to provide instructions for sending the single query component comprises content to provide instructions for forwarding a query component to a neighboring node of the enterprise system that has a query component for the common event information and that generates a request to the one data source;

and

wherein the content to provide instructions for receiving the response to the single query comprises content to provide instructions for receiving the response from the neighboring node of the enterprise.

15. The computer readable storage medium of claim 9, wherein the content to provide instructions for receiving the response comprises content to provide instructions for

receiving real-time and non real-time event information in response to a query component.

16. The computer readable storage medium of claim 9, further comprising content to provide instructions for

parsing one of the query components into multiple subcomponents, where at least one of the subcomponents is related to common event information as another received query component.

17. A server node of an enterprise network, comprising:

a network interface circuit to receive multiple query components from multiple query sources requesting information about one or more events in an enterprise system having multiple data sources distributed among separate enterprise nodes, where each event includes a change in a structured data object, the data sources being separate enterprise subsystems that generate the changes, and where the multiple query sources include one or more client devices;

a stream sharing engine to identify two query components related to common event information from one of the data sources;

a query router to send a single query component to an enterprise node local to the one data source of the enterprise system that generates the common event information, send other query components to other enterprise nodes local to data sources that generate event information related to the other query components, and receive a response to the single query component from the enterprise node local to the one data source; and

a query responder to send the response to each query source via the network interface circuit to provide the event information as a partial event query response.

18. The server node of claim 17, wherein the network interface circuit receives query components from query sources having different levels of security access with respect to common event information;

and

wherein the query router indicates the different levels of security access with respect to the common event information.

19. The server node of claim 17, wherein the network interface circuit receives query components from query sources having different levels of security access with respect to common event information;

and

wherein the query router requests access to the common event information according to a highest level of security access among the different levels of security access.

20. The server node of claim 19, wherein the stream sharing engine is to further filter the response to the single query component from the one data source, and the query responder is to send data to the query sources in accordance with the level of security access associated with each respective query source.

21. The server node of claim 20, wherein the stream sharing engine further includes an access lists that indicates the level of security access associated with each respective query source, and filters the response in accordance with the access list.

22. The server node of claim 17, wherein the query router forwards the query component to a neighboring node of the enterprise system that has a query component for the common event information and that generates a request to the one data source, and receives the response from the neighboring node of the enterprise.