Exposes the StreamInsight query template language. For more information, see Using StreamInsight LINQ.
Provides access to the start time with expressions that can only refer to the start time of an event.
Allows to specify lambda expressions for event duration changes. It provides access to start time, end time, and event payload.
Represents a group of streams.
Represents a stream of events that can be ordered.
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.
Exposes a rank along with the event payload over a ranked stream using Take.
Provides the extension methods used for writing LINQ queries over a stream of CEP events.
Represents a stream of events from any user specified payload type.
This class represents the context in which a CepStream was created.
Decorates the user-defined aggregate extension method.
Decorates the user-defined operator extension method.
Utility class used by user defined operator, aggregate and functions.
A window is a finite collection of events that results from applying a windowing operator on a stream of events..
Provides extension methods for built-in aggregates.
Results from applying a windowing operator to a stream.
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.
Defines the window output policies that are applicable to hopping 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.
Provides support for event sinks that implement the IObservable interface.
Exception thrown from LINQ provider when the query cannot be correctly produced.
Defines the output policies that are applicable to snapshot windows. A window output policy describes how the CEP engine modifies the timestamp of events that result from a window-based operation.
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.
Represents an extended observable interface supporting named queries for subscriptions.
Provides access to the grouping key.
The kind of clip for the input events that falls into the same window.