EVENT STREAM TRANSFORMATIONS

• US 20160063080A1
• Filed: 10/15/2014
• Published: 03/03/2016
• Est. Priority Date: 08/29/2014
• Status: Active Grant

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Corporation
• Inventors: Akchurin, Eldar, Tarnavski, Tihomir, Periorellis, Panagiotis, Nano, Olivier, Santos, Ivo Jose Garcia dos, Novik, Lev
• Granted Patent: US 10,235,436 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/2456 Join operations
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 16/254 Extract, transform and load [ETL] procedures, e.g. ETL data flows in data warehouses
• CPC Class Codes: H04L 67/12 specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks

Abstract

The formulation of transformations on one or more input event streams to generation one or more output event streams. Accordingly, the transformations may be considered to be a query on the original input event stream(s). The event query includes event stream source representations representing an input event stream available in a particular execution context. The event query also includes a transformation module identifying the transformation set to be performed on the input event streams in the execution context. Once the query is properly formed, an execution module may then cause the transformations to be executed upon the designated input event stream(s) to generate output event streams.

Claims

1. A computer program product comprising one or more computer-readable storage media having thereon the following:

an event stream source representation representing an event stream available in an execution context;

a transformation module identifying a transformation set of one or more transformations to be performed on one or more input event streams represented by the transformation module, the transformation module identifying the event stream as one of the event streams by referencing the contemporary event stream source representation, the transformation module identifying the historical event stream as one of the input event streams by referencing the historical event stream source representation; and

an execution module interpreting the transformation module to cause the transformation set to be performed in the execution context on the identified input streams to generate the resulting event stream.

2. The computer program product in accordance with claim 1, the computer-readable storage media further having thereon the following:

an authoring module configured to allow an author to author the event stream source representation and the transformation module.

3. The computer program product in accordance with claim 2, the authoring module configured to provide a set of programming abstractions for authoring the event stream source representation, the set of programming abstractions include an event stream source representation abstraction that is the same regardless of the event stream.

4. The computer program product in accordance with claim 2, the authoring module configured to provide a set of programming abstractions for authoring the event stream source representation, the set of programming abstractions include an abstraction that joins a contemporary input stream with historical input stream.

5. The computer program product in accordance with claim 1, the computer-readable storage media further having thereon the following:

a context identification module identifying the execution context to the execution module so that the execution module can cause the transformation set to be performed in the execution context.

6. The computer program product in accordance with claim 5, the execution context being a local computing system.

7. The computer program product in accordance with claim 5, the execution context being a cloud computing environment.

8. The computer program product in accordance with claim 5, the computer-readable storage media further having thereon the following:

an authoring module configured to allow an author to author the context identification module.

9. The computer program product in accordance with claim 1, the computer-readable storage media further having thereon the following:

an initiation control configured to initiate the execution module upon detection of user input.

10. A method for causing a resulting event stream to be generated by executing a transformation set on one or more input event streams, the method comprising:

an act of accessing an event stream source representation representing a particular event stream available in an execution context,

an act of transformation module identifying a transformation set of one or more transformations to be performed on one or more input event streams represented by the transformation module, the transformation module identifying the particular event stream as one of the one or more input event streams by referencing the event stream source representation; and

an execution module interpreting the transformation module to cause the transformation set to be performed in the execution context on the identified one or more input event streams to generate the resulting event stream.

11. The method in accordance with claim 10, the particular event stream being a contemporary event stream, the event stream source representation being a contemporary event stream source representation.

12. The method in accordance with claim 11, further comprising:

an act of accessing a historical event stream source representation representing a historical event stream available in an execution context.

13. The method in accordance with claim 10, the one or more transformations comprising a filtering operation that is applied to the particular event stream.

14. The method in accordance with claim 13, the one or more transformations comprising event generation logic for generating events of the resulting event stream, the event generation logic using the filtered particular event stream as input.

15. The method in accordance with claim 10, the one or more transformations comprising event generation logic for generating events of the resulting event stream, the event generation logic using the particular event stream as input.

16. The method in accordance with claim 10, further comprising:

an act of accessing an event stream sink representation representing a particular event sink available in the execution context, the execution module configured to provide the resulting event stream into the particular event sink.

17. A system comprising:

one or more processing units; and

one or more computer-readable storage media having thereon computer executable instructions that are structured such that, when executed by the one or more processing units, causes the one system to perform the following;

an act of obtaining a transformation module configured to perform a transformation set of one or more transformations on one or more input event streams;

an act of coupling the transformation module to an input contemporary event stream and an input historical event stream such that when the transformation module executes, the transformation module performs the transformation set on the input contemporary event stream and the input historical event stream; and

an act of executing the transformation module to generate a resulting event stream.

18. The system in accordance with claim 17, the input historical event stream being a historical time-shifted version of the input contemporary event stream.

19. The system in accordance with claim 17, the one or more transformations comprising a filtering operation that is applied to at least one of the input contemporary event stream and the input historical event stream.

20. The system in accordance with claim 17, the one or more transformations comprising event generation logic for generating events of the resulting event stream, the event generation logic using at least a portion of the input contemporary event stream and at least a portion of the input historical event stream as input.