ToStream(TPayload)-Methode (Query)
Erstellt einen neuen Eingabedatenstrom, der an den Ausgabeereignis-Datenstrom einer vorhandenen Abfrage gebunden ist.
Namespace: Microsoft.ComplexEventProcessing
Assembly: Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)
Syntax
public static CepStream<TPayload> ToStream<TPayload>(
this Query query
)
Typparameter
- TPayload
Der Typ der Nutzlast für den neuen Datenstrom.
Parameter
- query
Typ: Microsoft.ComplexEventProcessing. . :: . .Query
Die vorhandene Abfrage.
Rückgabewert
Typ: Microsoft.ComplexEventProcessing.Linq. . :: . .CepStream< (Of < ( <'TPayload> ) > ) >
Eine Instanz der CepStream-Klasse, die verwendet werden kann, um neue Abfragen zu erstellen.
Hinweis zur Verwendung
In Visual Basic und C# können Sie die Methode als Instanzenmethode für jedes Objekt vom Typ Query 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).
Beispiele
Application myApp = server.CreateApplication("MyApp");
var inputstream = CepStream{TPayload}.Create("inputStream", typeof(InputFactory), inConf, EventShape.Point);
var filtered = from e in inputstream
where e.Value > 25
select e;
var query = filtered.ToQuery(myApp, "filterQuery", "", typeof(OutputFactory), outConf, EventShape.Point, StreamEventOrder.FullyOrdered);
var filteredStream = query.ToStream{TPayload}();
var validated = from e in filteredStream
select new
{
SourceId = e.SourceId,
Value = e.Value,
Status = e.Value > 75 ? false : true
};
var validationQuery = validated.ToQuery("validationQuery", "", typeof(OutputFactory), outConf2, EventShape.Point, StreamEventOrder.FullyOrdered);