CepStream-Klasse
Stellt die Erweiterungsmethoden bereit, die für das Schreiben von LINQ-Abfragen für einen Datenstrom von CEP-Ereignissen verwendet werden.
Vererbungshierarchie
System. . :: . .Object
Microsoft.ComplexEventProcessing.Linq..::..CepStream
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)
Syntax
public static class CepStream
Der CepStream-Typ macht folgende Elemente verfügbar.
Methoden
| Name | Beschreibung | |
|---|---|---|
.gif "Öffentliche Methode") .gif "Statisches Element") |
AlterEventDuration< (Of < <' (TPayload> ) > > ) | Ändert die Dauer der Eingabeereignisse. Diese Methode ändert nicht die Startzeit eines Ereignisses. |
|
AlterEventLifetime< (Of < <' (TPayload> ) > > ) | Ändert die Lebensdauer der Ereignisse im Datenstrom. Diese Methode kann sowohl die Startzeit als auch die Endzeit eines Ereignisses ändern. |
|
ClipEventDuration< (Of < <' (TSource, TClip> ) > > ) | Verkürzt die Lebensdauer von Ereignissen in sourceStream auf die Startzeit des nächsten entsprechenden Ereignisses in clipStream, das mit matchExpression übereinstimmt. |
|
CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32) | Gruppiert Ereignisse eines Eingabedatenstroms auf der Grundlage einer angegebenen Anzahl eindeutiger Ereignisstartzeiten anhand der Standardausgaberichtlinie in Ereignisfenster. Das Fenster verschiebt sich, wenn ein neues Ereignis eintrifft, das zu einem anderen Zeitpunkt startet. |
|
CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32, CountWindowOutputPolicy) | Gruppiert Ereignisse eines Eingabedatenstroms auf der Grundlage einer angegebenen Anzahl eindeutiger Ereignisstartzeiten in Ereignisfenster. Das Fenster verschiebt sich, wenn ein neues Ereignis eintrifft, das zu einem anderen Zeitpunkt startet. |
|
CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32, WindowInputPolicy, CountWindowOutputPolicy) | Gruppiert Ereignisse eines Eingabedatenstroms auf der Grundlage einer angegebenen Anzahl eindeutiger Ereignisstartzeiten in Ereignisfenster. Das Fenster verschiebt sich, wenn ein neues Ereignis eintrifft, das zu einem anderen Zeitpunkt startet. |
|
GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > )) | Partitioniert den Eingabedatenstrom nach dem angegebenen Gruppierungsschlüssel. |
|
GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) | Gruppiert den Quelldatenstrom nach den angegebenen Schlüsselauswahlfunktionen und projiziert die Ergebnisse mithilfe der Elementauswahlfunktion. |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan) | Transformiert anhand der Standardausgaberichtlinie einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. Das Fenster wird durch die konstanten Zeitintervalle für die Fenstergröße und die Abschnittgröße definiert. |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, HoppingWindowOutputPolicy) | Transformiert einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. Das Fenster wird durch die konstanten Zeitintervalle für die Fenstergröße und die Abschnittgröße definiert. |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime) | Transformiert anhand der Standardausgaberichtlinie einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. Das Fenster wird durch konstante Zeitintervalle für die Fenstergröße und die Abschnittgröße definiert. Sie können auch eine Ausrichtungszeit als Referenz für den Startzeitpunkt des Fensters angeben. |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) | Transformiert einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. Das Fenster wird durch die konstanten Zeitintervalle für die Fenstergröße und die Abschnittgröße definiert. Sie können auch eine Ausrichtungszeit als Referenz für den Startzeitpunkt des Fensters angeben. |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) | Transformiert einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. Das Fenster wird durch konstante Zeitintervalle für die Fenstergröße und die Abschnittgröße definiert. Sie können auch eine Ausrichtungszeit als Referenz für den Startzeitpunkt des Fensters angeben. |
|
HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) | Das Fenster wird durch konstante Zeitintervalle für die Fenstergröße und die Abschnittgröße definiert. Sie können auch eine Ausrichtungszeit als Referenz für den Startzeitpunkt des Fensters angeben. |
|
IsEmpty< (Of < <' (TPayload> ) > > ) | Funktion, die in Abfragen verwendet wird, um einen Left Anti Semi Join (LASJ) anzugeben. |
|
Join< (Of < <' (TOuter, TInner, TKey, TResult> ) > > ) | Verknüpft die Ereignisse vom äußeren Datenstrom mit Ereignissen vom inneren Datenstrom anhand des vorhandenen Joinschlüssels. |
|
OrderBy< (Of < <' (TPayload, TOrderKey> ) > > ) | Ordnet den Eingabedatenstrom nach dem rankSelector. |
|
OrderByDescending< (Of < <' (TPayload, TOrderKey> ) > > ) | Ordnet den Eingabedatenstrom nach dem rankSelector in absteigender Reihenfolge. |
|
Scan< (Of < <' (TInputEvent, TInputPayload, TOutputPayload> ) > > ) | Scannt einen Eingabedatenstrom mithilfe eines benutzerdefinierten Datenstromoperators. |
|
Select< (Of < <' (TInput, TResult> ) > > )(CepOrderedStream< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TResult> ) > > )> ) > > )) | Wird dieser Methode ein geordneter Datenstrom übergeben, erzeugt sie einen geordneten Datenstrom, der für die Rangfolge verwendet werden kann. |
|
Select< (Of < <' (TPayload, TResult> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) | Projiziert Ereignisse aus einem Eingabedatenstrom mithilfe eines Projektionsausdrucks. |
|
Select< (Of < <' (TInput, TResult> ) > > )(CepWindowStream< (Of < <' (CepWindow< (Of < <' (TInput> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), TResult> ) > > )> ) > > )) | Ordnet einem Datenstrom auf der Grundlage eines angegebenen Zuordnungsausdrucks einen Fensterdatenstrom zu. |
|
Select< (Of < <' (TInput, TOutput> ) > > )(ICepEnumerable< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TOutput> ) > > )> ) > > )) | Projiziert jedes Ereignis eines Enumerable-Eingabedatenstroms in ein neues Ereignis. |
|
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> ) > > )> ) > > )) | Unterstützt die Sortierung für einen Datenstrom im Fenster. |
|
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> ) > > )> ) > > )) | Erzeugt auf der Grundlage des Kreuzjoins von zwei Eingabedatenströmen einen Datenstrom. |
|
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> ) > > )> ) > > )) | Unterstützt das Hinzufügen von Abfragelogik in einer Anweisung zum Gruppieren und Übernehmen. |
|
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> ) > > )> ) > > )) | Erzeugt auf der Grundlage des Kreuzjoins von zwei Eingabedatenströmen einen Datenstrom. |
|
ShiftEventTime< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > )) | Verlagert die Ereignisstartzeit auf einen neuen Zeitstempel, ohne die Lebensdauer zu ändern. |
|
ShiftEventTime< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > )) | Verlagert die Ereignisstartzeit um die angegebene Zeitspanne, ohne die Lebensdauer zu ändern. |
|
SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) | Transformiert anhand der Standardausgaberichtlinie einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. Jedes Fenster ist ein Momentaufnahmefenster, das von den nächstgelegenen Ereignisendpunkten im Datenstrom definiert wird. |
|
SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), SnapshotWindowOutputPolicy) | Transformiert einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. Jedes Fenster ist ein Momentaufnahmefenster, das von den nächstgelegenen Ereignisendpunkten im Datenstrom definiert wird. |
|
SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), WindowInputPolicy, SnapshotWindowOutputPolicy) | Transformiert einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. Jedes Fenster ist ein Momentaufnahmefenster, das von den nächstgelegenen Ereignisendpunkten im Datenstrom definiert wird. |
|
Take< (Of < <' (TPayload> ) > > )(CepOrderedStream< (Of < <' (TPayload> ) > > ), UInt32) | Entnimmt aus jedem Fenster eines angegebenen geordneten Datenstroms eine angegebene Anzahl von Ereignissen. |
|
Take< (Of < <' (TInput, TResult> ) > > )(CepOrderedStream< (Of < <' (TInput> ) > > ), UInt32, Expression< (Of < <' (Func< (Of < <' (CepRankedEvent< (Of < <' (TInput> ) > > ), TResult> ) > > )> ) > > )) | Wertet den angegebenen Ausdruck anhand einer angegebenen Anzahl von Ereignissen in jedem Fenster aus. Diese Methode wird für Fälle verwendet, in denen der Rang in das Ergebnis von Take() projiziert werden soll. |
|
ThenBy< (Of < <' (TPayload, TOrderKey> ) > > ) | Ordnet einen geordneten Datenstrom nach einem anderen orderKey als durch rankSelector angegeben. |
|
ThenByDescending< (Of < <' (TPayload, TOrderKey> ) > > ) | Ordnet einen geordneten Datenstrom nach einem anderen orderKey, wie durch rankSelector angegeben. |
|
ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) | Konvertiert einen CepStream von Edge-Ereignissen in eine Ereignissenke, die die IEnumerable-Schnittstelle implementiert. Die Reihenfolge von Ereignissen ist FullyOrdered. |
|
ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) | Konvertiert einen CepStream von Edge-Ereignissen mit der angegebenen Ereignisreihenfolge in eine Ereignissenke, die die IEnumerable-Schnittstelle implementiert. |
|
ToEdgeStream< (Of < <' (TInput, TPayload> ) > > ) | Konvertiert einen Enumerable-Eingabedatenstrom in einen Datenstrom von Edge-Ereignissen und stellt die temporären Eigenschaften der Eingabe bereit. |
|
ToEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) | Konvertiert einen Datenstrom von Ereignissen in eine Enumerable-Ausgabe durch Entfernen von Ereignisheadern und Verwerfen von CTI-Ereignissen. |
|
ToEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) | Konvertiert einen Datenstrom von Ereignissen in eine Enumerable-Ausgabe mit der angegebenen Ereignisreihenfolge durch Entfernen von Ereignisheadern und Verwerfen von CTI-Ereignissen. |
|
ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) | Konvertiert einen CepStream von Intervallereignissen in eine Ereignissenke, die die IEnumerable-Schnittstelle implementiert. Die Reihenfolge von Ereignissen ist FullyOrdered. |
|
ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) | Konvertiert einen CepStream von Intervallereignissen mit der angegebenen Ereignisreihenfolge in eine Ereignissenke, die die IEnumerable-Schnittstelle implementiert. |
|
ToIntervalStream< (Of < <' (TInput, TPayload> ) > > ) | Konvertiert einen Enumerable-Eingabedatenstrom in einen Datenstrom von Intervallereignissen und stellt die temporären Eigenschaften der Eingabe bereit. |
|
ToPointEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) | Konvertiert einen CepStream von Punktereignissen in eine Ereignissenke, die die IEnumerable-Schnittstelle implementiert. Die Reihenfolge von Ereignissen ist FullyOrdered. |
|
ToPointEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) | Konvertiert einen CepStream von Punktereignissen mit der angegebenen Ereignisreihenfolge in eine Ereignissenke, die die IEnumerable-Schnittstelle implementiert. |
|
ToPointEventStream< (Of < <' (TPayload> ) > > ) | Ändert die Ereignisse in einem Eingabedatenstrom in Punktereignisse, indem nur die Ereignisstartzeiten beibehalten werden. |
|
ToPointStream< (Of < <' (TInput, TPayload> ) > > ) | |
|
ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (EdgeEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String) | |
|
ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (IntervalEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String) | |
|
ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (PointEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String) | |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan) | Transformiert anhand der Standardausgaberichtlinie einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. Ein rollierendes Fenster ist eine besondere Art von springendem Fenster, bei dem die Fenstergröße und die Abschnittgröße gleich sind. |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, HoppingWindowOutputPolicy) | Transformiert einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. Ein rollierendes Fenster ist eine besondere Art von springendem Fenster, bei dem die Fenstergröße und die Abschnittgröße gleich sind. |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime) | Transformiert anhand der Standardausgaberichtlinie einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. Ein rollierendes Fenster ist eine besondere Art von springendem Fenster, bei dem die Fenstergröße und die Abschnittgröße gleich sind. Sie können auch eine Ausrichtungszeit als Referenz für den Startzeitpunkt des Fensters angeben. |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) | Transformiert einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. Ein rollierendes Fenster ist eine besondere Art von springendem Fenster, bei dem die Fenstergröße und die Abschnittgröße gleich sind. Sie können auch eine Ausrichtungszeit als Referenz für den Startzeitpunkt des Fensters angeben. |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime, HoppingWindowOutputPolicy) | Transformiert einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. Ein rollierendes Fenster ist eine besondere Art von springendem Fenster, bei dem die Fenstergröße und die Abschnittgröße gleich sind. Sie können auch eine Ausrichtungszeit als Referenz für den Startzeitpunkt des Fensters angeben. |
|
TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) | Transformiert einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. Ein rollierendes Fenster ist eine besondere Art von springendem Fenster, bei dem die Fenstergröße und die Abschnittgröße gleich sind. Sie können auch eine Ausrichtungszeit als Referenz für den Startzeitpunkt des Fensters angeben. |
|
Union< (Of < <' (TPayload> ) > > ) | Vereinigt zwei Datenströme als Union zu einem Datenstrom. |
|
Where< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, Boolean> ) > > )> ) > > )) | Filtert Ereignisse aus einem Eingabedatenstrom mithilfe einer angegebenen Filterfunktion. |
|
Where< (Of < <' (TInput> ) > > )(ICepEnumerable< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, Boolean> ) > > )> ) > > )) | Filtert Ereignisse aus einem Enumerable-Eingabedatenstrom mithilfe des angegebenen Filterausdrucks. |
Zum Anfang
Hinweise
CepStream ist eine Auflistung der Erweiterungsmethoden. Die Erweiterungsmethoden geben im Allgemeinen einen Ausdruck für einen LINQ-Methodenaufruf zurück. Die Methodenaufrufe zeichnen die Aufrufsequenz in einem kanonischen Format auf, das anschließend in eine ausführbare CEP-Abfrage übersetzt wird.
Threadsicherheit
Alle öffentlichen static (Shared in Visual Basic)-Elemente dieses Typs sind Threadsicher. Für Instanzelemente wird die Threadsicherheit nicht gewährleistet.