CepStream<TPayload>-Klasse
Stellt einen Datenstrom von Ereignissen eines beliebigen benutzerdefinierten Nutzlasttyps dar.
Vererbungshierarchie
System.Object
Microsoft.ComplexEventProcessing.Linq.CepStream<TPayload>
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)
Syntax
'Declaration
Public NotInheritable Class CepStream(Of TPayload)
'Usage
Dim instance As CepStream(Of TPayload)
public sealed class CepStream<TPayload>
generic<typename TPayload>
public ref class CepStream sealed
[<SealedAttribute>]
type CepStream<'TPayload> = class end
JScript unterstützt keine generischen Typen und Methoden.
Typparameter
- TPayload
Der Nutzlasttyp des Ereignisses im Datenstrom.
Der CepStream<TPayload>-Typ macht folgende Elemente verfügbar.
Methoden
| Name | Beschreibung | |
|---|---|---|
.gif "Öffentliche Methode") .gif "Statisches Element") |
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. |
|
GetHashCode | (Geerbt von Object.) |
|
GetType | (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 | |
|---|---|---|
.gif "Öffentliche Erweiterungsmethode") |
AlterEventDuration<TPayload> | Ändert die Dauer der Eingabeereignisse.Diese Methode ändert nicht die Startzeit eines Ereignisses. (Definiert von CepStream.) |
|
AlterEventLifetime<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<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<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<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<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<TPayload, TGroupingKey>(Expression<Func<TPayload, TGroupingKey>>) | Überladen Partitioniert den Eingabedatenstrom nach dem angegebenen Gruppierungsschlüssel. (Definiert von CepStream.) |
|
GroupBy<TPayload, TGroupingKey, TResult>(Expression<Func<TPayload, TGroupingKey>>, Expression<Func<TPayload, TResult>>) | Überladen Gruppiert den Quelldatenstrom nach den angegebenen Schlüsselauswahlfunktionen und projiziert die Ergebnisse mithilfe der Elementauswahlfunktion. (Definiert von CepStream.) |
|
HoppingWindow<TPayload>(TimeSpan, TimeSpan) | Überladen Transformiert anhand der Standardausgaberichtlinie einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. (Definiert von CepStream.) |
|
HoppingWindow<TPayload>(TimeSpan, TimeSpan, DateTime) | Überladen Transformiert anhand der Standardausgaberichtlinie einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. (Definiert von CepStream.) |
|
HoppingWindow<TPayload>(TimeSpan, TimeSpan, HoppingWindowOutputPolicy) | Überladen Transformiert anhand der Standardausgaberichtlinie einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. (Definiert von CepStream.) |
|
HoppingWindow<TPayload>(TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) | Überladen Transformiert einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. (Definiert von CepStream.) |
|
HoppingWindow<TPayload>(TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) | Überladen Transformiert anhand der Standardausgaberichtlinie einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. (Definiert von CepStream.) |
|
HoppingWindow<TPayload>(TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) | Überladen Das Fenster wird durch konstante Zeitintervalle für die Fenstergröße und die Abschnittgröße definiert. (Definiert von CepStream.) |
|
IsEmpty<TPayload> | Führt eine LASJ (Left Anti-Semi-Join)-Abfrage des angegebenen Datenstroms aus. (Definiert von CepStream.) |
|
Join<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<TPayload, TResult> | Projiziert Ereignisse aus einem Eingabedatenstrom mithilfe eines Projektionsausdrucks. (Definiert von CepStream.) |
|
SelectMany<TInput, TBind, TResult> | Erzeugt auf der Grundlage des Kreuzjoins von zwei Eingabedatenströmen einen Datenstrom. (Definiert von CepStream.) |
|
ShiftEventTime<TPayload>(Expression<Func<CepEvent, DateTime>>) | Überladen Verschiebt die Ereigniszeiten nach dem vom shiftExpr-Parameter angegebenen Wert.Die Methode ändert nicht die Lebensdauer von Ereignissen. (Definiert von CepStream.) |
|
ShiftEventTime<TPayload>(Expression<Func<CepEvent, TimeSpan>>) | Überladen Verschiebt die Ereigniszeiten um die vom shiftExpr-Parameter angegebene Zeit.Der zurückgegebene Wert kann positiv oder negativ sein. (Definiert von CepStream.) |
|
SnapshotWindow<TPayload>() | Überladen Transformiert anhand der Standardausgaberichtlinie einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. (Definiert von CepStream.) |
|
SnapshotWindow<TPayload>(SnapshotWindowOutputPolicy) | Überladen Transformiert einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. (Definiert von CepStream.) |
|
SnapshotWindow<TPayload>(WindowInputPolicy, SnapshotWindowOutputPolicy) | Überladen Transformiert einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. (Definiert von CepStream.) |
|
ToEdgeEnumerable<TPayload>() | Überladen Konvertiert einen CepStream von Edge-Ereignissen in eine Ereignissenke, die die IEnumerable-Schnittstelle implementiert. (Definiert von CepStream.) |
|
ToEdgeEnumerable<TPayload>(StreamEventOrder) | Überladen Konvertiert einen CepStream von Edge-Ereignissen in eine Ereignissenke, die die IEnumerable-Schnittstelle implementiert. (Definiert von CepStream.) |
|
ToEdgeObservable<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<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<TPayload>() | Überladen Konvertiert einen Datenstrom von Ereignissen in eine Enumerable-Ausgabe durch Entfernen von Ereignisheadern und Verwerfen von CTI-Ereignissen. (Definiert von CepStream.) |
|
ToEnumerable<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<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<TPayload>(StreamEventOrder) | Überladen Konvertiert einen CepStream von Intervallereignissen mit der angegebenen Ereignisreihenfolge in eine Ereignissenke, die die IEnumerable-Schnittstelle implementiert. (Definiert von CepStream.) |
|
ToIntervalObservable<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<TPayload>(StreamEventOrder) | Überladen Konvertiert einen CepStream von Intervallereignissen mit der angegebenen Ereignisreihenfolge in eine Ereignissenke, die die IObservable-Schnittstelle implementiert. (Definiert von ObservableCepStream.) |
|
ToObservable<TPayload>() | Überladen Konvertiert einen Datenstrom von Ereignissen in eine Observable-Ausgabe durch Entfernen von Ereignisheadern und Verwerfen von CTI-Ereignissen. (Definiert von ObservableCepStream.) |
|
ToObservable<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<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<TPayload>(StreamEventOrder) | Überladen Konvertiert einen CepStream von Punktereignissen mit der angegebenen Ereignisreihenfolge in eine Ereignissenke, die die IEnumerable-Schnittstelle implementiert. (Definiert von CepStream.) |
|
ToPointEventStream<TPayload> | Ändert die Ereignisse in einem Eingabedatenstrom in Punktereignisse, indem nur die Ereignisstartzeiten beibehalten werden. (Definiert von CepStream.) |
|
ToPointObservable<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<TPayload>(StreamEventOrder) | Überladen Konvertiert einen CepStream von Punktereignissen mit der angegebenen Ereignisreihenfolge in eine Ereignissenke, die die IObservable-Schnittstelle implementiert. (Definiert von ObservableCepStream.) |
|
TumblingWindow<TPayload>(TimeSpan) | Überladen Transformiert anhand der Standardausgaberichtlinie einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. (Definiert von CepStream.) |
|
TumblingWindow<TPayload>(TimeSpan, DateTime) | Überladen Transformiert anhand der Standardausgaberichtlinie einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. (Definiert von CepStream.) |
|
TumblingWindow<TPayload>(TimeSpan, HoppingWindowOutputPolicy) | Überladen Transformiert einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. (Definiert von CepStream.) |
|
TumblingWindow<TPayload>(TimeSpan, DateTime, HoppingWindowOutputPolicy) | Überladen Transformiert einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. (Definiert von CepStream.) |
|
TumblingWindow<TPayload>(TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) | Überladen Transformiert einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. (Definiert von CepStream.) |
|
TumblingWindow<TPayload>(TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) | Überladen Transformiert einen Datenstrom in einen Fensterdatenstrom, wobei jedes Element ein CepWindow ist. (Definiert von CepStream.) |
|
Union<TPayload> | Vereinigt zwei Datenströme als Union zu einem Datenstrom. (Definiert von CepStream.) |
|
Where<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.