Méthode Take(TPayload) (CepOrderedStream(TPayload), UInt32)
Pour un flux de données ordonné spécifié, prend un nombre donné d'événements dans chaque fenêtre.
Espace de noms : Microsoft.ComplexEventProcessing.Linq
Assembly : Microsoft.ComplexEventProcessing (en Microsoft.ComplexEventProcessing.dll)
Syntaxe
public static CepStream<TPayload> Take<TPayload>(
this CepOrderedStream<TPayload> source,
uint numberOfElements
)
Paramètres de type
- TPayload
Type de charge utile des événements d'entrée.
Paramètres
- source
Type : Microsoft.ComplexEventProcessing.Linq. . :: . .CepOrderedStream< (Of < ( <'TPayload> ) > ) >
Flux d'entrée.
- numberOfElements
Type : System. . :: . .UInt32
Nombre d'éléments à prendre dans chaque fenêtre.
Valeur de retour
Type : Microsoft.ComplexEventProcessing.Linq. . :: . .CepStream< (Of < ( <'TPayload> ) > ) >
Flux de données avec un nombre donné d'événements pris dans chaque fenêtre.
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 CepOrderedStream< (Of < ( <'TPayload> ) > ) >. 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.105) ou https://msdn.microsoft.com/fr-fr/library/bb383977(v=sql.105).
Notes
Pour plus d'informations, consultez TopK.
Exemples
L'exemple suivant prend les cinq premiers événements de chaque fenêtre d'instantané définie pour le flux d'entrée inputStream, puis génère un nouveau flux d'événements. Les événements dans chaque fenêtre sont ordonnés dans l'ordre croissant des valeurs dans les champs de charge utile e.f et combinés avec l'ordre décroissant des valeurs dans le champ de charge utile e.i.
// Assuming the following input event type for inputStream:
public class MyPayload
{
public int f;
public int i;
}
var topfive = (from window in inputStream.Snapshot(SnapshotWindowOutputPolicy.Clip)
from e in window
orderby e.f ascending, e.i descending
select e).Take(5);