Partager via

Interface IQStreamable<TPayload>

  • Article

Représente une interface de base pour les parties d'une requête de flux temporel avec le type spécifié de charge utile.

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

Syntaxe

'Déclaration
Public Interface IQStreamable(Of TPayload) _
    Inherits IStreamable(Of TPayload), IQStreamable
'Utilisation
Dim instance As IQStreamable(Of TPayload)

public interface IQStreamable<TPayload> : IStreamable<TPayload>, 
    IQStreamable

generic<typename TPayload>
public interface class IQStreamable : IStreamable<TPayload>, 
    IQStreamable

type IQStreamable<'TPayload> =  
    interface 
        interface IStreamable<'TPayload>
        interface IQStreamable 
    end

JScript ne prend pas en charge les types et les méthodes génériques.

Paramètres de type

  • TPayload
    Type de la charge utile.

Le type IQStreamable<TPayload> expose les membres suivants.

Propriétés

  Nom Description
Propriété publique Expression Obtient l'expression décrivant la partie d'une requête. (hérité de IQStreamable.)
Propriété publique Provider Obtient le fournisseur LINQ pour la partie d'une requête de flux temporel. (hérité de IQStreamable.)

Haut de la page

Méthodes d'extension

  Nom Description
Méthode d'extension publique AlterEventDuration<TPayload> Modifie la durée des événements sans affecter l'heure de début. (défini par QStreamable.)
Méthode d'extension publique AlterEventLifetime<TPayload> Modifie la durée de vie des événements. (défini par QStreamable.)
Méthode d'extension publique AlterEventStartTime<TPayload> Modifie l'heure de début des événements sans affecter la durée. (défini par QStreamable.)
Méthode d'extension publique Bind<TPayload>(Func<Nullable<DateTimeOffset>, Int32, IRemoteObserver<EdgeEvent<TPayload>>>) Surchargé. Lie un flux temporel à un observateur d'événement session paramétrable sur une limite supérieure et un décalage. (défini par RemoteProvider.)
Méthode d'extension publique Bind<TPayload>(IRemoteObserver<EdgeEvent<TPayload>>) Surchargé. Lie un flux temporel à un récepteur d'observateur d'événement session. (défini par RemoteProvider.)
Méthode d'extension publique Bind<TPayload>(IRemoteObserver<IntervalEvent<TPayload>>) Surchargé. Lie un flux temporel à un récepteur d'observateur d'événement intervalle. (défini par RemoteProvider.)
Méthode d'extension publique Bind<TPayload>(Func<Nullable<DateTimeOffset>, Int32, IRemoteObserver<IntervalEvent<TPayload>>>) Surchargé. Lie un flux temporel à un observateur d'événement intervalle paramétrable sur une limite supérieure et un décalage. (défini par RemoteProvider.)
Méthode d'extension publique Bind<TPayload>(IRemoteObserver<TPayload>) Surchargé. Lie un flux temporel à un récepteur d'observateur. (défini par RemoteProvider.)
Méthode d'extension publique Bind<TPayload>(IRemoteStreamableSink<TPayload>) Surchargé. Lie une source de flux temporel à un récepteur de flux temporel. (défini par RemoteProvider.)
Méthode d'extension publique Bind<TPayload>(IRemoteObserver<PointEvent<TPayload>>) Surchargé. Lie un flux temporel à un récepteur d'observateur d'événement point. (défini par RemoteProvider.)
Méthode d'extension publique Bind<TPayload>(Func<Nullable<DateTimeOffset>, Int32, IRemoteObserver<PointEvent<TPayload>>>) Surchargé. Lie un flux temporel à un observateur d'événement point paramétrable sur une limite supérieure et un décalage. (défini par RemoteProvider.)
Méthode d'extension publique ClipEventDuration<TSource, TClip>(IQStreamable<TClip>, Expression<Func<TSource, TClip, Boolean>>) Surchargé. Fait coïncider l'heure de fin des événements dans la source avec l'heure de début de l'événement correspondant suivant dans le prédicat mis en correspondance. (défini par QStreamable.)
Méthode d'extension publique ClipEventDuration<TSource, TClip, TKey>(IQStreamable<TClip>, Expression<Func<TSource, TKey>>, Expression<Func<TClip, TKey>>) Surchargé. Fait coïncider l'heure de fin des événements dans la source avec l'heure de début de l'événement correspondant suivant dans clip avec une valeur de clé équivalent. (défini par QStreamable.)
Méthode d'extension publique CountWindow<TPayload> Produit un flux de données fenêtré basé sur un nombre.Chaque fenêtre est composée d'événements présentant un nombre d'heures de début unique.La fenêtre défile lorsqu'arrive un nouvel événement avec une heure de début distincte. (défini par QStreamable.)
Méthode d'extension publique Deploy<TPayload> Déploie un flux temporel distant. (défini par RemoteProvider.)
Méthode d'extension publique GroupBy<TPayload, TKey>(Expression<Func<TPayload, TKey>>) Surchargé. Opérateur de partition. (défini par QStreamable.)
Méthode d'extension publique GroupBy<TSource, TKey, TResult>(Expression<Func<TSource, TKey>>, Expression<Func<TSource, TResult>>) Surchargé. Opérateur de partition. (défini par QStreamable.)
Méthode d'extension publique HoppingWindow<TPayload>(TimeSpan, TimeSpan) Surchargé. Produit un flux de données fenêtré basé sur la définition de fenêtre.Les fenêtres récurrentes sont caractérisées par une durée de fenêtre et une taille de saut représentant la période de fenêtre. (défini par QStreamable.)
Méthode d'extension publique HoppingWindow<TPayload>(TimeSpan, TimeSpan, DateTime) Surchargé. Produit un flux de données fenêtré basé sur la définition de fenêtre.Les fenêtres récurrentes sont caractérisées par une durée de fenêtre et une taille de saut représentant la période de fenêtre. (défini par QStreamable.)
Méthode d'extension publique Join<TLeft, TRight, TKey, TResult> Joint des événements avec des durées de vie coïncidentes et des valeurs de clé correspondantes. (défini par QStreamable.)
Méthode d'extension publique LeftAntiJoin<TLeft, TRight>(IQStreamable<TRight>, Expression<Func<TLeft, TRight, Boolean>>) Surchargé. Retourne les événements degauche lorsqu'ils ne coïncident à aucun des événements de droite correspondants dans lesquels les événements sont mis en correspondance en fonction d'un prédicat. (défini par QStreamable.)
Méthode d'extension publique LeftAntiJoin<TLeft, TRight, TKey>(IQStreamable<TRight>, Expression<Func<TLeft, TKey>>, Expression<Func<TRight, TKey>>) Surchargé. Retourne des événements de gauche lorsqu'ils ne coïncident à aucun des événements de droite correspondants dans lesquels les événements sont mis en correspondance par clé. (défini par QStreamable.)
Méthode d'extension publique Multicast<TSource>(Expression<Func<IQStreamable<TSource>, IRemoteStreamableBinding>>) Surchargé. Définit une liaison pouvant être utilisée dans un flux en fonction d'une source donnée. (défini par RemoteProvider.)
Méthode d'extension publique Multicast<TSource, TResult>(Expression<Func<IQStreamable<TSource>, IQStreamable<TResult>>>) Surchargé. Opérateur de multidiffusion (défini par QStreamable.)
Méthode d'extension publique Select<TSource, TResult> Opérateur de projection. (défini par QStreamable.)
Méthode d'extension publique SelectMany<TLeft, TRight, TResult> Opérateur de jointure croisée. (défini par QStreamable.)
Méthode d'extension publique ShiftEventTime<TPayload> Décale les événements selon des valeurs spécifiées par le paramètre shiftSelector. (défini par QStreamable.)
Méthode d'extension publique SnapshotWindow<TPayload> Produit un flux de données fenêtré basé sur des instantanés.Les fenêtres sont définies par des limites d'événement dans la source. (défini par QStreamable.)
Méthode d'extension publique ToEdgeEnumerable<TPayload> Convertit un flux temporel en séquence. (défini par RemoteProvider.)
Méthode d'extension publique ToEdgeObservable<TPayload> Convertit un flux temporel en séquence. (défini par RemoteProvider.)
Méthode d'extension publique ToEnumerable<TPayload> Convertit un flux temporel en séquence. (défini par RemoteProvider.)
Méthode d'extension publique ToIntervalEnumerable<TPayload> Convertit un flux temporel en séquence. (défini par RemoteProvider.)
Méthode d'extension publique ToIntervalObservable<TPayload> Convertit un flux temporel en séquence. (défini par RemoteProvider.)
Méthode d'extension publique ToObservable<TPayload> Convertit un flux temporel en séquence. (défini par RemoteProvider.)
Méthode d'extension publique ToPointEnumerable<TPayload> Convertit un flux temporel en séquence. (défini par RemoteProvider.)
Méthode d'extension publique ToPointEventStream<TPayload> Remplace les événements dans le flux d'entrée par des événements point. (défini par QStreamable.)
Méthode d'extension publique ToPointObservable<TPayload> Convertit un flux temporel en séquence. (défini par RemoteProvider.)
Méthode d'extension publique TumblingWindow<TPayload>(TimeSpan) Surchargé. Produit un flux de données fenêtré basé sur la définition de fenêtre. (défini par QStreamable.)
Méthode d'extension publique TumblingWindow<TPayload>(TimeSpan, DateTime) Surchargé. Produit un flux de données fenêtré basé sur la définition de fenêtre. (défini par QStreamable.)
Méthode d'extension publique Union<TPayload> Opérateur d'union. (défini par QStreamable.)
Méthode d'extension publique Where<TPayload> Opérateur de sélection. (défini par QStreamable.)

Haut de la page

Voir aussi

Référence

Espace de noms Microsoft.ComplexEventProcessing.Linq