Classe QStreamable

Représente les méthodes d'extension d'opérateur pour les requêtes de flux temporel IQStreamable.

Hiérarchie d'héritage

System.Object
  Microsoft.ComplexEventProcessing.Linq.QStreamable

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

Syntaxe

'Déclaration
<ExtensionAttribute> _
Public NotInheritable Class QStreamable
'Utilisation

public static class QStreamable

[ExtensionAttribute]
public ref class QStreamable abstract sealed

[<AbstractClassAttribute>]
[<SealedAttribute>]
type QStreamable =  class end

public final class QStreamable

Le type QStreamable expose les membres suivants.

Méthodes

	Nom	Description
	AlterEventDuration<TPayload>	Modifie la durée des événements sans affecter l'heure de début.
	AlterEventLifetime<TPayload>	Modifie la durée de vie des événements.
	AlterEventStartTime<TPayload>	Modifie l'heure de début des événements sans affecter la durée.
	ClipEventDuration<TSource, TClip>(IQStreamable<TSource>, IQStreamable<TClip>, Expression<Func<TSource, TClip, Boolean>>)	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.
	ClipEventDuration<TSource, TClip, TKey>(IQStreamable<TSource>, IQStreamable<TClip>, Expression<Func<TSource, TKey>>, Expression<Func<TClip, TKey>>)	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.
	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.
	GroupBy<TPayload, TKey>(IQStreamable<TPayload>, Expression<Func<TPayload, TKey>>)	Opérateur de partition.
	GroupBy<TSource, TKey, TResult>(IQStreamable<TSource>, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TResult>>)	Opérateur de partition.
	HoppingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan, TimeSpan)	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.
	HoppingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan, TimeSpan, DateTime)	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.
	Join<TLeft, TRight, TKey, TResult>	Joint des événements avec des durées de vie coïncidentes et des valeurs de clé correspondantes.
	LeftAntiJoin<TLeft, TRight>(IQStreamable<TLeft>, IQStreamable<TRight>, Expression<Func<TLeft, TRight, Boolean>>)	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.
	LeftAntiJoin<TLeft, TRight, TKey>(IQStreamable<TLeft>, IQStreamable<TRight>, Expression<Func<TLeft, TKey>>, Expression<Func<TRight, TKey>>)	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é.
	Multicast<TSource, TResult>	Opérateur de multidiffusion
	OrderBy<TPayload, TKey>	Classe le contenu d'une fenêtre en fonction d'une clé.
	OrderByDescending<TPayload, TKey>	Classe le contenu d'une fenêtre en fonction d'une clé dans l'ordre décroissant.
	Scan<TSourceEvent, TSource, TResult>	Analyse un flux de données à l'aide d'un opérateur de flux de données défini par l'utilisateur.
	Select<TSource, TResult>(IQOrderedWindow<TSource>, Expression<Func<TSource, TResult>>)	Opérateur de projection sur une fenêtre ordonnée.
	Select<TSource, TResult>(IQStreamable<TSource>, Expression<Func<TSource, TResult>>)	Opérateur de projection.
	Select<TSource, TResult>(IQWindowedStreamable<TSource>, Expression<Func<CepWindow<TSource>, TResult>>)	Méthode de projection prenant en charge les calculs d'agrégation sur des fenêtres.
	SelectMany<TSource, TResult>(IQWindowedStreamable<TSource>, Expression<Func<IQWindowSource<TSource>, IQWindowResult<TResult>>>)	Lie un opérateur retournant un flux de résultats en fonction d'une fonction donnée à partir des résultats de fenêtre à fenêtre.
	SelectMany<TKey, TSource, TResult>(IQPartitionedStreamable<TKey, TSource>, Expression<Func<IQStreamable<TSource>, IQStreamable<TResult>>>)	Fusionne l'opérateur pour le flux partitionné.
	SelectMany<TLeft, TRight, TResult>(IQStreamable<TLeft>, Expression<Func<Unit, IQStreamable<TRight>>>, Expression<Func<TLeft, TRight, TResult>>)	Opérateur de jointure croisée.
	SelectMany<TSource, TBind, TResult>(IQWindowedStreamable<TSource>, Expression<Func<IQWindowSource<TSource>, IQWindowResult<TBind>>>, Expression<Func<Unit, TBind, TResult>>)	Lie un opérateur retournant un flux de résultats en fonction d'une fonction donnée à partir des résultats de fenêtre à fenêtre.
	SelectMany<TKey, TSource, TBind, TResult>(IQPartitionedStreamable<TKey, TSource>, Expression<Func<IQStreamable<TSource>, IQStreamable<TBind>>>, Expression<Func<IKey<TKey>, TBind, TResult>>)	Fusionne l'opérateur pour le flux partitionné.
	SelectMany<TKey, TSource, TBind, TResult>(IQPartitionedStreamable<TKey, TSource>, Expression<Func<IQStreamable<TSource>, IQWindowedStreamable<TBind>>>, Expression<Func<IKey<TKey>, CepWindow<TBind>, TResult>>)	Fusionne l'opérateur d'agrégation pour le flux partitionné.
	ShiftEventTime<TPayload>	Décale les événements selon des valeurs spécifiées par le paramètre shiftSelector.
	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.
	Take<TPayload>(IQOrderedWindow<TPayload>, UInt32)	Accepte les éléments de nombre supérieurs depuis une fenêtre ordonnée.En présence de liaisons, tous les éléments avec le classement le plus bas sont retournés.
	Take<TSource, TResult>(IQOrderedWindow<TSource>, UInt32, Expression<Func<CepRankedEvent<TSource>, TResult>>)	Accepte les éléments de nombre supérieurs depuis une fenêtre ordonnée.En présence de liaisons, tous les éléments avec le classement le plus bas sont retournés.
	ThenBy<TPayload, TKey>	Ajoute une clé de tri à une définition de fenêtre ordonnée.
	ThenByDescending<TPayload, TKey>	Ajoute une clé de tri à une définition de fenêtre ordonnée dans laquelle la clé est utilisée pour l'ordre décroissant.
	ToPointEventStream<TPayload>	Remplace les événements dans le flux d'entrée par des événements point.
	TumblingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan)	Produit un flux de données fenêtré basé sur la définition de fenêtre.
	TumblingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan, DateTime)	Produit un flux de données fenêtré basé sur la définition de fenêtre.
	Union<TPayload>	Opérateur d'union.
	UserDefinedOperator<TSource, TResult>(IQWindowSource<TSource>, Expression<Func<CepOperator<TSource, TResult>>>)	Applique un opérateur défini par l'utilisateur à une fenêtre.
	UserDefinedOperator<TSource, TResult>(IQWindowSource<TSource>, Expression<Func<CepTimeSensitiveOperator<TSource, TResult>>>)	Applique un opérateur défini par l'utilisateur à une fenêtre.
	Where<TPayload>	Opérateur de sélection.

Haut de la page

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