ToStream(TPayload) 메서드 (Query)
기존 쿼리의 출력 이벤트 스트림에 바인딩되는 새 입력 스트림을 만듭니다.
네임스페이스: Microsoft.ComplexEventProcessing
어셈블리: Microsoft.ComplexEventProcessing(Microsoft.ComplexEventProcessing.dll)
구문
public static CepStream<TPayload> ToStream<TPayload>(
this Query query
)
유형 매개 변수
- TPayload
새 스트림의 페이로드 유형입니다.
매개 변수
- query
유형: Microsoft.ComplexEventProcessing. . :: . .Query
기존 쿼리입니다.
반환 값
유형: Microsoft.ComplexEventProcessing.Linq. . :: . .CepStream< (Of < ( <'TPayload> ) > ) >
새 쿼리를 만드는 데 사용할 수 있는 CepStream 클래스의 인스턴스입니다.
사용법 정보
Visual Basic 및 C#에서는 이 메서드를 Query 유형의 모든 개체에 대한 인스턴스 메서드로 호출할 수 있습니다. 인스턴스 메서드 구문을 사용하여 이 메서드를 호출하는 경우 첫 번째 매개 변수를 생략합니다. 자세한 내용은 https://msdn.microsoft.com/ko-kr/library/bb384936(v=sql.105) 또는 https://msdn.microsoft.com/ko-kr/library/bb383977(v=sql.105)을(를) 참조하십시오.
예
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);