ToStream(TPayload) Método (Query)
Crea un nuevo flujo de entrada enlazado al flujo de eventos de salida de una consulta existente.
Espacio de nombres: Microsoft.ComplexEventProcessing
Ensamblado: Microsoft.ComplexEventProcessing (en Microsoft.ComplexEventProcessing.dll)
Sintaxis
public static CepStream<TPayload> ToStream<TPayload>(
this Query query
)
Parámetros de tipo
- TPayload
Tipo de la carga para el nuevo flujo.
Parámetros
- query
Tipo: Microsoft.ComplexEventProcessing. . :: . .Query
Consulta existente.
Valor devuelto
Tipo: Microsoft.ComplexEventProcessing.Linq. . :: . .CepStream< (Of < ( <'TPayload> ) > ) >
Instancia de la clase CepStream que se puede utilizar para crear nuevas consultas.
Nota de uso
En Visual Basic y C#, puede llamar a este método como un método de instancia en cualquier objeto del tipo Query. Cuando utilice la sintaxis del método de instancia para llamar a este método, sáltese este parámetro primero. Para obtener más información, vea https://msdn.microsoft.com/es-es/library/bb384936(v=sql.105) o https://msdn.microsoft.com/es-es/library/bb383977(v=sql.105).
Ejemplos
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);