Classe CepStream(TPayload)
Représente un flux d'événements de tout type de charge utile spécifié par l'utilisateur.
Hiérarchie d'héritage
System. . :: . .Object
Microsoft.ComplexEventProcessing.Linq..::..CepStream<(Of <(<'TPayload>)>)>
Espace de noms : Microsoft.ComplexEventProcessing.Linq
Assembly : Microsoft.ComplexEventProcessing (en Microsoft.ComplexEventProcessing.dll)
Syntaxe
public sealed class CepStream<TPayload>
Paramètres de type
- TPayload
Type de charge utile de l'événement dans le flux.
Le type CepStream<(Of <(<'TPayload>)>)> expose les membres suivants.
Méthodes
| Nom | Description | |
|---|---|---|
.gif "Méthode publique") .gif "Membre statique") |
Create(String) | Crée un flux de données indépendant avec la charge utile d'événement de type « TPayload ». |
|
Create(Uri, EventShape) | Crée un flux de données dépendant sur une entrée à partir d'un flux publié donné. |
|
Create(Uri, EventShape, AdvanceTimeSettings) | Crée un flux de données dépendant pour une entrée provenant d'un flux publié donné. |
|
Create(Application, Uri, EventShape) | Crée un flux de données dépendant sur une entrée à partir d'un flux publié donné. |
|
Create(String, Type, Object, EventShape) | Crée un flux de données dépendant à partir d'une fabrique d'adaptateur d'entrée donnée. |
|
Create(Application, Uri, EventShape, AdvanceTimeSettings) | Crée un flux de données dépendant pour une entrée provenant d'un flux publié donné. |
|
Create(String, Type, Object, EventShape, AdvanceTimeSettings) | Crée un flux de données dépendant à partir d'une fabrique d'adaptateur d'entrée donnée. |
|
Create(Application, String, Type, Object, EventShape) | Crée un flux de données dépendant à partir d'une fabrique d'adaptateur d'entrée donnée. |
|
Create(Application, String, Type, Object, EventShape, AdvanceTimeSettings) | Crée un flux de données dépendant à partir d'une fabrique d'adaptateur d'entrée donnée. |
|
Equals | (hérité de Object.) |
|
ExtractInputStreams | Récupère une liste avec les informations sur les flux d'entrée d'une définition de flux donnée. |
.gif "Méthode protégée") |
Finalize | (hérité de Object.) |
|
GetHashCode | (hérité de Object.) |
|
GetType | (hérité de Object.) |
|
MemberwiseClone | (hérité de Object.) |
|
ToPublishedStreamQuery(Uri, String, String, EventShape, StreamEventOrder) | Crée une requête avec une sortie liée à un flux de données publié nommé explicitement. La sortie de la requête peut être consommée via la composition de requête dynamique. Une seule requête peut produire, à un moment donné, des événements pour un flux de données publié. |
|
ToPublishedStreamQuery(Uri, Application, String, String, EventShape, StreamEventOrder) | Crée une requête avec une sortie liée à un flux de données publié nommé explicitement. La sortie de la requête peut être consommée via la composition de requête dynamique. Une seule requête peut produire, à un moment donné, des événements pour un flux publié. |
|
ToQuery(String, String, EventShape, StreamEventOrder) | Crée une requête à partir du flux de données avec une sortie indépendante. Toutes les entrées de la requête doivent être liées à des adaptateurs, des séquences ou d'autres requêtes. La sortie de la requête peut être consommée via la composition de requête dynamique uniquement. L'application dans laquelle cette requête va s'exécuter est déduite de la définition du flux de données. |
|
ToQuery(Application, String, String, EventShape, StreamEventOrder) | Crée une requête à partir du flux de données avec une sortie indépendante exécutée dans l'application spécifiée. Toutes les entrées de la requête doivent être liées à des adaptateurs, des séquences ou d'autres requêtes. La sortie de la requête peut être consommée via la composition de requête dynamique uniquement. |
|
ToQuery(String, String, Type, Object, EventShape, StreamEventOrder) | Crée une requête à partir du flux de données lié à un adaptateur de sortie. L'adaptateur de sortie est spécifié par le type de la fabrique d'adaptateur et l'objet de configuration. L'application dans laquelle cette requête va s'exécuter est déduite de la définition du flux de données. |
|
ToQuery(String, String, Type, Object, EventShape, StreamEventOrder, Boolean) | Crée une requête à partir du flux de données lié à un adaptateur de sortie. L'adaptateur de sortie est spécifié par le type de la fabrique d'adaptateur et l'objet de configuration. L'application dans laquelle cette requête va s'exécuter est déduite de la définition du flux de données. La requête peut être spécifiée comme étant résistante. |
|
ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder) | Crée une requête à partir du flux de données lié à un adaptateur de sortie exécuté dans l'application spécifiée. L'adaptateur de sortie est spécifié par le type de la fabrique d'adaptateur et l'objet de configuration. |
|
ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder, Boolean) | Crée une requête à partir du flux de données lié à un adaptateur de sortie exécuté dans l'application spécifiée. L'adaptateur de sortie est spécifié par le type de la fabrique d'adaptateur et l'objet de configuration. La requête peut être spécifiée comme étant résistante. |
|
ToString | (hérité de Object.) |
Haut de la page
Méthodes d'extension
| Nom | Description | |
|---|---|---|
.gif "Méthode d'extension publique") |
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. (défini par CepStream.) |
|
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. (défini par CepStream.) |
|
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. (défini par CepStream.) |
|
CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32) | Surchargé. 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. (défini par CepStream.) |
|
CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, CountWindowOutputPolicy) | Surchargé. 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. (défini par CepStream.) |
|
CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, WindowInputPolicy, CountWindowOutputPolicy) | Surchargé. 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. (défini par CepStream.) |
|
GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > )) | Surchargé. Partitionne le flux d'entrée par la clé de regroupement spécifiée. (défini par CepStream.) |
|
GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) | Surchargé. 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. (défini par CepStream.) |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan) | Surchargé. 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. (défini par CepStream.) |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime) | Surchargé. 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. (défini par CepStream.) |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, HoppingWindowOutputPolicy) | Surchargé. 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. (défini par CepStream.) |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) | Surchargé. 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. (défini par CepStream.) |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) | Surchargé. 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. (défini par CepStream.) |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) | Surchargé. 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. (défini par CepStream.) |
|
IsEmpty< (Of < <' (TPayload> ) > > ) | Fonction utilisée dans les requêtes pour indiquer une opération LASJ (« Left Anti Semi Join »). (défini par CepStream.) |
|
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. (défini par CepStream.) |
|
Select< (Of < <' (TPayload, TResult> ) > > ) | Projette les événements de flux d'entrée à l'aide d'une expression de projections. (défini par CepStream.) |
|
SelectMany< (Of < <' (TInput, TBind, TResult> ) > > ) | Produit un flux de données selon la jointure croisée de deux flux d'entrée. (défini par CepStream.) |
|
ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > )) | Surchargé. Déplace l'heure de début de l'événement vers un nouvel horodatage sans modifier la durée de la vie. (défini par CepStream.) |
|
ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > )) | Surchargé. Décale l'heure de début de l'événement de l'intervalle spécifié sans modifier la durée de la vie. (défini par CepStream.) |
|
SnapshotWindow< (Of < <' (TPayload> ) > > )() () () () | Surchargé. 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. (défini par CepStream.) |
|
SnapshotWindow< (Of < <' (TPayload> ) > > )(SnapshotWindowOutputPolicy) | Surchargé. 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. (défini par CepStream.) |
|
SnapshotWindow< (Of < <' (TPayload> ) > > )(WindowInputPolicy, SnapshotWindowOutputPolicy) | Surchargé. 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. (défini par CepStream.) |
|
ToEdgeEnumerable< (Of < <' (TPayload> ) > > )() () () () | Surchargé. 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. (défini par CepStream.) |
|
ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) | Surchargé. 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. (défini par CepStream.) |
|
ToEdgeObservable< (Of < <' (TPayload> ) > > )() () () () | Surchargé. Convertit un CepStream d'événements session en un récepteur d'événements qui implémente l'interface IObservable. L'ordre des événements est FullyOrdered. (défini par ObservableCepStream.) |
|
ToEdgeObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) | Surchargé. 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 IObservable. (défini par ObservableCepStream.) |
|
ToEnumerable< (Of < <' (TPayload> ) > > )() () () () | Surchargé. 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. (défini par CepStream.) |
|
ToEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) | Surchargé. 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. (défini par CepStream.) |
|
ToIntervalEnumerable< (Of < <' (TPayload> ) > > )() () () () | Surchargé. 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. (défini par CepStream.) |
|
ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) | Surchargé. 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. (défini par CepStream.) |
|
ToIntervalObservable< (Of < <' (TPayload> ) > > )() () () () | Surchargé. Convertit un CepStream d'événements intervalle en un récepteur d'événements qui implémente l'interface IObservable. L'ordre des événements est FullyOrdered. (défini par ObservableCepStream.) |
|
ToIntervalObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) | Surchargé. 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 IObservable. (défini par ObservableCepStream.) |
|
ToObservable< (Of < <' (TPayload> ) > > )() () () () | Surchargé. Convertit un flux de données d'événements en une sortie observable en supprimant les en-têtes d'événement et en ignorant les événements CTI. (défini par ObservableCepStream.) |
|
ToObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) | Surchargé. Convertit un flux de données d'événements en une sortie observable avec l'ordre des événements spécifié en supprimant les en-têtes d'événement et en ignorant les événements CTI. (défini par ObservableCepStream.) |
|
ToPointEnumerable< (Of < <' (TPayload> ) > > )() () () () | Surchargé. 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. (défini par CepStream.) |
|
ToPointEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) | Surchargé. 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. (défini par CepStream.) |
|
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. (défini par CepStream.) |
|
ToPointObservable< (Of < <' (TPayload> ) > > )() () () () | Surchargé. Convertit un CepStream d'événements point en un récepteur d'événements qui implémente l'interface IObservable. L'ordre des événements est FullyOrdered. (défini par ObservableCepStream.) |
|
ToPointObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) | Surchargé. 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 IObservable. (défini par ObservableCepStream.) |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan) | Surchargé. 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. (défini par CepStream.) |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime) | Surchargé. 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. (défini par CepStream.) |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, HoppingWindowOutputPolicy) | Surchargé. 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. (défini par CepStream.) |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, HoppingWindowOutputPolicy) | Surchargé. 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. (défini par CepStream.) |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) | Surchargé. 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. (défini par CepStream.) |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) | Surchargé. 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. (défini par CepStream.) |
|
Union< (Of < <' (TPayload> ) > > ) | Réunit deux flux en un seul. (défini par CepStream.) |
|
Where< (Of < <' (TPayload> ) > > ) | Filtre les événements d'un flux d'entrée à l'aide d'une fonction de filtre donnée. (défini par CepStream.) |
Haut de la page
Notes
Avant d'écrire une requête CEP, vous devez fournir la définition de flux de données appropriée. Cette classe fournit différentes méthodes pour créer un objet CepStream.
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.