Classe CepStream

  • Article

Fournit les méthodes d'extension utilisées pour l'écriture de requêtes LINQ sur un flux de données d'événements CEP.

Hiérarchie d'héritage

System. . :: . .Object
  Microsoft.ComplexEventProcessing.Linq..::..CepStream

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

Syntaxe

public static class CepStream

Le type CepStream expose les membres suivants.

Méthodes

  Nom Description
Méthode publiqueMembre statique AlterEventDuration< (Of < <' (TPayload> ) > > ) Modifie la durée des événements d'entrée. Cette méthode ne change pas l'heure de début d'un événement.
Méthode publiqueMembre statique AlterEventLifetime< (Of < <' (TPayload> ) > > ) Modifie la durée de vie des événements dans le flux de données. Cette méthode peut modifier à la fois l'heure de début et l'heure de fin d'un événement.
Méthode publiqueMembre statique ClipEventDuration< (Of < <' (TSource, TClip> ) > > ) Réduit la durée de vie des événements dans sourceStream à l'heure de début de l'événement correspondant suivant dans clipStream mis en correspondance par matchExpression.
Méthode publiqueMembre statique CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32) 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 à l'aide de la stratégie de sortie par défaut. La fenêtre défile lorsqu'arrive un nouvel événement qui commence à une heure différente.
Méthode publiqueMembre statique CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (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.
Méthode publiqueMembre statique CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32, WindowInputPolicy, 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.
Méthode publiqueMembre statique GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > )) Partitionne le flux d'entrée par la clé de regroupement spécifiée.
Méthode publiqueMembre statique GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) Regroupe le flux de données source selon les fonctions de sélecteur de clé spécifiées et les résultats de projets à l'aide de la fonction de sélecteur d'élément.
Méthode publiqueMembre statique HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan) Transforme un flux de données en un flux de données de fenêtre où chaque membre est un CepWindow à l'aide de la stratégie de sortie par défaut. La fenêtre est définie par une taille de fenêtre constante et des intervalles de temps de taille de saut.
Méthode publiqueMembre statique HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, HoppingWindowOutputPolicy) 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.
Méthode publiqueMembre statique HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime) Transforme un flux de données en un flux de données de fenêtre où chaque membre est un CepWindow à l'aide de la stratégie de sortie par défaut. La fenêtre est définie par une taille de fenêtre constante et des intervalles de temps de taille de saut. Vous pouvez également fournir une heure d'alignement en tant que référence pour le point de départ de la fenêtre.
Méthode publiqueMembre statique HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) 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. Vous pouvez également fournir une heure d'alignement en tant que référence pour le point de départ de la fenêtre.
Méthode publiqueMembre statique HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) 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 la taille de la fenêtre constante et le TimeSpan de taille de saut. Vous pouvez également fournir une heure d'alignement en tant que référence pour le point de départ de la fenêtre.
Méthode publiqueMembre statique HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) La fenêtre est définie par la taille de la fenêtre constante et des intervalles de temps de taille de saut. Vous pouvez également fournir une heure d'alignement en tant que référence pour le point de départ de la fenêtre.
Méthode publiqueMembre statique IsEmpty< (Of < <' (TPayload> ) > > ) Fonction utilisée dans les requêtes pour indiquer une opération LASJ (« Left Anti Semi Join »).
Méthode publiqueMembre statique Join< (Of < <' (TOuter, TInner, TKey, TResult> ) > > ) Joint les événements du flux de données externe avec les événements du flux de données interne sur la clé de jointure donnée.
Méthode publiqueMembre statique OrderBy< (Of < <' (TPayload, TOrderKey> ) > > ) Trie le flux de données d'entrée selon rankSelector.
Méthode publiqueMembre statique OrderByDescending< (Of < <' (TPayload, TOrderKey> ) > > ) Trie le flux d'entrée selon rankSelector par ordre décroissant.
Méthode publiqueMembre statique Scan< (Of < <' (TInputEvent, TInputPayload, TOutputPayload> ) > > ) Analyse un flux de données d'entrée à l'aide d'un opérateur de flux de données défini par l'utilisateur.
Méthode publiqueMembre statique Select< (Of < <' (TInput, TResult> ) > > )(CepOrderedStream< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TResult> ) > > )> ) > > )) Pour un flux de données ordonné donné, cette méthode produit un flux de données ordonné qui peut être utilisé pour le classement.
Méthode publiqueMembre statique Select< (Of < <' (TPayload, TResult> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) Projette les événements de flux d'entrée à l'aide d'une expression de projections.
Méthode publiqueMembre statique Select< (Of < <' (TInput, TResult> ) > > )(CepWindowStream< (Of < <' (CepWindow< (Of < <' (TInput> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), TResult> ) > > )> ) > > )) Mappe un flux de données de fenêtre à un flux de données selon une expression de mappage donnée.
Méthode publiqueMembre statique Select< (Of < <' (TInput, TOutput> ) > > )(ICepEnumerable< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TOutput> ) > > )> ) > > )) Projette chaque événement d'un flux d'entrée énumérable dans un nouvel événement.
Méthode publiqueMembre statique SelectMany< (Of < <' (TInput, TResult> ) > > )(CepWindowStream< (Of < <' (CepWindow< (Of < <' (TInput> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), CepWindow< (Of < <' (TInput> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), TInput, TResult> ) > > )> ) > > )) Prend en charge l'opération ORDER BY sur un flux de données fenêtré.
Méthode publiqueMembre statique SelectMany< (Of < <' (TInput, TBind, TResult> ) > > )(CepStream< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepStream< (Of < <' (TInput> ) > > ), CepStream< (Of < <' (TBind> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TBind, TResult> ) > > )> ) > > )) Produit un flux de données selon la jointure croisée de deux flux d'entrée.
Méthode publiqueMembre statique SelectMany< (Of < <' (TInput, TGroupingKey, TBind, TResult> ) > > )(CepGroupingStreams< (Of < <' (TInput, TGroupingKey> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepStream< (Of < <' (TInput> ) > > ), CepStream< (Of < <' (TBind> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (IKey< (Of < <' (TGroupingKey> ) > > ), TBind, TResult> ) > > )> ) > > )) Prend en charge l'ajout de la logique de requête dans un opérateur Group and Apply.
Méthode publiqueMembre statique SelectMany< (Of < <' (TInput, TGroupingKey, TBind, TResult> ) > > )(CepGroupingStreams< (Of < <' (TInput, TGroupingKey> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepStream< (Of < <' (TInput> ) > > ), CepWindowStream< (Of < <' (TBind> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (IKey< (Of < <' (TGroupingKey> ) > > ), TBind, TResult> ) > > )> ) > > )) Produit un flux de données selon la jointure croisée de deux flux d'entrée.
Méthode publiqueMembre statique ShiftEventTime< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > )) Déplace l'heure de début de l'événement vers un nouvel horodatage sans modifier la durée de la vie.
Méthode publiqueMembre statique ShiftEventTime< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > )) Décale l'heure de début de l'événement de l'intervalle spécifié sans modifier la durée de la vie.
Méthode publiqueMembre statique SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Transforme un flux de données en un flux de données de fenêtre où chaque membre est un CepWindow à l'aide de la stratégie de sortie par défaut. Chaque fenêtre est une fenêtre d'instantané définie par les points de terminaison d'événement les plus proches dans le flux de données.
Méthode publiqueMembre statique SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), SnapshotWindowOutputPolicy) Transforme un flux de données en un flux de données de fenêtre où chaque membre est un CepWindow. Chaque fenêtre est une fenêtre d'instantané définie par les points de terminaison d'événement les plus proches dans le flux de données.
Méthode publiqueMembre statique SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), WindowInputPolicy, SnapshotWindowOutputPolicy) Transforme un flux de données en un flux de données de fenêtre où chaque membre est un CepWindow. Chaque fenêtre est une fenêtre d'instantané définie par les points de terminaison d'événement les plus proches dans le flux de données.
Méthode publiqueMembre statique Take< (Of < <' (TPayload> ) > > )(CepOrderedStream< (Of < <' (TPayload> ) > > ), UInt32) Pour un flux de données ordonné spécifié, prend un nombre donné d'événements dans chaque fenêtre.
Méthode publiqueMembre statique Take< (Of < <' (TInput, TResult> ) > > )(CepOrderedStream< (Of < <' (TInput> ) > > ), UInt32, Expression< (Of < <' (Func< (Of < <' (CepRankedEvent< (Of < <' (TInput> ) > > ), TResult> ) > > )> ) > > )) Prend un nombre spécifié d'événements de chaque fenêtre et évalue l'expression donnée. Cette méthode est utilisée pour projeter le classement dans le résultat de Take().
Méthode publiqueMembre statique ThenBy< (Of < <' (TPayload, TOrderKey> ) > > ) Trie un flux de données ordonné selon un autre orderKey, tel qu'indiqué par rankSelector.
Méthode publiqueMembre statique ThenByDescending< (Of < <' (TPayload, TOrderKey> ) > > ) Trie un flux de données ordonné selon un autre orderKey, tel qu'indiqué par rankSelector.
Méthode publiqueMembre statique ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Convertit un CepStream d'événements session en un récepteur d'événements qui implémente l'interface IEnumerable. L'ordre des événements est FullyOrdered.
Méthode publiqueMembre statique ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) Convertit un CepStream d'événements session avec l'ordre des événements spécifié en un récepteur d'événements qui implémente l'interface IEnumerable.
Méthode publiqueMembre statique ToEdgeStream< (Of < <' (TInput, TPayload> ) > > ) Convertit un flux d'entrée énumérable en un flux de données d'événements session et fournit les caractéristiques temporelles de l'entrée.
Méthode publiqueMembre statique ToEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Convertit un flux de données d'événements en une sortie énumérable en supprimant les en-têtes d'événement et en ignorant les événements CTI.
Méthode publiqueMembre statique ToEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) Convertit un flux de données d'événements en une sortie énumérable avec l'ordre des événements spécifié en supprimant les en-têtes d'événement et en ignorant les événements CTI.
Méthode publiqueMembre statique ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Convertit un CepStream d'événements intervalle en un récepteur d'événements qui implémente l'interface IEnumerable. L'ordre des événements est FullyOrdered.
Méthode publiqueMembre statique ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) Convertit un CepStream d'événements intervalle avec l'ordre des événements spécifié en un récepteur d'événements qui implémente l'interface IEnumerable.
Méthode publiqueMembre statique ToIntervalStream< (Of < <' (TInput, TPayload> ) > > ) Convertit un flux d'entrée énumérable en un flux de données d'événements intervalle et fournit les caractéristiques temporelles de l'entrée.
Méthode publiqueMembre statique ToPointEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Convertit un CepStream d'événements point en un récepteur d'événements qui implémente l'interface IEnumerable. L'ordre des événements est FullyOrdered.
Méthode publiqueMembre statique ToPointEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) Convertit un CepStream d'événements point avec l'ordre des événements spécifié en un récepteur d'événements qui implémente l'interface IEnumerable.
Méthode publiqueMembre statique ToPointEventStream< (Of < <' (TPayload> ) > > ) Transforme les événements du flux d'entrée en événements point en conservant uniquement les heures de début des événements.
Méthode publiqueMembre statique ToPointStream< (Of < <' (TInput, TPayload> ) > > )
Méthode publiqueMembre statique ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (EdgeEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)
Méthode publiqueMembre statique ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (IntervalEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)
Méthode publiqueMembre statique ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (PointEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)
Méthode publiqueMembre statique TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan) Transforme un flux de données en un flux de données de fenêtre où chaque membre est un CepWindow à l'aide de la stratégie de sortie par défaut. Une fenêtre bascule est un genre spécial de fenêtre récurrente où la taille de la fenêtre et la taille de saut de fenêtre sont identiques.
Méthode publiqueMembre statique TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, HoppingWindowOutputPolicy) Transforme un flux de données en un flux de données de fenêtre où chaque membre est un CepWindow. Une fenêtre bascule est un genre spécial de fenêtre récurrente où la taille de la fenêtre et la taille de saut de fenêtre sont identiques.
Méthode publiqueMembre statique TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime) Transforme un flux de données en un flux de données de fenêtre où chaque membre est un CepWindow à l'aide de la stratégie de sortie par défaut. Une fenêtre bascule est un genre spécial de fenêtre récurrente où la taille de la fenêtre et la taille de saut de fenêtre sont identiques. Vous pouvez également fournir une heure d'alignement en tant que référence pour le point de départ de la fenêtre.
Méthode publiqueMembre statique TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) Transforme un flux de données en un flux de données de fenêtre où chaque membre est un CepWindow. Une fenêtre bascule est un genre spécial de fenêtre récurrente où la taille de la fenêtre et la taille de saut de fenêtre sont identiques. Vous pouvez également fournir une heure d'alignement en tant que référence pour le point de départ de la fenêtre.
Méthode publiqueMembre statique TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime, HoppingWindowOutputPolicy) Transforme un flux de données en un flux de données de fenêtre où chaque membre est un CepWindow. Une fenêtre bascule est un genre spécial de fenêtre récurrente où la taille de la fenêtre et la taille de saut de fenêtre sont identiques. Vous pouvez également fournir une heure d'alignement en tant que référence pour le point de départ de la fenêtre.
Méthode publiqueMembre statique TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) Transforme un flux de données en un flux de données de fenêtre où chaque membre est un CepWindow. Une fenêtre bascule est un genre spécial de fenêtre récurrente où la taille de la fenêtre et la taille de saut de fenêtre sont identiques. Vous pouvez également fournir une heure d'alignement en tant que référence pour le point de départ de la fenêtre.
Méthode publiqueMembre statique Union< (Of < <' (TPayload> ) > > ) Réunit deux flux en un seul.
Méthode publiqueMembre statique Where< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, Boolean> ) > > )> ) > > )) Filtre les événements d'un flux d'entrée à l'aide d'une fonction de filtre donnée.
Méthode publiqueMembre statique Where< (Of < <' (TInput> ) > > )(ICepEnumerable< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, Boolean> ) > > )> ) > > )) Filtre les événements d'un flux d'entrée énumérable à l'aide de l'expression de filtre spécifiée.

Haut de la page

Notes

CepStream est une collection de méthodes d'extension. En général, les méthodes d'extension retournent une expression d'appel de méthode LINQ. Les appels de méthode capturent la séquence d'invocation sous forme canonique qui est convertie ensuite en requête CEP exécutable.

Sécurité des threads

Tous les membres publics static (Shared dans Visual Basic) de ce type sont thread-safe. Tous les membres de l'instance ne sont pas garantis comme étant thread-safe.

Voir aussi

Référence

Espace de noms Microsoft.ComplexEventProcessing.Linq