Microsoft.ComplexEventProcessing.Linq Namespace

Provides access to the start time with expressions that can only refer to the start time of an event.

Represents a group of streams.

An ordered stream is the result of an "order by" or one of its variants in the query. It helps constrain subsequent query specification to operations that are allowed on an ordered stream, such as Take.

Provides the extension methods used for writing LINQ queries over a stream of CEP events.

Decorates the user-defined aggregate extension method.

Utility class used by user defined operator, aggregate and functions.

Provides extension methods for built-in aggregates.

Defines the window output policies that are applicable to count windows. A window output policy describes how the CEP engine modifies the timestamp of events that result from a window-based operation.

Contains all information extracted from a stream definition.

Exception thrown from LINQ provider when the query cannot be correctly produced.

The window input policy describes how the timestamps of events that fall into a given window are changed before processing the window operation.

Represents a payload that can be accessed using key grouping.

Extends the IEnumerable<T> interface to let you specify a query name and description for an enumerable event source.

Provides access to the grouping key.

The kind of clip for the input events that falls into the same window.