Partager via


Méthode CountByStartTimeWindow(TPayload) (CepStream(TPayload), UInt32, CountWindowOutputPolicy)

Regroupe les événements de flux d'entrée dans les fenêtres d'événements selon un nombre donné d'heures de début d'événement uniques. La fenêtre défile lorsqu'arrive un nouvel événement qui commence à une heure différente.

Espace de noms :  Microsoft.ComplexEventProcessing.Linq
Assembly :  Microsoft.ComplexEventProcessing (en Microsoft.ComplexEventProcessing.dll)

Syntaxe

public static CepWindowStream<CepWindow<TPayload>> CountByStartTimeWindow<TPayload>(
    this CepStream<TPayload> source,
    uint numberOfEventStartTime,
    CountWindowOutputPolicy outputPolicy
)

Paramètres de type

  • TPayload
    Type de la charge utile d'événement d'entrée.

Paramètres

  • numberOfEventStartTime
    Type : System. . :: . .UInt32
    Taille de la fenêtre selon un nombre d'heures de début d'événement uniques.

Valeur de retour

Type : Microsoft.ComplexEventProcessing.Linq. . :: . .CepWindowStream< (Of < ( <'CepWindow< (Of < ( <'TPayload> ) > ) >> ) > ) >
Flux de données de fenêtre auquel des agrégats, un classement ou des opérations définies par l'utilisateur peuvent être appliqués.

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 CepStream< (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

La stratégie de sortie par défaut pour les résultats de l'opération reposant sur un jeu en sus de la fenêtre consiste à créer un événement de point aligné sur l'heure de fin de la fenêtre. Pour plus d'informations sur les fenêtres, consultez Utilisation de fenêtres d'événement et Fenêtres utilisant des nombres.

Exemples

var agg = from w in inputStream.CountByStartTimeWindow(10, WindowOutputPolicy.ClipToWindowEnd)
          select new { sum = w.Sum(e => e.i) };

Voir aussi

Référence

CepStream Classe

Surcharge CountByStartTimeWindow

Espace de noms Microsoft.ComplexEventProcessing.Linq