SnapshotWindow(TPayload)-Methode (CepStream(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.
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)
Syntax
public static CepWindowStream<CepWindow<TPayload>> SnapshotWindow<TPayload>(
this CepStream<TPayload> source,
WindowInputPolicy inputPolicy,
SnapshotWindowOutputPolicy outputPolicy
)
Typparameter
- TPayload
Der Typ der Eingabeereignisnutzlast.
Parameter
- source
Typ: Microsoft.ComplexEventProcessing.Linq. . :: . .CepStream< (Of < ( <'TPayload> ) > ) >
CepStream, auf den der Momentaufnahmevorgang angewendet wird.
- inputPolicy
Typ: Microsoft.ComplexEventProcessing.Linq. . :: . .WindowInputPolicy
Gibt an, wie Ereignisse geändert werden, bevor sie in den Fenstervorgang eingefügt werden.
- outputPolicy
Typ: Microsoft.ComplexEventProcessing.Linq. . :: . .SnapshotWindowOutputPolicy
Gibt an, wie Ausgabeereignisse des Fenstervorgangs geändert werden, bevor sie zurück in den Datenstrom eingefügt werden.
Rückgabewert
Typ: Microsoft.ComplexEventProcessing.Linq. . :: . .CepWindowStream< (Of < ( <'CepWindow< (Of < ( <'TPayload> ) > ) >> ) > ) >
Ein Fensterdatenstrom, auf den Aggregate, Rangfolgen oder benutzerdefinierte Vorgänge angewendet werden können.
Hinweis zur Verwendung
In Visual Basic und C# können Sie die Methode als Instanzenmethode für jedes Objekt vom Typ CepStream< (Of < ( <'TPayload> ) > ) > aufrufen. Wenn Sie Instanzmethodensyntax zum Aufruf dieser Methode verwenden, vernachlässigen Sie den ersten Parameter. Weitere Informationen finden Sie unter https://msdn.microsoft.com/de-de/library/bb384936(v=sql.105) oder https://msdn.microsoft.com/de-de/library/bb383977(v=sql.105).
Hinweise
Weitere Informationen zu Fenstern finden Sie unter Verwenden von Ereignisfenstern und Momentaufnahmefenster.
Beispiele
var snapshotAgg = from w in inputStream.SnapshotWindow(WindowInputPolicy.ClipToWindow,
SnapshotWindowOutputPolicy.Clip)
select new { sum = w.Sum(e => e.i) };