Microsoft.ComplexEventProcessing.Linq Namespace
Exposes the StreamInsight query template language. For more information, see Using StreamInsight LINQ.
| Class | Description | |
|---|---|---|
|
CepCheckpointableProcessExtensions | Extension methods supporting creation of checkpointable processes. |
|
CepEvent | Provides access to the start time with expressions that can only refer to the start time of an event. |
|
CepEvent<TPayload> | Allows to specify lambda expressions for event duration changes. It provides access to start time, end time, and event payload. |
|
CepGroupingStreams<TPayload, TGroupingKey> | Represents a group of streams. |
|
CepOrderableStream<T> | Represents a stream of events that can be ordered. |
|
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. |
|
CepRankedEvent<P> | Exposes a rank along with the event payload over a ranked stream using Take. |
|
CepStream | Provides the extension methods used for writing LINQ queries over a stream of CEP events. |
|
CepStream<TPayload> | Represents a stream of events from any user specified payload type. |
|
CepStreamCreationContext | This class represents the context in which a CepStream was created. |
|
CepUserDefinedAggregateAttribute | Decorates the user-defined aggregate extension method. |
|
CepUserDefinedOperatorAttribute | Decorates the user-defined operator extension method. |
|
CepUtility | Utility class used by user defined operator, aggregate and functions. |
|
CepWindow<TPayload> | A window is a finite collection of events that results from applying a windowing operator on a stream of events.. |
|
CepWindowExtensionMethods | Provides extension methods for built-in aggregates. |
|
CepWindowStream<T> | Results from applying a windowing operator to a stream. |
|
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. |
|
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. |
|
InputStreamInfo | Contains all information extracted from a stream definition. |
|
ObservableCepStream | Provides support for event sinks that implement the IObservable interface. |
|
QStreamable | Represents operator extension methods for IQStreamable temporal stream queries. |
|
QueryGenerationException | Exception thrown from LINQ provider when the query cannot be correctly produced. |
|
RemoteEntityAttribute | Attribute that will be present on all context properties. This tells the LINQ provider that the property represents an entity on the remote server and it has to be evaluated instead of being sent to the server as part of the entity definition. |
|
RemoteProvider | Provides extension methods supporting definition, deployment, retrieval of and transition between sequences and temporal streams. |
|
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. |
|
WindowInputPolicy | The window input policy describes how the timestamps of events that fall into a given window are changed before processing the window operation. |
| Structure | Description | |
|---|---|---|
|
KeyedPayload<TKey, TPayload> | Represents a payload that can be accessed using key grouping. |
| Interface | Description | |
|---|---|---|
|
IBinding | Binding between a data generator and data consumer. |
|
ICepEnumerable<T> | Extends the IEnumerable<T> interface to let you specify a query name and description for an enumerable event source. |
|
ICepObservable<T> | Represents an extended observable interface supporting named queries for subscriptions. |
|
IKey<K> | Provides access to the grouping key. |
|
IOrderedWindow<TPayload> | Represents a window in which the arrival of events is fully ordered. |
|
IPartitionedStreamable<TKey, TPayload> | Represents a partitioned data that can be organized into streams. |
|
IQOrderedWindow<TPayload> | Represents an ordered window query. |
|
IQPartitionedStreamable<TKey, TPayload> | Represents a partitioned temporal stream query. |
|
IQStreamable | Base interface for parts of a temporal stream query. |
|
IQStreamable<TPayload> | Represents a base interface for parts of a temporal stream query with the specified type of payload. |
|
IQStreamableProvider | LINQ provider supporting composition of temporal stream queries. |
|
IQWindowedStreamable<TPayload> | Represents a windowed temporal stream query. |
|
IQWindowResult<TResult> | Provides the result of events within the window stream. |
|
IQWindowSource<TSource> | Provides the source of events within the window stream. |
|
IRemote | A component that is remotely hosted. |
|
IRemoteBinding | Remote binding between a data generator and data consumer. |
|
IRemoteObserver<TElement> | Represents the changes in observable objects. |
|
IRemoteProvider | Represents a LINQ provider supporting creation of remote sequence and stream definitions. |
|
IRemoteStreamableBinding | Represents a remote binding of streamable data. |
|
IRemoteStreamableSink<TPayload> | Represents a remotely hosted streamable event sink with specific payload type. |
|
IRemoteSubject<TSource, TResult> | Represents an interface for the remote binding. |
|
IStreamable<TPayload> | Represents a streamable data. |
|
IStreamableBinding | Represents the binding of streamable data. |
|
IStreamableSink<TPayload> | Represents a temporal stream event sink. |
|
IWindowedStreamable<TPayload> | Represents a windowed data that can be organized into streams. |
|
IWindowResult<TResult> | Provides the result of the event within the window stream. |
|
IWindowSource<TSource> | Provides the source of events within the window stream. |
| Enumeration | Description | |
|---|---|---|
|
WindowInputPolicy.ClipKind | The kind of clip for the input events that falls into the same window. |
