QStreamable.SelectMany<TKey, TSource, TBind, TResult> Method (IQPartitionedStreamable<TKey, TSource>, Expression<Func<IQStreamable<TSource>, IQWindowedStreamable<TBind>>>, Expression<Func<IKey<TKey>, CepWindow<TBind>, TResult>>)
Merges aggregate operator for partitioned stream.
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)
Syntax
'Declaration
<ExtensionAttribute> _
Public Shared Function SelectMany(Of TKey, TSource, TBind, TResult) ( _
source As IQPartitionedStreamable(Of TKey, TSource), _
streamSelector As Expression(Of Func(Of IQStreamable(Of TSource), IQWindowedStreamable(Of TBind))), _
resultSelector As Expression(Of Func(Of IKey(Of TKey), CepWindow(Of TBind), TResult)) _
) As IQStreamable(Of TResult)
'Usage
Dim source As IQPartitionedStreamable(Of TKey, TSource)
Dim streamSelector As Expression(Of Func(Of IQStreamable(Of TSource), IQWindowedStreamable(Of TBind)))
Dim resultSelector As Expression(Of Func(Of IKey(Of TKey), CepWindow(Of TBind), TResult))
Dim returnValue As IQStreamable(Of TResult)
returnValue = source.SelectMany(streamSelector, _
resultSelector)
public static IQStreamable<TResult> SelectMany<TKey, TSource, TBind, TResult>(
this IQPartitionedStreamable<TKey, TSource> source,
Expression<Func<IQStreamable<TSource>, IQWindowedStreamable<TBind>>> streamSelector,
Expression<Func<IKey<TKey>, CepWindow<TBind>, TResult>> resultSelector
)
[ExtensionAttribute]
public:
generic<typename TKey, typename TSource, typename TBind, typename TResult>
static IQStreamable<TResult>^ SelectMany(
IQPartitionedStreamable<TKey, TSource>^ source,
Expression<Func<IQStreamable<TSource>^, IQWindowedStreamable<TBind>^>^>^ streamSelector,
Expression<Func<IKey<TKey>^, CepWindow<TBind>^, TResult>^>^ resultSelector
)
static member SelectMany :
source:IQPartitionedStreamable<'TKey, 'TSource> *
streamSelector:Expression<Func<IQStreamable<'TSource>, IQWindowedStreamable<'TBind>>> *
resultSelector:Expression<Func<IKey<'TKey>, CepWindow<'TBind>, 'TResult>> -> IQStreamable<'TResult>
JScript does not support generic types and methods.
Type Parameters
- TKey
The partition key type.
- TSource
The source payload type.
- TBind
The intermediate payload type.
- TResult
The result payload type.
Parameters
- source
Type: Microsoft.ComplexEventProcessing.Linq.IQPartitionedStreamable<TKey, TSource>
The partitioned stream source.
- streamSelector
Type: System.Linq.Expressions.Expression<Func<IQStreamable<TSource>, IQWindowedStreamable<TBind>>>
The function returning a windowed stream given a partition stream.
- resultSelector
Type: System.Linq.Expressions.Expression<Func<IKey<TKey>, CepWindow<TBind>, TResult>>
The aggregate projection expression.
Return Value
Type: Microsoft.ComplexEventProcessing.Linq.IQStreamable<TResult>
The merged stream.
Usage Note
In Visual Basic and C#, you can call this method as an instance method on any object of type IQPartitionedStreamable<TKey, TSource>. When you use instance method syntax to call this method, omit the first parameter. For more information, see https://msdn.microsoft.com/en-us/library/bb384936(v=sql.111) or https://msdn.microsoft.com/en-us/library/bb383977(v=sql.111).