Export (0) Print
Expand All
Expand Minimize

Microsoft.ComplexEventProcessing.Linq Namespace

Exposes the StreamInsight query template language. For more information, see Using StreamInsight LINQ.

  Class Description
Public class CepCheckpointableProcessExtensions Extension methods supporting creation of checkpointable processes.
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 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 Provides 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 QStreamable Represents operator extension methods for IQStreamable temporal stream queries.
Public class QueryGenerationException Exception thrown from LINQ provider when the query cannot be correctly produced.
Public class 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.
Public class RemoteProvider Provides extension methods supporting definition, deployment, retrieval of and transition between sequences and temporal streams.
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.

  Structure Description
Public structure KeyedPayload<TKey, TPayload> Represents a payload that can be accessed using key grouping.

  Interface Description
Public interface IBinding Binding between a data generator and data consumer.
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> Represents an extended observable interface supporting named queries for subscriptions.
Public interface IKey<K> Provides access to the grouping key.
Public interface IOrderedWindow<TPayload> Represents a window in which the arrival of events is fully ordered.
Public interface IPartitionedStreamable<TKey, TPayload> Represents a partitioned data that can be organized into streams.
Public interface IQOrderedWindow<TPayload> Represents an ordered window query.
Public interface IQPartitionedStreamable<TKey, TPayload> Represents a partitioned temporal stream query.
Public interface IQStreamable Base interface for parts of a temporal stream query.
Public interface IQStreamable<TPayload> Represents a base interface for parts of a temporal stream query with the specified type of payload.
Public interface IQStreamableProvider LINQ provider supporting composition of temporal stream queries.
Public interface IQWindowedStreamable<TPayload> Represents a windowed temporal stream query.
Public interface IQWindowResult<TResult> Provides the result of events within the window stream.
Public interface IQWindowSource<TSource> Provides the source of events within the window stream.
Public interface IRemote A component that is remotely hosted.
Public interface IRemoteBinding Remote binding between a data generator and data consumer.
Public interface IRemoteObserver<TElement> Represents the changes in observable objects.
Public interface IRemoteProvider Represents a LINQ provider supporting creation of remote sequence and stream definitions.
Public interface IRemoteStreamableBinding Represents a remote binding of streamable data.
Public interface IRemoteStreamableSink<TPayload> Represents a remotely hosted streamable event sink with specific payload type.
Public interface IRemoteSubject<TSource, TResult> Represents an interface for the remote binding.
Public interface IStreamable<TPayload> Represents a streamable data.
Public interface IStreamableBinding Represents the binding of streamable data.
Public interface IStreamableSink<TPayload> Represents a temporal stream event sink.
Public interface IWindowedStreamable<TPayload> Represents a windowed data that can be organized into streams.
Public interface IWindowResult<TResult> Provides the result of the event within the window stream.
Public interface IWindowSource<TSource> Provides the source of events within the window stream.

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