Méthode ToStream(TPayload) (Query)
Crée un flux d'entrée lié au flux des événements de sortie d'une requête existante.
Espace de noms : Microsoft.ComplexEventProcessing
Assembly : Microsoft.ComplexEventProcessing (en Microsoft.ComplexEventProcessing.dll)
Syntaxe
public static CepStream<TPayload> ToStream<TPayload>(
this Query query
)
Paramètres de type
- TPayload
Type de la charge utile du nouveau flux.
Paramètres
- query
Type : Microsoft.ComplexEventProcessing. . :: . .Query
Requête existante.
Valeur de retour
Type : Microsoft.ComplexEventProcessing.Linq. . :: . .CepStream< (Of < ( <'TPayload> ) > ) >
Instance de la classe CepStream qui peut être utilisée pour créer des requêtes.
Remarque relative à l'utilisation
En Visual Basic et C#, vous pouvez appeler cette méthode comme méthode d'instance sur tout objet de type Query. Lorsque vous utilisez la syntaxe de la méthode d'instance pour appeler cette méthode, omettez le premier paramètre. Pour plus d'informations, consultez https://msdn.microsoft.com/fr-fr/library/bb384936(v=sql.105) ou https://msdn.microsoft.com/fr-fr/library/bb383977(v=sql.105).
Exemples
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);