CepOrderedStream<T> Class

Article
04/29/2016

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.

Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)

Inheritance Hierarchy

System.Object
Microsoft.ComplexEventProcessing.Linq.CepOrderedStream<T>

Syntax

public class CepOrderedStream<T>

generic<typename T>
public ref class CepOrderedStream

type CepOrderedStream<'T> = class end

Public Class CepOrderedStream(Of T)

Methods

	Name	Description
	Equals(Object)	(Inherited from Object.)
	Finalize()	(Inherited from Object.)
	GetHashCode()	(Inherited from Object.)
	GetType()	(Inherited from Object.)
	MemberwiseClone()	(Inherited from Object.)
	ToString()	(Inherited from Object.)

Extension Methods

	Name	Description
	Select<TInput, TResult>(Expression<Func<TInput, TResult>>)	Overloaded. Given an ordered stream, this method produces an ordered stream that can be used for ranking.(Defined by CepStream.)
	Take<TPayload>(UInt32)	Overloaded. Given an ordered stream, takes a given number of events from each window.(Defined by CepStream.)
	Take<TInput, TResult>(UInt32, Expression<Func<CepRankedEvent<TInput>, TResult>>)	Overloaded. Takes a given number of events from each window and also evaluate the given expression. This is used for cases in which you want to project the rank into the result of Take().(Defined by CepStream.)
	ThenBy<TPayload, TOrderKey>(Expression<Func<TPayload, TOrderKey>>)	Orders an ordered stream by another order key as indicated by rankSelector.(Defined by CepStream.)
	ThenByDescending<TPayload, TOrderKey>(Expression<Func<TPayload, TOrderKey>>)	Orders an ordered stream by another order key as indicated by rankSelector. (Defined by CepStream.)

Remarks

Once a stream has been ordered, it must be followed by a Take operation that yields a regular CEP stream that can be composed further.

Thread Safety

Any public static (Shared in Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.