Microsoft.ComplexEventProcessing.Linq Namespace

  • Article

Exposes the StreamInsight query template language. For more information, see Writing Query Templates in LINQ.

Classes

  Class Description
Public class CepEvent Provides access to the start time with expressions that can only refer to the start time of an event.
Public class CepEvent<TPayload> Allows to specify lambda expressions for event duration changes. It provides access to start time, end time, and event payload.
Public class CepGroupingStreams<TPayload, TGroupingKey> Represents a group of streams.
Public class CepOrderableStream<T> Represents a stream of events that can be ordered.
Public class CepOrderedStream<T> 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.
Public class CepRankedEvent<P> Exposes a rank along with the event payload over a ranked stream using Take.
Public class CepStream Provides the extension methods used for writing LINQ queries over a stream of CEP events.
Public class CepStream<TPayload> Represents a stream of events from any user specified payload type.
Public class CepStreamConsumer<T> CepStreamConsumer represents a specific stream consumer information. It will be translated to actual output binding for a query.
Public class CepStreamCreationContext This class represents the context in which a CepStream was created.
Public class CepUserDefinedAggregateAttribute Decorates the user-defined aggregate extension method.
Public class CepUserDefinedOperatorAttribute Decorates the user-defined operator extension method.
Public class CepUtility Utility class used by user defined operator, aggregate and functions.
Public class CepWindow<TPayload> A window is a finite collection of events that results from applying a windowing operator on a stream of events..
Public class CepWindowExtensionMethods Extension methods for built-in aggregates.
Public class CepWindowStream<T> Results from applying a windowing operator to a stream.
Public class CountWindowOutputPolicy 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.
Public class HoppingWindowOutputPolicy 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.
Public class InputStreamInfo Contains all information extracted from a stream definition.
Public class ObservableCepStream Provides support for event sinks that implement the IObservable interface.
Public class QueryGenerationException Exception thrown from LINQ provider when the query cannot be correctly produced.
Public class SnapshotWindowOutputPolicy 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.
Public class WindowInputPolicy The window input policy describes how the timestamps of events that fall into a given window are changed before processing the window operation.

Structures

  Structure Description
Public structure KeyedPayload<TKey, TPayload>

Interfaces

  Interface Description
Public interface ICepEnumerable<T> Extends the IEnumerable<T> interface to let you specify a query name and description for an enumerable event source.
Public interface ICepObservable<T> Extends the IObservable<T> interface to let you specify a query name and description for an observable event source.
Public interface IKey<K> Provides access to the grouping key.

Enumerations

  Enumeration Description
Public enumeration WindowInputPolicy.ClipKind The kind of clip for the input events that falls into the same window.