CepStream(TPayload)-Klasse
Stellt einen Datenstrom von Ereignissen eines beliebigen benutzerdefinierten Nutzlasttyps dar.
Vererbungshierarchie
System. . :: . .Object
Microsoft.ComplexEventProcessing.Linq..::..CepStream<(Of <(<'TPayload>)>)>
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)
Syntax
public sealed class CepStream<TPayload>
Typparameter
- TPayload
Der Nutzlasttyp des Ereignisses im Datenstrom.
Der CepStream<(Of <(<'TPayload>)>)>-Typ macht folgende Elemente verfügbar.
Methoden
Name | Beschreibung | |
---|---|---|
Create(String) | Erstellt einen ungebundenen Datenstrom mit einer Ereignisnutzlast vom Typ 'TPayload'. | |
Create(Uri, EventShape) | Erstellt einen gebundenen Datenstrom für eine Eingabe aus einem angegebenen veröffentlichten Datenstrom. | |
Create(Uri, EventShape, AdvanceTimeSettings) | Erstellt einen gebundenen Datenstrom für eine Eingabe aus einem angegebenen veröffentlichten Datenstrom. | |
Create(Application, Uri, EventShape) | Erstellt einen gebundenen Datenstrom für eine Eingabe aus einem angegebenen veröffentlichten Datenstrom. | |
Create(String, Type, Object, EventShape) | Erstellt einen gebundenen Datenstrom aus einer angegebenen Eingabeadapterfactory. | |
Create(Application, Uri, EventShape, AdvanceTimeSettings) | Erstellt einen gebundenen Datenstrom für eine Eingabe aus einem angegebenen veröffentlichten Datenstrom. | |
Create(String, Type, Object, EventShape, AdvanceTimeSettings) | Erstellt einen gebundenen Datenstrom aus einer angegebenen Eingabeadapterfactory. | |
Create(Application, String, Type, Object, EventShape) | Erstellt einen gebundenen Datenstrom aus einer angegebenen Eingabeadapterfactory. | |
Create(Application, String, Type, Object, EventShape, AdvanceTimeSettings) | Erstellt einen gebundenen Datenstrom aus einer angegebenen Eingabeadapterfactory. | |
Equals | (Geerbt von Object.) | |
ExtractInputStreams | Ruft eine Liste mit Informationen zu Eingabedatenströmen aus einer angegebenen Datenstromdefinition ab. | |
Finalize | (Geerbt von Object.) | |
GetHashCode | (Geerbt von Object.) | |
GetType | (Geerbt von Object.) | |
MemberwiseClone | (Geerbt von Object.) | |
ToPublishedStreamQuery(Uri, String, String, EventShape, StreamEventOrder) | Erstellt eine Abfrage mit einer Ausgabe, die an einen explizit benannten veröffentlichten Datenstrom gebunden ist. Die Ausgabe der Abfrage kann durch dynamische Abfragezusammenstellung genutzt werden. Nur jeweils eine Abfrage kann Ereignisse für einen veröffentlichten Datenstrom erzeugen. | |
ToPublishedStreamQuery(Uri, Application, String, String, EventShape, StreamEventOrder) | Erstellt eine Abfrage mit einer Ausgabe, die an einen explizit benannten veröffentlichten Datenstrom gebunden ist. Die Ausgabe der Abfrage kann durch dynamische Abfragezusammenstellung genutzt werden. Nur jeweils eine Abfrage kann Ereignisse für einen veröffentlichten Datenstrom erzeugen. | |
ToQuery(String, String, EventShape, StreamEventOrder) | Erstellt eine Abfrage aus dem Datenstrom mit einer nicht gebundenen Ausgabe. Alle Eingaben für die Abfrage müssen an Adapter, Sequenzen oder andere Abfragen gebunden werden. Die Ausgabe der Abfrage kann nur durch dynamische Abfragezusammenstellung genutzt werden. Die Anwendung, in der diese Abfrage ausgeführt wird, wird durch die Definition des Datenstroms impliziert. | |
ToQuery(Application, String, String, EventShape, StreamEventOrder) | Erstellt eine Abfrage aus dem Datenstrom mit einer nicht gebundenen Ausgabe, die in der angegebenen Anwendung ausgeführt wird. Alle Eingaben für die Abfrage müssen an Adapter, Sequenzen oder andere Abfragen gebunden werden. Die Ausgabe der Abfrage kann nur durch dynamische Abfragezusammenstellung genutzt werden. | |
ToQuery(String, String, Type, Object, EventShape, StreamEventOrder) | Erstellt eine Abfrage aus dem Datenstrom, die an einen Ausgabeadapter gebunden wird. Der Ausgabeadapter wird vom Typ der Adapterfactory und vom Konfigurationsobjekt angegeben. Die Anwendung, in der diese Abfrage ausgeführt wird, wird durch die Definition des Datenstroms impliziert. | |
ToQuery(String, String, Type, Object, EventShape, StreamEventOrder, Boolean) | Erstellt eine Abfrage aus dem Datenstrom, die an einen Ausgabeadapter gebunden wird. Der Ausgabeadapter wird vom Typ der Adapterfactory und vom Konfigurationsobjekt angegeben. Die Anwendung, in der diese Abfrage ausgeführt wird, wird durch die Definition des Datenstroms impliziert. Die Abfrage kann als stabil festgelegt werden. | |
ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder) | Erstellt eine Abfrage aus dem Datenstrom, die an einen Ausgabeadapter gebunden ist, der in der angegebenen Anwendung ausgeführt wird. Der Ausgabeadapter wird vom Typ der Adapterfactory und vom Konfigurationsobjekt angegeben. | |
ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder, Boolean) | Erstellt eine Abfrage aus dem Datenstrom, die an einen Ausgabeadapter gebunden ist, der in der angegebenen Anwendung ausgeführt wird. Der Ausgabeadapter wird vom Typ der Adapterfactory und vom Konfigurationsobjekt angegeben. Die Abfrage kann als stabil festgelegt werden. | |
ToString | (Geerbt von Object.) |
Zum Anfang
Erweiterungsmethoden
Name | Beschreibung | |
---|---|---|
AlterEventDuration< (Of < <' (TPayload> ) > > ) | Ändert die Dauer der Eingabeereignisse. Diese Methode ändert nicht die Startzeit eines Ereignisses. (Definiert von CepStream.) | |
AlterEventLifetime< (Of < <' (TPayload> ) > > ) | Ändert die Lebensdauer der Ereignisse im Datenstrom. Diese Methode kann sowohl die Startzeit als auch die Endzeit eines Ereignisses ändern. (Definiert von CepStream.) | |
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. (Definiert von CepStream.) | |
CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32) | Überladen 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. (Definiert von CepStream.) | |
CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, CountWindowOutputPolicy) | Überladen 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. (Definiert von CepStream.) | |
CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, WindowInputPolicy, CountWindowOutputPolicy) | Überladen 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. (Definiert von CepStream.) | |
GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > )) | Überladen Partitioniert den Eingabedatenstrom nach dem angegebenen Gruppierungsschlüssel. (Definiert von CepStream.) | |
GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) | Überladen Gruppiert den Quelldatenstrom nach den angegebenen Schlüsselauswahlfunktionen und projiziert die Ergebnisse mithilfe der Elementauswahlfunktion. (Definiert von CepStream.) | |
HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan) | Überladen 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. (Definiert von CepStream.) | |
HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime) | Überladen 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. (Definiert von CepStream.) | |
HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, HoppingWindowOutputPolicy) | Überladen 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. (Definiert von CepStream.) | |
HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) | Überladen 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. (Definiert von CepStream.) | |
HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) | Überladen 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. (Definiert von CepStream.) | |
HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) | Überladen 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. (Definiert von CepStream.) | |
IsEmpty< (Of < <' (TPayload> ) > > ) | Funktion, die in Abfragen verwendet wird, um einen Left Anti Semi Join (LASJ) anzugeben. (Definiert von CepStream.) | |
Join< (Of < <' (TOuter, TInner, TKey, TResult> ) > > ) | Verknüpft die Ereignisse vom äußeren Datenstrom mit Ereignissen vom inneren Datenstrom anhand des vorhandenen Joinschlüssels. (Definiert von CepStream.) | |
Select< (Of < <' (TPayload, TResult> ) > > ) | Projiziert Ereignisse aus einem Eingabedatenstrom mithilfe eines Projektionsausdrucks. (Definiert von CepStream.) | |
SelectMany< (Of < <' (TInput, TBind, TResult> ) > > ) | Erzeugt auf der Grundlage des Kreuzjoins von zwei Eingabedatenströmen einen Datenstrom. (Definiert von CepStream.) | |
ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > )) | Überladen Verlagert die Ereignisstartzeit auf einen neuen Zeitstempel, ohne die Lebensdauer zu ändern. (Definiert von CepStream.) | |
ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > )) | Überladen Verlagert die Ereignisstartzeit um die angegebene Zeitspanne, ohne die Lebensdauer zu ändern. (Definiert von CepStream.) | |
SnapshotWindow< (Of < <' (TPayload> ) > > )() () () () | Überladen 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. (Definiert von CepStream.) | |
SnapshotWindow< (Of < <' (TPayload> ) > > )(SnapshotWindowOutputPolicy) | Überladen 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. (Definiert von CepStream.) | |
SnapshotWindow< (Of < <' (TPayload> ) > > )(WindowInputPolicy, SnapshotWindowOutputPolicy) | Überladen 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. (Definiert von CepStream.) | |
ToEdgeEnumerable< (Of < <' (TPayload> ) > > )() () () () | Überladen Konvertiert einen CepStream von Edge-Ereignissen in eine Ereignissenke, die die IEnumerable-Schnittstelle implementiert. Die Reihenfolge von Ereignissen ist FullyOrdered. (Definiert von CepStream.) | |
ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) | Überladen Konvertiert einen CepStream von Edge-Ereignissen mit der angegebenen Ereignisreihenfolge in eine Ereignissenke, die die IEnumerable-Schnittstelle implementiert. (Definiert von CepStream.) | |
ToEdgeObservable< (Of < <' (TPayload> ) > > )() () () () | Überladen Konvertiert einen CepStream von Edge-Ereignissen in eine Ereignissenke, die die IObservable-Schnittstelle implementiert. Die Reihenfolge von Ereignissen ist FullyOrdered. (Definiert von ObservableCepStream.) | |
ToEdgeObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) | Überladen Konvertiert einen CepStream von Edge-Ereignissen mit der angegebenen Ereignisreihenfolge in eine Ereignissenke, die die IObservable-Schnittstelle implementiert. (Definiert von ObservableCepStream.) | |
ToEnumerable< (Of < <' (TPayload> ) > > )() () () () | Überladen Konvertiert einen Datenstrom von Ereignissen in eine Enumerable-Ausgabe durch Entfernen von Ereignisheadern und Verwerfen von CTI-Ereignissen. (Definiert von CepStream.) | |
ToEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) | Überladen Konvertiert einen Datenstrom von Ereignissen in eine Enumerable-Ausgabe mit der angegebenen Ereignisreihenfolge durch Entfernen von Ereignisheadern und Verwerfen von CTI-Ereignissen. (Definiert von CepStream.) | |
ToIntervalEnumerable< (Of < <' (TPayload> ) > > )() () () () | Überladen Konvertiert einen CepStream von Intervallereignissen in eine Ereignissenke, die die IEnumerable-Schnittstelle implementiert. Die Reihenfolge von Ereignissen ist FullyOrdered. (Definiert von CepStream.) | |
ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) | Überladen Konvertiert einen CepStream von Intervallereignissen mit der angegebenen Ereignisreihenfolge in eine Ereignissenke, die die IEnumerable-Schnittstelle implementiert. (Definiert von CepStream.) | |
ToIntervalObservable< (Of < <' (TPayload> ) > > )() () () () | Überladen Konvertiert einen CepStream von Intervallereignissen in eine Ereignissenke, die die IObservable-Schnittstelle implementiert. Die Reihenfolge von Ereignissen ist FullyOrdered. (Definiert von ObservableCepStream.) | |
ToIntervalObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) | Überladen Konvertiert einen CepStream von Intervallereignissen mit der angegebenen Ereignisreihenfolge in eine Ereignissenke, die die IObservable-Schnittstelle implementiert. (Definiert von ObservableCepStream.) | |
ToObservable< (Of < <' (TPayload> ) > > )() () () () | Überladen Konvertiert einen Datenstrom von Ereignissen in eine Observable-Ausgabe durch Entfernen von Ereignisheadern und Verwerfen von CTI-Ereignissen. (Definiert von ObservableCepStream.) | |
ToObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) | Überladen Konvertiert einen Datenstrom von Ereignissen in eine Observable-Ausgabe mit der angegebenen Ereignisreihenfolge durch Entfernen von Ereignisheadern und Verwerfen von CTI-Ereignissen. (Definiert von ObservableCepStream.) | |
ToPointEnumerable< (Of < <' (TPayload> ) > > )() () () () | Überladen Konvertiert einen CepStream von Punktereignissen in eine Ereignissenke, die die IEnumerable-Schnittstelle implementiert. Die Reihenfolge von Ereignissen ist FullyOrdered. (Definiert von CepStream.) | |
ToPointEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) | Überladen Konvertiert einen CepStream von Punktereignissen mit der angegebenen Ereignisreihenfolge in eine Ereignissenke, die die IEnumerable-Schnittstelle implementiert. (Definiert von CepStream.) | |
ToPointEventStream< (Of < <' (TPayload> ) > > ) | Ändert die Ereignisse in einem Eingabedatenstrom in Punktereignisse, indem nur die Ereignisstartzeiten beibehalten werden. (Definiert von CepStream.) | |
ToPointObservable< (Of < <' (TPayload> ) > > )() () () () | Überladen Konvertiert einen CepStream von Punktereignissen in eine Ereignissenke, die die IObservable-Schnittstelle implementiert. Die Reihenfolge von Ereignissen ist FullyOrdered. (Definiert von ObservableCepStream.) | |
ToPointObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) | Überladen Konvertiert einen CepStream von Punktereignissen mit der angegebenen Ereignisreihenfolge in eine Ereignissenke, die die IObservable-Schnittstelle implementiert. (Definiert von ObservableCepStream.) | |
TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan) | Überladen 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. (Definiert von CepStream.) | |
TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime) | Überladen 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. (Definiert von CepStream.) | |
TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, HoppingWindowOutputPolicy) | Überladen 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. (Definiert von CepStream.) | |
TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, HoppingWindowOutputPolicy) | Überladen 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. (Definiert von CepStream.) | |
TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) | Überladen 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. (Definiert von CepStream.) | |
TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) | Überladen 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. (Definiert von CepStream.) | |
Union< (Of < <' (TPayload> ) > > ) | Vereinigt zwei Datenströme als Union zu einem Datenstrom. (Definiert von CepStream.) | |
Where< (Of < <' (TPayload> ) > > ) | Filtert Ereignisse aus einem Eingabedatenstrom mithilfe einer angegebenen Filterfunktion. (Definiert von CepStream.) |
Zum Anfang
Hinweise
Vor dem Schreiben einer CEP-Abfrage müssen Sie die geeignete Datenstromdefinition bereitstellen. Diese Klasse bietet verschiedene Methoden zum Erstellen eines CepStream-Objekts.
Threadsicherheit
Alle öffentlichen static (Shared in Visual Basic)-Elemente dieses Typs sind Threadsicher. Für Instanzelemente wird die Threadsicherheit nicht gewährleistet.