CepStream(TPayload) 클래스

아티클
08/01/2011

사용자 지정 페이로드 유형의 이벤트 스트림을 나타냅니다.

상속 계층

System. . :: . .Object
Microsoft.ComplexEventProcessing.Linq..::..CepStream<(Of <(<'TPayload>)>)>

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

구문

public sealed class CepStream<TPayload>

유형 매개 변수

TPayload
스트림의 이벤트 페이로드 유형입니다.

CepStream<(Of <(<'TPayload>)>)> 유형에서 다음 멤버를 표시합니다.

메서드

	이름	설명
	Create(String)	'TPayload' 유형의 이벤트 페이로드를 사용하여 바인딩 해제된 스트림을 만듭니다.
	Create(Uri, EventShape)	지정된 게시된 스트림에서 입력에 대해 바인딩된 스트림을 만듭니다.
	Create(Uri, EventShape, AdvanceTimeSettings)	지정된 게시된 스트림에서 입력에 대해 바인딩된 스트림을 만듭니다.
	Create(Application, Uri, EventShape)	지정된 게시된 스트림에서 입력에 대해 바인딩된 스트림을 만듭니다.
	Create(String, Type, Object, EventShape)	지정된 입력 어댑터 팩터리에서 바인딩된 스트림을 만듭니다.
	Create(Application, Uri, EventShape, AdvanceTimeSettings)	지정된 게시된 스트림에서 입력에 대해 바인딩된 스트림을 만듭니다.
	Create(String, Type, Object, EventShape, AdvanceTimeSettings)	지정된 입력 어댑터 팩터리에서 바인딩된 스트림을 만듭니다.
	Create(Application, String, Type, Object, EventShape)	지정된 입력 어댑터 팩터리에서 바인딩된 스트림을 만듭니다.
	Create(Application, String, Type, Object, EventShape, AdvanceTimeSettings)	지정된 입력 어댑터 팩터리에서 바인딩된 스트림을 만듭니다.
	Equals	(Object에서 상속됨)
	ExtractInputStreams	지정된 스트림 정의에서 입력 스트림에 대한 정보가 포함된 목록을 검색합니다.
	Finalize	(Object에서 상속됨)
	GetHashCode	(Object에서 상속됨)
	GetType	(Object에서 상속됨)
	MemberwiseClone	(Object에서 상속됨)
	ToPublishedStreamQuery(Uri, String, String, EventShape, StreamEventOrder)	명시적으로 명명된 게시된 스트림에 바인딩되는 출력을 포함하는 쿼리를 만듭니다. 동적 쿼리 작성을 통해 쿼리 출력을 사용할 수 있습니다. 하나의 쿼리만 지정된 시간에 게시된 스트림에 대한 이벤트를 생성할 수 있습니다.
	ToPublishedStreamQuery(Uri, Application, String, String, EventShape, StreamEventOrder)	명시적으로 명명된 게시된 스트림에 바인딩되는 출력을 포함하는 쿼리를 만듭니다. 동적 쿼리 작성을 통해 쿼리 출력을 사용할 수 있습니다. 하나의 쿼리만 지정된 시간에 게시된 스트림에 대한 이벤트를 생성할 수 있습니다.
	ToQuery(String, String, EventShape, StreamEventOrder)	바인딩 해제된 출력이 있는 스트림에서 쿼리를 만듭니다. 쿼리에 입력되는 모든 사항은 어댑터, 시퀀스 또는 기타 쿼리에 바인딩되어야 합니다. 동적 쿼리 컴퍼지션을 통해서만 쿼리 출력을 사용할 수 있습니다. 이 쿼리에서 실행할 응용 프로그램은 스트림 정의로 함축됩니다.
	ToQuery(Application, String, String, EventShape, StreamEventOrder)	지정된 응용 프로그램에서 실행되는 바인딩 해제된 출력이 있는 스트림에서 쿼리를 만듭니다. 쿼리에 입력되는 모든 사항은 어댑터, 시퀀스 또는 기타 쿼리에 바인딩되어야 합니다. 동적 쿼리 컴퍼지션을 통해서만 쿼리 출력을 사용할 수 있습니다.
	ToQuery(String, String, Type, Object, EventShape, StreamEventOrder)	출력 어댑터에 바인딩되는 스트림에서 쿼리를 만듭니다. 출력 어댑터는 어댑터 팩터리 및 구성 개체 유형으로 지정됩니다. 이 쿼리에서 실행할 응용 프로그램은 스트림 정의로 함축됩니다.
	ToQuery(String, String, Type, Object, EventShape, StreamEventOrder, Boolean)	출력 어댑터에 바인딩되는 스트림에서 쿼리를 만듭니다. 출력 어댑터는 어댑터 팩터리 및 구성 개체 유형으로 지정됩니다. 이 쿼리에서 실행할 응용 프로그램은 스트림 정의로 함축됩니다. 쿼리를 복구 가능하도록 지정할 수 있습니다.
	ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder)	지정된 응용 프로그램에서 실행되는 출력 어댑터에 바인딩되는 스트림에서 쿼리를 만듭니다. 출력 어댑터는 어댑터 팩터리 및 구성 개체 유형으로 지정됩니다.
	ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder, Boolean)	지정된 응용 프로그램에서 실행되는 출력 어댑터에 바인딩되는 스트림에서 쿼리를 만듭니다. 출력 어댑터는 어댑터 팩터리 및 구성 개체 유형으로 지정됩니다. 쿼리를 복구 가능하도록 지정할 수 있습니다.
	ToString	(Object에서 상속됨)

맨 위로 이동

확장 메서드

	이름	설명
	AlterEventDuration< (Of < <' (TPayload> ) > > )	입력 이벤트의 기간을 변경합니다. 이 메서드는 이벤트 시작 시간은 변경하지 않습니다. (CepStream에 의해 정의됨)
	AlterEventLifetime< (Of < <' (TPayload> ) > > )	스트림의 이벤트 수명을 변경합니다. 이 메서드는 이벤트 시작 시간과 종료 시간을 모두 변경할 수 있습니다. (CepStream에 의해 정의됨)
	ClipEventDuration< (Of < <' (TSource, TClip> ) > > )	sourceStream의 이벤트 수명을 clipStream에서 matchExpression과 일치하는 다음 해당 이벤트의 시작 시간으로 단축합니다. (CepStream에 의해 정의됨)
	CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32)	오버로드되었습니다. 기본 출력 정책을 사용하여 지정된 수의 고유한 이벤트 시작 시간을 기준으로 하여 입력 스트림 이벤트를 창으로 그룹화합니다. 다른 시간에 시작되는 새 이벤트가 도착하면 창이 옆으로 이동(sliding)됩니다. (CepStream에 의해 정의됨)
	CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, CountWindowOutputPolicy)	오버로드되었습니다. 지정된 수의 고유한 이벤트 시작 시간을 기준으로 하여 입력 스트림 이벤트를 창으로 그룹화합니다. 다른 시간에 시작되는 새 이벤트가 도착하면 창이 옆으로 이동(sliding)됩니다. (CepStream에 의해 정의됨)
	CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, WindowInputPolicy, CountWindowOutputPolicy)	오버로드되었습니다. 지정된 수의 고유한 이벤트 시작 시간을 기준으로 하여 입력 스트림 이벤트를 창으로 그룹화합니다. 다른 시간에 시작되는 새 이벤트가 도착하면 창이 옆으로 이동(sliding)됩니다. (CepStream에 의해 정의됨)
	GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ))	오버로드되었습니다. 지정한 그룹화 키로 입력 스트림을 분할합니다. (CepStream에 의해 정의됨)
	GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > ))	오버로드되었습니다. 요소 선택기 함수를 사용하여 지정한 키 선택기 함수 및 프로젝트 결과로 원본 스트림을 그룹화합니다. (CepStream에 의해 정의됨)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan)	오버로드되었습니다. 기본 출력 정책을 사용하여 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 창은 상수 창 크기와 도약 크기 시간 범위로 정의됩니다. (CepStream에 의해 정의됨)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime)	오버로드되었습니다. 기본 출력 정책을 사용하여 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 창은 상수 창 크기와 도약 크기 시간 범위로 정의됩니다. 맞춤 시간을 창 시작 지점에 대한 참조로 제공할 수도 있습니다. (CepStream에 의해 정의됨)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, HoppingWindowOutputPolicy)	오버로드되었습니다. 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 창은 상수 창 크기와 도약 크기 시간 범위로 정의됩니다. (CepStream에 의해 정의됨)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy)	오버로드되었습니다. 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 창은 상수 창 크기와 도약 크기 시간 범위로 정의됩니다. 맞춤 시간을 창 시작 지점에 대한 참조로 제공할 수도 있습니다. (CepStream에 의해 정의됨)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy)	오버로드되었습니다. 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 창은 상수 창 크기와 도약 크기 시간 범위로 정의됩니다. 맞춤 시간을 창 시작 지점에 대한 참조로 제공할 수도 있습니다. (CepStream에 의해 정의됨)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy)	오버로드되었습니다. 창은 상수 창 크기와 도약 크기 시간 범위로 정의됩니다. 맞춤 시간을 창 시작 지점에 대한 참조로 제공할 수도 있습니다. (CepStream에 의해 정의됨)
	IsEmpty< (Of < <' (TPayload> ) > > )	쿼리에서 LASJ(Left Anti Semi Join)를 나타내는 데 사용되는 함수입니다. (CepStream에 의해 정의됨)
	Join< (Of < <' (TOuter, TInner, TKey, TResult> ) > > )	외부 스트림의 이벤트를 지정된 조인 키에서 내부 스트림의 이벤트와 조인합니다. (CepStream에 의해 정의됨)
	Select< (Of < <' (TPayload, TResult> ) > > )	프로젝션 식을 사용하여 입력 스트림에서 이벤트를 프로젝션합니다. (CepStream에 의해 정의됨)
	SelectMany< (Of < <' (TInput, TBind, TResult> ) > > )	두 입력 스트림의 크로스 조인을 기준으로 스트림을 생성합니다. (CepStream에 의해 정의됨)
	ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > ))	오버로드되었습니다. 수명은 변경하지 않고 이벤트 시작 시간을 새 타임스탬프로 이동합니다. (CepStream에 의해 정의됨)
	ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > ))	오버로드되었습니다. 수명은 변경하지 않고 지정된 시간 범위에 따라 이벤트 시작 시간을 이동합니다. (CepStream에 의해 정의됨)
	SnapshotWindow< (Of < <' (TPayload> ) > > )() () () ()	오버로드되었습니다. 기본 출력 정책을 사용하여 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 여기서 각 창은 스트림에서 가장 근접한 이벤트 끝점으로 정의되는 스냅숏 창입니다. (CepStream에 의해 정의됨)
	SnapshotWindow< (Of < <' (TPayload> ) > > )(SnapshotWindowOutputPolicy)	오버로드되었습니다. 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 여기서 각 창은 스트림에서 가장 근접한 이벤트 끝점으로 정의되는 스냅숏 창입니다. (CepStream에 의해 정의됨)
	SnapshotWindow< (Of < <' (TPayload> ) > > )(WindowInputPolicy, SnapshotWindowOutputPolicy)	오버로드되었습니다. 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 여기서 각 창은 스트림에서 가장 근접한 이벤트 끝점으로 정의되는 스냅숏 창입니다. (CepStream에 의해 정의됨)
	ToEdgeEnumerable< (Of < <' (TPayload> ) > > )() () () ()	오버로드되었습니다. 가장자리 이벤트의 CepStream을 IEnumerable 인터페이스를 구현하는 이벤트 싱크로 변환합니다. 이벤트의 순서는 FullyOrdered 입니다. (CepStream에 의해 정의됨)
	ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	오버로드되었습니다. 지정한 이벤트 순서를 가진 가장자리 이벤트 CepStream을 IEnumerable 인터페이스를 구현하는 이벤트 싱크로 변환합니다. (CepStream에 의해 정의됨)
	ToEdgeObservable< (Of < <' (TPayload> ) > > )() () () ()	오버로드되었습니다. 가장자리 이벤트의 CepStream을 IObservable 인터페이스를 구현하는 이벤트 싱크로 변환합니다. 이벤트의 순서는 FullyOrdered 입니다. (ObservableCepStream에 의해 정의됨)
	ToEdgeObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	오버로드되었습니다. 지정한 이벤트 순서를 가진 가장자리 이벤트 CepStream을 IObservable 인터페이스를 구현하는 이벤트 싱크로 변환합니다. (ObservableCepStream에 의해 정의됨)
	ToEnumerable< (Of < <' (TPayload> ) > > )() () () ()	오버로드되었습니다. 이벤트 스트림에서 이벤트 헤더를 제거하고 CTI(현재 시간 증분) 이벤트를 삭제하여 열거 가능한 출력으로 변환합니다. (CepStream에 의해 정의됨)
	ToEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	오버로드되었습니다. 이벤트 스트림에서 이벤트 헤더를 제거하고 CTI(현재 시간 증분) 이벤트를 삭제하여 지정한 이벤트 순서를 가진 열거 가능한 출력으로 변환합니다. (CepStream에 의해 정의됨)
	ToIntervalEnumerable< (Of < <' (TPayload> ) > > )() () () ()	오버로드되었습니다. 간격 이벤트의 CepStream을 IEnumerable 인터페이스를 구현하는 이벤트 싱크로 변환합니다. 이벤트의 순서는 FullyOrdered 입니다. (CepStream에 의해 정의됨)
	ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	오버로드되었습니다. 지정한 이벤트 순서를 가진 간격 이벤트 CepStream을 IEnumerable 인터페이스를 구현하는 이벤트 싱크로 변환합니다. (CepStream에 의해 정의됨)
	ToIntervalObservable< (Of < <' (TPayload> ) > > )() () () ()	오버로드되었습니다. 간격 이벤트의 CepStream을 IObservable 인터페이스를 구현하는 이벤트 싱크로 변환합니다. 이벤트의 순서는 FullyOrdered 입니다. (ObservableCepStream에 의해 정의됨)
	ToIntervalObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	오버로드되었습니다. 지정한 이벤트 순서를 가진 간격 이벤트 CepStream을 IObservable 인터페이스를 구현하는 이벤트 싱크로 변환합니다. (ObservableCepStream에 의해 정의됨)
	ToObservable< (Of < <' (TPayload> ) > > )() () () ()	오버로드되었습니다. 이벤트 스트림에서 이벤트 헤더를 제거하고 CTI(현재 시간 증분) 이벤트를 삭제하여 Observable 출력으로 변환합니다. (ObservableCepStream에 의해 정의됨)
	ToObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	오버로드되었습니다. 이벤트 스트림을 이벤트 헤더를 제거하고 CTI(현재 시간 증분) 이벤트를 삭제하여 지정한 이벤트 순서를 가진 Observable 출력으로 변환합니다. (ObservableCepStream에 의해 정의됨)
	ToPointEnumerable< (Of < <' (TPayload> ) > > )() () () ()	오버로드되었습니다. 시점 이벤트의 CepStream을 IEnumerable 인터페이스를 구현하는 이벤트 싱크로 변환합니다. 이벤트의 순서는 FullyOrdered 입니다. (CepStream에 의해 정의됨)
	ToPointEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	오버로드되었습니다. 지정한 이벤트 순서를 가진 시점 이벤트의 CepStream을 IEnumerable 인터페이스를 구현하는 이벤트 싱크로 변환합니다. (CepStream에 의해 정의됨)
	ToPointEventStream< (Of < <' (TPayload> ) > > )	이벤트 시작 시간만 유지하여 입력 스트림의 이벤트를 시점 이벤트로 변경합니다. (CepStream에 의해 정의됨)
	ToPointObservable< (Of < <' (TPayload> ) > > )() () () ()	오버로드되었습니다. 시점 이벤트의 CepStream을 IObservable 인터페이스를 구현하는 이벤트 싱크로 변환합니다. 이벤트의 순서는 FullyOrdered 입니다. (ObservableCepStream에 의해 정의됨)
	ToPointObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	오버로드되었습니다. 지정한 이벤트 순서를 가진 시점 이벤트 CepStream을 IObservable 인터페이스를 구현하는 이벤트 싱크로 변환합니다. (ObservableCepStream에 의해 정의됨)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan)	오버로드되었습니다. 기본 출력 정책을 사용하여 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 연속 창은 창 크기와 도약 크기가 같은 특수한 종류의 도약 창입니다. (CepStream에 의해 정의됨)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime)	오버로드되었습니다. 기본 출력 정책을 사용하여 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 연속 창은 창 크기와 도약 크기가 같은 특수한 종류의 도약 창입니다. 맞춤 시간을 창 시작 지점에 대한 참조로 제공할 수도 있습니다. (CepStream에 의해 정의됨)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, HoppingWindowOutputPolicy)	오버로드되었습니다. 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 연속 창은 창 크기와 도약 크기가 같은 특수한 종류의 도약 창입니다. (CepStream에 의해 정의됨)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, HoppingWindowOutputPolicy)	오버로드되었습니다. 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 연속 창은 창 크기와 도약 크기가 같은 특수한 종류의 도약 창입니다. 맞춤 시간을 창 시작 지점에 대한 참조로 제공할 수도 있습니다. (CepStream에 의해 정의됨)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy)	오버로드되었습니다. 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 연속 창은 창 크기와 도약 크기가 같은 특수한 종류의 도약 창입니다. 맞춤 시간을 창 시작 지점에 대한 참조로 제공할 수도 있습니다. (CepStream에 의해 정의됨)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy)	오버로드되었습니다. 스트림을 각 멤버가 CepWindow인 창 스트림으로 변환합니다. 연속 창은 창 크기와 도약 크기가 같은 특수한 종류의 도약 창입니다. 맞춤 시간을 창 시작 지점에 대한 참조로 제공할 수도 있습니다. (CepStream에 의해 정의됨)
	Union< (Of < <' (TPayload> ) > > )	두 스트림을 한 스트림으로 통합합니다. (CepStream에 의해 정의됨)
	Where< (Of < <' (TPayload> ) > > )	지정한 필터 함수를 사용하여 입력 스트림에서 이벤트를 필터링합니다. (CepStream에 의해 정의됨)

맨 위로 이동

주의

적절한 스트림 정의를 제공해야 CEP 쿼리를 작성할 수 있습니다. 이 클래스는 CepStream 개체를 만들기 위한 다양한 메서드를 제공합니다.

스레드 보안

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

참고 항목

참조

Microsoft.ComplexEventProcessing.Linq 네임스페이스

다음을 통해 공유