Méthode HoppingWindow(TPayload) (CepStream(TPayload), TimeSpan, TimeSpan, HoppingWindowOutputPolicy)

Article
08/01/2011

Transforme un flux de données en un flux de données de fenêtre où chaque membre est un CepWindow. La fenêtre est définie par une taille de fenêtre constante et des intervalles de temps de taille de saut.

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

Syntaxe

public static CepWindowStream<CepWindow<TPayload>> HoppingWindow<TPayload>(
    this CepStream<TPayload> source,
    TimeSpan windowSize,
    TimeSpan hopSize,
    HoppingWindowOutputPolicy outputPolicy
)

Paramètres de type

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

Paramètres

source
Type : Microsoft.ComplexEventProcessing.Linq. . :: . .CepStream< (Of < ( <'TPayload> ) > ) >
CepStream auquel appliquer l'opération HoppingWindow.

windowSize
Type : System. . :: . .TimeSpan
Longueur de la fenêtre.

hopSize
Type : System. . :: . .TimeSpan
Taille de saut de la fenêtre.

outputPolicy
Type : Microsoft.ComplexEventProcessing.Linq. . :: . .HoppingWindowOutputPolicy
Indique comment les événements de sortie de l'opération d'affichage sont modifiés.

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

Utilise une stratégie d'entrée par défaut qui fait coïncider les heures de début et de fin des événements à la taille de la fenêtre. Pour plus d'informations, consultez Utilisation de fenêtres d'événement.

Exemples

var hoppingAgg = from w in inputStream.HoppingWindow(TimeSpan.FromHours(1),
                                                     TimeSpan.FromMinutes(10),
                                                     WindowOutputPolicy.ClipToWindowEnd)
                 select new { sum = w.Sum(e => e.i) };