다음을 통해 공유


IQStreamable<TPayload> 인터페이스

지정한 페이로드 유형을 포함한 임시 스트림 쿼리 부분에 대한 기본 인터페이스를 나타냅니다.

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

구문

‘선언
Public Interface IQStreamable(Of TPayload) _
    Inherits IStreamable(Of TPayload), IQStreamable
‘사용 방법
Dim instance As IQStreamable(Of TPayload)
public interface IQStreamable<TPayload> : IStreamable<TPayload>, 
    IQStreamable
generic<typename TPayload>
public interface class IQStreamable : IStreamable<TPayload>, 
    IQStreamable
type IQStreamable<'TPayload> =  
    interface 
        interface IStreamable<'TPayload>
        interface IQStreamable 
    end
JScript는 제네릭 형식 및 메서드를 지원하지 않습니다.

유형 매개 변수

  • TPayload
    페이로드의 유형입니다.

IQStreamable<TPayload> 유형에서 다음 멤버를 표시합니다.

속성

  이름 설명
공용 속성 Expression 쿼리 부분을 설명하는 식을 가져옵니다. (IQStreamable에서 상속됨)
공용 속성 Provider 임시 스트림 쿼리 부분의 LINQ 공급자를 가져옵니다. (IQStreamable에서 상속됨)

맨 위로 이동

확장 메서드

  이름 설명
