Interface IQStreamable<TPayload>
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 | |
---|---|---|
Expression | Obtient l'expression décrivant la partie d'une requête. (hérité de IQStreamable.) | |
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 | |
---|---|---|
AlterEventDuration<TPayload> | Modifie la durée des événements sans affecter l'heure de début. (défini par QStreamable.) | |
AlterEventLifetime<TPayload> | Modifie la durée de vie des événements. (défini par QStreamable.) | |
AlterEventStartTime<TPayload> | Modifie l'heure de début des événements sans affecter la durée. (défini par QStreamable.) | |
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.) | |
Bind<TPayload>(IRemoteObserver<EdgeEvent<TPayload>>) | Surchargé. Lie un flux temporel à un récepteur d'observateur d'événement session. (défini par RemoteProvider.) | |
Bind<TPayload>(IRemoteObserver<IntervalEvent<TPayload>>) | Surchargé. Lie un flux temporel à un récepteur d'observateur d'événement intervalle. (défini par RemoteProvider.) | |
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.) | |
Bind<TPayload>(IRemoteObserver<TPayload>) | Surchargé. Lie un flux temporel à un récepteur d'observateur. (défini par RemoteProvider.) | |
Bind<TPayload>(IRemoteStreamableSink<TPayload>) | Surchargé. Lie une source de flux temporel à un récepteur de flux temporel. (défini par RemoteProvider.) | |
Bind<TPayload>(IRemoteObserver<PointEvent<TPayload>>) | Surchargé. Lie un flux temporel à un récepteur d'observateur d'événement point. (défini par RemoteProvider.) | |
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.) | |
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.) | |
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.) | |
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.) | |
Deploy<TPayload> | Déploie un flux temporel distant. (défini par RemoteProvider.) | |
GroupBy<TPayload, TKey>(Expression<Func<TPayload, TKey>>) | Surchargé. Opérateur de partition. (défini par QStreamable.) | |
GroupBy<TSource, TKey, TResult>(Expression<Func<TSource, TKey>>, Expression<Func<TSource, TResult>>) | Surchargé. Opérateur de partition. (défini par QStreamable.) | |
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.) | |
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.) | |
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.) | |
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.) | |
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.) | |
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.) | |
Multicast<TSource, TResult>(Expression<Func<IQStreamable<TSource>, IQStreamable<TResult>>>) | Surchargé. Opérateur de multidiffusion (défini par QStreamable.) | |
Select<TSource, TResult> | Opérateur de projection. (défini par QStreamable.) | |
SelectMany<TLeft, TRight, TResult> | Opérateur de jointure croisée. (défini par QStreamable.) | |
ShiftEventTime<TPayload> | Décale les événements selon des valeurs spécifiées par le paramètre shiftSelector. (défini par QStreamable.) | |
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.) | |
ToEdgeEnumerable<TPayload> | Convertit un flux temporel en séquence. (défini par RemoteProvider.) | |
ToEdgeObservable<TPayload> | Convertit un flux temporel en séquence. (défini par RemoteProvider.) | |
ToEnumerable<TPayload> | Convertit un flux temporel en séquence. (défini par RemoteProvider.) | |
ToIntervalEnumerable<TPayload> | Convertit un flux temporel en séquence. (défini par RemoteProvider.) | |
ToIntervalObservable<TPayload> | Convertit un flux temporel en séquence. (défini par RemoteProvider.) | |
ToObservable<TPayload> | Convertit un flux temporel en séquence. (défini par RemoteProvider.) | |
ToPointEnumerable<TPayload> | Convertit un flux temporel en séquence. (défini par RemoteProvider.) | |
ToPointEventStream<TPayload> | Remplace les événements dans le flux d'entrée par des événements point. (défini par QStreamable.) | |
ToPointObservable<TPayload> | Convertit un flux temporel en séquence. (défini par RemoteProvider.) | |
TumblingWindow<TPayload>(TimeSpan) | Surchargé. Produit un flux de données fenêtré basé sur la définition de fenêtre. (défini par QStreamable.) | |
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.) | |
Union<TPayload> | Opérateur d'union. (défini par QStreamable.) | |
Where<TPayload> | Opérateur de sélection. (défini par QStreamable.) |
Haut de la page