다음을 통해 공유

CepStream 클래스

  • 아티클

CEP 이벤트 스트림에 대해 LINQ 쿼리를 작성하는 데 사용되는 확장 메서드를 제공합니다.

상속 계층

System. . :: . .Object
  Microsoft.ComplexEventProcessing.Linq..::..CepStream

네임스페이스:  Microsoft.ComplexEventProcessing.Linq
어셈블리:  Microsoft.ComplexEventProcessing(Microsoft.ComplexEventProcessing.dll)

구문

public static class CepStream

CepStream 유형에서 다음 멤버를 표시합니다.

메서드

  이름 설명
공용 메서드정적 멤버 AlterEventDuration< (Of < <' (TPayload> ) > > ) 입력 이벤트의 기간을 변경합니다. 이 메서드는 이벤트 시작 시간은 변경하지 않습니다.
공용 메서드정적 멤버 AlterEventLifetime< (Of < <' (TPayload> ) > > ) 스트림의 이벤트 수명을 변경합니다. 이 메서드는 이벤트 시작 시간과 종료 시간을 모두 변경할 수 있습니다.
공용 메서드정적 멤버 ClipEventDuration< (Of < <' (TSource, TClip> ) > > ) sourceStream의 이벤트 수명을 clipStream에서 matchExpression과 일치하는 다음 해당 이벤트의 시작 시간으로 단축합니다.
공용 메서드정적 멤버 CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32) 기본 출력 정책을 사용하여 지정된 수의 고유한 이벤트 시작 시간을 기준으로 하여 입력 스트림 이벤트를 창으로 그룹화합니다. 다른 시간에 시작되는 새 이벤트가 도착하면 창이 옆으로 이동(sliding)됩니다.
공용 메서드정적 멤버 CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32, CountWindowOutputPolicy) 지정된 수의 고유한 이벤트 시작 시간을 기준으로 하여 입력 스트림 이벤트를 창으로 그룹화합니다. 다른 시간에 시작되는 새 이벤트가 도착하면 창이 옆으로 이동(sliding)됩니다.
공용 메서드정적 멤버 CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32, WindowInputPolicy, CountWindowOutputPolicy) 지정된 수의 고유한 이벤트 시작 시간을 기준으로 하여 입력 스트림 이벤트를 창으로 그룹화합니다. 다른 시간에 시작되는 새 이벤트가 도착하면 창이 옆으로 이동(sliding)됩니다.
공용 메서드정적 멤버 GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > )) 지정한 그룹화 키로 입력 스트림을 분할합니다.
공용 메서드정적 멤버 GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) 요소 선택기 함수를 사용하여 지정한 키 선택기 함수 및 프로젝트 결과로 원본 스트림을 그룹화합니다.
공용 메서드정적 멤버 HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan) 기본 출력 정책을 사용하여 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 창은 상수 창 크기와 도약 크기 시간 범위로 정의됩니다.
공용 메서드정적 멤버 HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, HoppingWindowOutputPolicy) 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 창은 상수 창 크기와 도약 크기 시간 범위로 정의됩니다.
공용 메서드정적 멤버 HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime) 기본 출력 정책을 사용하여 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 창은 상수 창 크기와 도약 크기 시간 범위로 정의됩니다. 맞춤 시간을 창 시작 지점에 대한 참조로 제공할 수도 있습니다.
공용 메서드정적 멤버 HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 창은 상수 창 크기와 도약 크기 시간 범위로 정의됩니다. 맞춤 시간을 창 시작 지점에 대한 참조로 제공할 수도 있습니다.
공용 메서드정적 멤버 HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 창은 상수 창 크기와 도약 크기 시간 범위로 정의됩니다. 맞춤 시간을 창 시작 지점에 대한 참조로 제공할 수도 있습니다.
공용 메서드정적 멤버 HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) 창은 상수 창 크기와 도약 크기 시간 범위로 정의됩니다. 맞춤 시간을 창 시작 지점에 대한 참조로 제공할 수도 있습니다.
공용 메서드정적 멤버 IsEmpty< (Of < <' (TPayload> ) > > ) 쿼리에서 LASJ(Left Anti Semi Join)를 나타내는 데 사용되는 함수입니다.
공용 메서드정적 멤버 Join< (Of < <' (TOuter, TInner, TKey, TResult> ) > > ) 외부 스트림의 이벤트를 지정된 조인 키에서 내부 스트림의 이벤트와 조인합니다.
공용 메서드정적 멤버 OrderBy< (Of < <' (TPayload, TOrderKey> ) > > ) 입력 스트림을 rankSelector로 정렬합니다.
공용 메서드정적 멤버 OrderByDescending< (Of < <' (TPayload, TOrderKey> ) > > ) rankSelector를 기준으로 입력 스트림을 내림차순으로 정렬합니다.
공용 메서드정적 멤버 Scan< (Of < <' (TInputEvent, TInputPayload, TOutputPayload> ) > > ) 사용자 정의 스트림 연산자를 사용하여 입력 스트림을 검색합니다.
공용 메서드정적 멤버 Select< (Of < <' (TInput, TResult> ) > > )(CepOrderedStream< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TResult> ) > > )> ) > > )) 정렬된 스트림을 지정하면 이 메서드는 순위에 사용할 수 있는 정렬된 스트림을 생성합니다.
공용 메서드정적 멤버 Select< (Of < <' (TPayload, TResult> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) 프로젝션 식을 사용하여 입력 스트림에서 이벤트를 프로젝션합니다.
공용 메서드정적 멤버 Select< (Of < <' (TInput, TResult> ) > > )(CepWindowStream< (Of < <' (CepWindow< (Of < <' (TInput> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), TResult> ) > > )> ) > > )) 지정된 매핑 식을 기준으로 스트림에 창 스트림을 매핑합니다.
공용 메서드정적 멤버 Select< (Of < <' (TInput, TOutput> ) > > )(ICepEnumerable< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TOutput> ) > > )> ) > > )) 열거 가능한 입력 스트림의 각 이벤트를 새 이벤트로 프로젝션합니다.
공용 메서드정적 멤버 SelectMany< (Of < <' (TInput, TResult> ) > > )(CepWindowStream< (Of < <' (CepWindow< (Of < <' (TInput> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), CepWindow< (Of < <' (TInput> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), TInput, TResult> ) > > )> ) > > )) 기간 이동 스트림에 대한 정렬 작업을 지원합니다.
공용 메서드정적 멤버 SelectMany< (Of < <' (TInput, TBind, TResult> ) > > )(CepStream< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepStream< (Of < <' (TInput> ) > > ), CepStream< (Of < <' (TBind> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TBind, TResult> ) > > )> ) > > )) 두 입력 스트림의 크로스 조인을 기준으로 스트림을 생성합니다.
공용 메서드정적 멤버 SelectMany< (Of < <' (TInput, TGroupingKey, TBind, TResult> ) > > )(CepGroupingStreams< (Of < <' (TInput, TGroupingKey> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepStream< (Of < <' (TInput> ) > > ), CepStream< (Of < <' (TBind> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (IKey< (Of < <' (TGroupingKey> ) > > ), TBind, TResult> ) > > )> ) > > )) 그룹 및 적용 내에 쿼리 논리를 추가할 수 있도록 지원합니다.
공용 메서드정적 멤버 SelectMany< (Of < <' (TInput, TGroupingKey, TBind, TResult> ) > > )(CepGroupingStreams< (Of < <' (TInput, TGroupingKey> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepStream< (Of < <' (TInput> ) > > ), CepWindowStream< (Of < <' (TBind> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (IKey< (Of < <' (TGroupingKey> ) > > ), TBind, TResult> ) > > )> ) > > )) 두 입력 스트림의 크로스 조인을 기준으로 스트림을 생성합니다.
공용 메서드정적 멤버 ShiftEventTime< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > )) 수명은 변경하지 않고 이벤트 시작 시간을 새 타임스탬프로 이동합니다.
공용 메서드정적 멤버 ShiftEventTime< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > )) 수명은 변경하지 않고 지정된 시간 범위에 따라 이벤트 시작 시간을 이동합니다.
공용 메서드정적 멤버 SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) 기본 출력 정책을 사용하여 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 여기서 각 창은 스트림에서 가장 근접한 이벤트 끝점으로 정의되는 스냅숏 창입니다.
공용 메서드정적 멤버 SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), SnapshotWindowOutputPolicy) 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 여기서 각 창은 스트림에서 가장 근접한 이벤트 끝점으로 정의되는 스냅숏 창입니다.
공용 메서드정적 멤버 SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), WindowInputPolicy, SnapshotWindowOutputPolicy) 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 여기서 각 창은 스트림에서 가장 근접한 이벤트 끝점으로 정의되는 스냅숏 창입니다.
공용 메서드정적 멤버 Take< (Of < <' (TPayload> ) > > )(CepOrderedStream< (Of < <' (TPayload> ) > > ), UInt32) 정렬된 스트림을 지정하면 각 창에서 지정된 수의 이벤트를 가져옵니다.
공용 메서드정적 멤버 Take< (Of < <' (TInput, TResult> ) > > )(CepOrderedStream< (Of < <' (TInput> ) > > ), UInt32, Expression< (Of < <' (Func< (Of < <' (CepRankedEvent< (Of < <' (TInput> ) > > ), TResult> ) > > )> ) > > )) 각 창에서 지정된 수의 이벤트를 가져오며 지정된 식도 계산합니다. 순위를 Take()의 결과에 프로젝션하려는 경우에 사용됩니다.
공용 메서드정적 멤버 ThenBy< (Of < <' (TPayload, TOrderKey> ) > > ) 정렬된 스트림을 rankSelector로 표시되는 다른 orderKey로 정렬합니다.
공용 메서드정적 멤버 ThenByDescending< (Of < <' (TPayload, TOrderKey> ) > > ) 정렬된 스트림을 rankSelector로 표시되는 다른 orderKey로 정렬합니다.
공용 메서드정적 멤버 ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) 가장자리 이벤트의 CepStream을 IEnumerable 인터페이스를 구현하는 이벤트 싱크로 변환합니다. 이벤트의 순서는 FullyOrdered 입니다.
공용 메서드정적 멤버 ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) 지정한 이벤트 순서를 가진 가장자리 이벤트 CepStream을 IEnumerable 인터페이스를 구현하는 이벤트 싱크로 변환합니다.
공용 메서드정적 멤버 ToEdgeStream< (Of < <' (TInput, TPayload> ) > > ) 열거 가능한 입력 스트림을 가장자리 이벤트 스트림으로 변환하고 입력의 임시 특성을 제공합니다.
공용 메서드정적 멤버 ToEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) 이벤트 스트림에서 이벤트 헤더를 제거하고 CTI(현재 시간 증분) 이벤트를 삭제하여 열거 가능한 출력으로 변환합니다.
공용 메서드정적 멤버 ToEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) 이벤트 스트림에서 이벤트 헤더를 제거하고 CTI(현재 시간 증분) 이벤트를 삭제하여 지정한 이벤트 순서를 가진 열거 가능한 출력으로 변환합니다.
공용 메서드정적 멤버 ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) 간격 이벤트의 CepStream을 IEnumerable 인터페이스를 구현하는 이벤트 싱크로 변환합니다. 이벤트의 순서는 FullyOrdered 입니다.
공용 메서드정적 멤버 ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) 지정한 이벤트 순서를 가진 간격 이벤트 CepStream을 IEnumerable 인터페이스를 구현하는 이벤트 싱크로 변환합니다.
공용 메서드정적 멤버 ToIntervalStream< (Of < <' (TInput, TPayload> ) > > ) 열거 가능한 입력 스트림을 간격 이벤트 스트림으로 변환하고 입력의 임시 특성을 제공합니다.
공용 메서드정적 멤버 ToPointEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) 시점 이벤트의 CepStream을 IEnumerable 인터페이스를 구현하는 이벤트 싱크로 변환합니다. 이벤트의 순서는 FullyOrdered 입니다.
공용 메서드정적 멤버 ToPointEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) 지정한 이벤트 순서를 가진 시점 이벤트의 CepStream을 IEnumerable 인터페이스를 구현하는 이벤트 싱크로 변환합니다.
공용 메서드정적 멤버 ToPointEventStream< (Of < <' (TPayload> ) > > ) 이벤트 시작 시간만 유지하여 입력 스트림의 이벤트를 시점 이벤트로 변경합니다.
공용 메서드정적 멤버 ToPointStream< (Of < <' (TInput, TPayload> ) > > )
공용 메서드정적 멤버 ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (EdgeEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)
공용 메서드정적 멤버 ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (IntervalEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)
공용 메서드정적 멤버 ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (PointEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)
공용 메서드정적 멤버 TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan) 기본 출력 정책을 사용하여 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 연속 창은 창 크기와 도약 크기가 같은 특수한 종류의 도약 창입니다.
공용 메서드정적 멤버 TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, HoppingWindowOutputPolicy) 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 연속 창은 창 크기와 도약 크기가 같은 특수한 종류의 도약 창입니다.
공용 메서드정적 멤버 TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime) 기본 출력 정책을 사용하여 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 연속 창은 창 크기와 도약 크기가 같은 특수한 종류의 도약 창입니다. 맞춤 시간을 창 시작 지점에 대한 참조로 제공할 수도 있습니다.
공용 메서드정적 멤버 TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 연속 창은 창 크기와 도약 크기가 같은 특수한 종류의 도약 창입니다. 맞춤 시간을 창 시작 지점에 대한 참조로 제공할 수도 있습니다.
공용 메서드정적 멤버 TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime, HoppingWindowOutputPolicy) 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 연속 창은 창 크기와 도약 크기가 같은 특수한 종류의 도약 창입니다. 맞춤 시간을 창 시작 지점에 대한 참조로 제공할 수도 있습니다.
공용 메서드정적 멤버 TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 연속 창은 창 크기와 도약 크기가 같은 특수한 종류의 도약 창입니다. 맞춤 시간을 창 시작 지점에 대한 참조로 제공할 수도 있습니다.
공용 메서드정적 멤버 Union< (Of < <' (TPayload> ) > > ) 두 스트림을 한 스트림으로 통합합니다.
공용 메서드정적 멤버 Where< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, Boolean> ) > > )> ) > > )) 지정한 필터 함수를 사용하여 입력 스트림에서 이벤트를 필터링합니다.
공용 메서드정적 멤버 Where< (Of < <' (TInput> ) > > )(ICepEnumerable< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, Boolean> ) > > )> ) > > )) 지정한 필터 함수를 사용하여 열거 가능한 입력 스트림에서 이벤트를 필터링합니다.

맨 위로 이동

주의

CepStream은 확장 메서드의 컬렉션입니다. 일반적으로 확장 메서드는 LINQ 메서드 호출 식을 반환합니다. 메서드 호출은 나중에 실행 가능한 CEP 쿼리로 변환되는 정규 형식으로 호출 시퀀스를 캡처합니다.

스레드 보안

이 유형의 모든 공용 static(Visual Basic에서는 Shared) 멤버는 스레드로부터 안전합니다. 인스턴스 멤버는 스레드로부터의 안전성이 보장되지 않습니다.

참고 항목

참조

Microsoft.ComplexEventProcessing.Linq 네임스페이스