공용 확장 메서드 AlterEventDuration<TPayload> 시작 시간에 영향을 주지 않고 이벤트의 기간을 변경합니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 AlterEventLifetime<TPayload> 이벤트 수명을 변경합니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 AlterEventStartTime<TPayload> 기간에 영향을 주지 않고 이벤트의 시작 시간을 변경합니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 Bind<TPayload>(Func<Nullable<DateTimeOffset>, Int32, IRemoteObserver<EdgeEvent<TPayload>>>) 오버로드되었습니다. 임시 스트림을 상위 워터마크 및 오프셋에서 매개 변수화된 가장자리 이벤트 Observer에 바인딩합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 Bind<TPayload>(IRemoteObserver<EdgeEvent<TPayload>>) 오버로드되었습니다. 임시 스트림을 가장자리 이벤트 Observer 싱크에 바인딩합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 Bind<TPayload>(IRemoteObserver<IntervalEvent<TPayload>>) 오버로드되었습니다. 임시 스트림을 간격 이벤트 Observer 싱크에 바인딩합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 Bind<TPayload>(Func<Nullable<DateTimeOffset>, Int32, IRemoteObserver<IntervalEvent<TPayload>>>) 오버로드되었습니다. 임시 스트림을 상위 워터마크 및 오프셋에서 매개 변수화된 간격 이벤트 Observer에 바인딩합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 Bind<TPayload>(IRemoteObserver<TPayload>) 오버로드되었습니다. 임시 스트림을 Observer 싱크에 바인딩합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 Bind<TPayload>(IRemoteStreamableSink<TPayload>) 오버로드되었습니다. 임시 스트림 원본을 임시 스트림 싱크에 바인딩합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 Bind<TPayload>(IRemoteObserver<PointEvent<TPayload>>) 오버로드되었습니다. 임시 스트림을 시점 이벤트 Observer 싱크에 바인딩합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 Bind<TPayload>(Func<Nullable<DateTimeOffset>, Int32, IRemoteObserver<PointEvent<TPayload>>>) 오버로드되었습니다. 임시 스트림을 상위 워터마크 및 오프셋에서 매개 변수화된 시점 이벤트 Observer에 바인딩합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 ClipEventDuration<TSource, TClip>(IQStreamable<TClip>, Expression<Func<TSource, TClip, Boolean>>) 오버로드되었습니다. 원본 의 이벤트 종료 시간을 잘라내기에서 조건자와 일치하는 다음 해당 이벤트의 시작 시간에 맞게 자릅니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 ClipEventDuration<TSource, TClip, TKey>(IQStreamable<TClip>, Expression<Func<TSource, TKey>>, Expression<Func<TClip, TKey>>) 오버로드되었습니다. 원본의 이벤트 종료 시간을 해당 키 값을 가진 잘라내기에서 다음 해당 이벤트의 시작 시간에 맞게 자릅니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 CountWindow<TPayload> 개수를 기준으로 기간 이동 스트림을 생성합니다.각 창은 고유한 시작 시간 count가 있는 이벤트로 구성됩니다.고유한 시작 시간을 가진 새 이벤트가 도착하면 창이 옆으로 이동(sliding)됩니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 Deploy<TPayload> 원격 임시 스트림을 배포합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 GroupBy<TPayload, TKey>(Expression<Func<TPayload, TKey>>) 오버로드되었습니다. 파티션 연산자입니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 GroupBy<TSource, TKey, TResult>(Expression<Func<TSource, TKey>>, Expression<Func<TSource, TResult>>) 오버로드되었습니다. 파티션 연산자입니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 HoppingWindow<TPayload>(TimeSpan, TimeSpan) 오버로드되었습니다. 창 정의를 기준으로 기간 이동 스트림을 생성합니다.도약 창은 창 기간을 나타내는 창 지속 시간과 도약 크기를 특징으로 합니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 HoppingWindow<TPayload>(TimeSpan, TimeSpan, DateTime) 오버로드되었습니다. 창 정의를 기준으로 기간 이동 스트림을 생성합니다.도약 창은 창 기간을 나타내는 창 지속 시간과 도약 크기를 특징으로 합니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 Join<TLeft, TRight, TKey, TResult> 수명과 키 값이 일치하는 이벤트를 조인합니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 LeftAntiJoin<TLeft, TRight>(IQStreamable<TRight>, Expression<Func<TLeft, TRight, Boolean>>) 오버로드되었습니다. predicate를 기준으로 이벤트를 연결하는 경우 일치하는 right 이벤트가 없을 때 left 이벤트를 반환합니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 LeftAntiJoin<TLeft, TRight, TKey>(IQStreamable<TRight>, Expression<Func<TLeft, TKey>>, Expression<Func<TRight, TKey>>) 오버로드되었습니다. 키를 기준으로 이벤트를 연결하는 경우 일치하는 right 이벤트가 없을 때 left 이벤트를 반환합니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 Multicast<TSource>(Expression<Func<IQStreamable<TSource>, IRemoteStreamableBinding>>) 오버로드되었습니다. 원본을 기준으로 Streamable 바인딩을 정의합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 Multicast<TSource, TResult>(Expression<Func<IQStreamable<TSource>, IQStreamable<TResult>>>) 오버로드되었습니다. 멀티캐스트 연산자입니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 Select<TSource, TResult> 프로젝션 연산자입니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 SelectMany<TLeft, TRight, TResult> 상호 조인 연산자입니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 ShiftEventTime<TPayload> shiftSelector 매개 변수에 지정된 오프셋만큼 이벤트를 이동합니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 SnapshotWindow<TPayload> 스냅숏을 기준으로 기간 이동 스트림을 생성합니다.창은 원본에 이벤트 경계로 정의됩니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 ToEdgeEnumerable<TPayload> 임시 스트림을 시퀀스로 변환합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 ToEdgeObservable<TPayload> 임시 스트림을 시퀀스로 변환합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 ToEnumerable<TPayload> 임시 스트림을 시퀀스로 변환합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 ToIntervalEnumerable<TPayload> 임시 스트림을 시퀀스로 변환합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 ToIntervalObservable<TPayload> 임시 스트림을 시퀀스로 변환합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 ToObservable<TPayload> 임시 스트림을 시퀀스로 변환합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 ToPointEnumerable<TPayload> 임시 스트림을 시퀀스로 변환합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 ToPointEventStream<TPayload> 입력 스트림의 이벤트를 시점 이벤트로 변경합니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 ToPointObservable<TPayload> 임시 스트림을 시퀀스로 변환합니다. (RemoteProvider에 의해 정의됨)
공용 확장 메서드 TumblingWindow<TPayload>(TimeSpan) 오버로드되었습니다. 창 정의를 기준으로 기간 이동 스트림을 생성합니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 TumblingWindow<TPayload>(TimeSpan, DateTime) 오버로드되었습니다. 창 정의를 기준으로 기간 이동 스트림을 생성합니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 Union<TPayload> UNION 연산자입니다. (QStreamable에 의해 정의됨)
공용 확장 메서드 Where<TPayload> 선택 연산자입니다. (QStreamable에 의해 정의됨)

맨 위로 이동

참고 항목

참조

Microsoft.ComplexEventProcessing.Linq 네임스페이스