StreamInsight LINQ 사용
데이터가 StreamInsight 서버로 전달되면 데이터에 대해 계산을 계속 수행할 수 있습니다. 즉, 고정 쿼리는 서버로 삽입되는 이벤트를 처리한 다음 처리된 출력 이벤트를 내보냅니다. 이러한 고정 쿼리는 언어 프레임워크 LINQ로 작성됩니다. LINQ는 C# 등의 호스트 언어로 완벽하게 통합되어 데이터 집합에 대한 선언적 쿼리를 표현하는 데 사용되는 메커니즘입니다. 현재 릴리스에서 StreamInsight는 호스트 언어로 C#만 지원합니다. 이 프레임워크가 StreamInsight 플랫폼용으로 조정되어 StreamInsight 서버와 C#이 긴밀하게 통합됩니다. 이 섹션의 항목에서는 이 플랫폼에서 지원되는 이벤트에 대한 여러 계산 작업과 StreamInsight LINQ 쿼리를 통해 이러한 작업을 지정하는 방법을 보여 줍니다.
참고
StreamInsight 버전 2.0 및 이전 버전에서는 CepStream<> 인터페이스를 사용하여 임시 스트림이 구현됩니다. CepStream<> 인터페이스가 계속 지원되지만 버전 2.1 이상 버전에서는 임시 스트림이 IQStreamable<> 인터페이스를 통해 구현되며 StreamInsight LINQ를 사용하여 처리될 수 있습니다. IQStreamable<>을 통해 작성된 임시 쿼리의 구문은 기존 CepStream<> 기반 LINQ 제공자의 구문과 일치하지만 IQStreamable<> 인터페이스의 새 기능을 활용할 수 있도록 약간 변경되었습니다. 이 섹션에서는 IQStreamable<> 및 CepStream<> 인터페이스 간의 차이점을 식별합니다.
StreamInsight용 LINQ 쿼리 작성에 대한 자세한 지침은 Hitchhiker의 StreamInsight 쿼리 가이드를 참조하십시오.
섹션 내용
프로젝션
필터링
조인
통합
그룹 및 적용
타임스탬프 수정
사용자 정의 함수(StreamInsight)
사용자 정의 스트림 연산자
이벤트 창 사용
개수 창
도약 창
스냅숏 창
집계
TopK
사용자 정의 집계 및 연산자