CepStream.SelectMany<TInput, TResult> Method (CepWindowStream<CepWindow<TInput>>, Expression<Func<CepWindow<TInput>, CepWindow<TInput>>>, Expression<Func<CepWindow<TInput>, TInput, TResult>>)

Supports order by operation against a windowed stream.

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

Syntax

public static CepOrderableStream<TResult> SelectMany<TInput, TResult>(
    this CepWindowStream<CepWindow<TInput>> source,
    Expression<Func<CepWindow<TInput>, CepWindow<TInput>>> bind,
    Expression<Func<CepWindow<TInput>, TInput, TResult>> selector
)

public:
generic<typename TInput, typename TResult>
[ExtensionAttribute]
static CepOrderableStream<TResult>^ SelectMany(
    CepWindowStream<CepWindow<TInput>^>^ source,
    Expression<Func<CepWindow<TInput>^, CepWindow<TInput>^>^>^ bind,
    Expression<Func<CepWindow<TInput>^, TInput, TResult>^>^ selector
)

static member SelectMany<'TInput, 'TResult> : 
        source:CepWindowStream<CepWindow<'TInput>> *
        bind:Expression<Func<CepWindow<'TInput>, CepWindow<'TInput>>> *
        selector:Expression<Func<CepWindow<'TInput>, 'TInput, 'TResult>> -> CepOrderableStream<'TResult>

<ExtensionAttribute>
Public Shared Function SelectMany(Of TInput, TResult) (
    source As CepWindowStream(Of CepWindow(Of TInput)),
    bind As Expression(Of Func(Of CepWindow(Of TInput), CepWindow(Of TInput))),
    selector As Expression(Of Func(Of CepWindow(Of TInput), TInput, TResult))
) As CepOrderableStream(Of TResult)

Parameters

• source
  Type: Microsoft.ComplexEventProcessing.Linq.CepWindowStream<CepWindow<TInput>>

  The stream source.

• bind
  Type: System.Linq.Expressions.Expression<Func<CepWindow<TInput>, CepWindow<TInput>>>

  The bind expression to bind elements in the two "from" clauses.

• selector
  Type: System.Linq.Expressions.Expression<Func<CepWindow<TInput>, TInput, TResult>>

  The result selector.

Return Value

Type: Microsoft.ComplexEventProcessing.Linq.CepOrderableStream<TResult>

A stream that can be ordered.

Type Parameters

• TInput
  The type of the input event payload.

• TResult
  The type of output event payload.

Remarks

An example is: <code> (from w in s.Snapshot() from e in w order by e.i order by e.j descending select e).Take(10) </code> The two "from" clauses are converted into SelectMany.

See Also

SelectMany Overload
CepStream Class
Microsoft.ComplexEventProcessing.Linq Namespace

Return to top