Méthode QStreamable.SelectMany<TKey, TSource, TBind, TResult> (IQPartitionedStreamable<TKey, TSource>, Expression<Func<IQStreamable<TSource>, IQWindowedStreamable<TBind>>>, Expression<Func<IKey<TKey>, CepWindow<TBind>, TResult>>)
Fusionne l'opérateur d'agrégation pour le flux partitionné.
Espace de noms : Microsoft.ComplexEventProcessing.Linq
Assembly : Microsoft.ComplexEventProcessing (en Microsoft.ComplexEventProcessing.dll)
Syntaxe
'Déclaration
<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)
'Utilisation
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 ne prend pas en charge les types et les méthodes génériques.
Paramètres de type
- TKey
Type de clé de partition.
- TSource
Type de charge utile source.
- TBind
Type de charge utile intermédiaire.
- TResult
Type de charge utile de résultat.
Paramètres
- source
Type : Microsoft.ComplexEventProcessing.Linq.IQPartitionedStreamable<TKey, TSource>
Source de flux de données partitionné.
- streamSelector
Type : System.Linq.Expressions.Expression<Func<IQStreamable<TSource>, IQWindowedStreamable<TBind>>>
Fonction retournant un flux fenêtré en fonction d'un flux de partition donné.
- resultSelector
Type : System.Linq.Expressions.Expression<Func<IKey<TKey>, CepWindow<TBind>, TResult>>
Expression de projection d'agrégation.
Valeur de retour
Type : Microsoft.ComplexEventProcessing.Linq.IQStreamable<TResult>
Flux de données fusionné.
Remarque relative à l'utilisation
En Visual Basic et C#, vous pouvez appeler cette méthode comme méthode d'instance sur tout objet de type IQPartitionedStreamable<TKey, TSource>. Lorsque vous utilisez la syntaxe de la méthode d'instance pour appeler cette méthode, omettez le premier paramètre. Pour plus d'informations, consultez https://msdn.microsoft.com/fr-fr/library/bb384936(v=sql.111) ou https://msdn.microsoft.com/fr-fr/library/bb383977(v=sql.111).