StreamInsight의 IObservable 및 IEnumerable에 대한 API 지원

이 항목에서는 IObservable 또는 IEnumerable 인터페이스를 구현하는 이벤트 원본 및 싱크를 지원하는 StreamInsight의 API 기능을 요약합니다.

Observable 및 열거 가능 입력에 대한 API 지원

다음 API 기능은 IObservable 또는 IEnumerable 인터페이스를 구현하는 이벤트 원본을 지원합니다.

입력 만들기

바인딩된 입력 만들기

CepStream<(Of <(<'TPayload>)>)> 클래스의 Create 메서드에 대한 다음 오버로드 중 하나를 사용하여 응용 프로그램에 바인딩되는 입력 스트림을 만듭니다.

• Create(Application, String, Type, Object, EventShape)

• Create(Application, String, Type, Object, EventShape, AdvanceTimeSettings)

• Create(Application, Uri, EventShape)

• Create(Application, Uri, EventShape, AdvanceTimeSettings)

Observable 입력에서 입력 만들기

ObservableCepStream 클래스의 ToStream 메서드에 대한 다음 오버로드 중 하나를 사용하여 IObservable 이벤트 원본을 입력 스트림으로 변환합니다.

• ToStream<(Of <<'(TPayload>)>>)(IObservable<(Of <<'(PointEvent<(Of <<'(TPayload>)>>)>)>>), Application, AdvanceTimeSettings, String)

• ToPointStream<(Of <<'(TInput, TPayload>)>>)(IObservable<(Of <<'(TInput>)>>), Application, Expression<(Of <<'(Func<(Of <<'(TInput, PointEvent<(Of <<'(TPayload>)>>)>)>>)>)>>), AdvanceTimeSettings, String)

• ToStream<(Of <<'(TPayload>)>>)(IObservable<(Of <<'(IntervalEvent<(Of <<'(TPayload>)>>)>)>>), Application, AdvanceTimeSettings, String)

• ToIntervalStream<(Of <<'(TInput, TPayload>)>>)(IObservable<(Of <<'(TInput>)>>), Application, Expression<(Of <<'(Func<(Of <<'(TInput, IntervalEvent<(Of <<'(TPayload>)>>)>)>>)>)>>), AdvanceTimeSettings, String)

• ToStream<(Of <<'(TPayload>)>>)(IObservable<(Of <<'(EdgeEvent<(Of <<'(TPayload>)>>)>)>>), Application, AdvanceTimeSettings, String)

• ToEdgeStream<(Of <<'(TInput, TPayload>)>>)(IObservable<(Of <<'(TInput>)>>), Application, Expression<(Of <<'(Func<(Of <<'(TInput, EdgeEvent<(Of <<'(TPayload>)>>)>)>>)>)>>), AdvanceTimeSettings, String)

열거 가능 입력에서 입력 만들기

CepStream 클래스의 ToStream 메서드에 대한 다음 오버로드 중 하나를 사용하여 IEnumerable 이벤트 원본을 입력 스트림으로 변환합니다.

• ToStream

• ToPointStream<(Of <<'(TInput, TPayload>)>>)(IEnumerable<(Of <<'(TInput>)>>), Application, Expression<(Of <<'(Func<(Of <<'(TInput, PointEvent<(Of <<'(TPayload>)>>)>)>>)>)>>), AdvanceTimeSettings, String)

• ToStream<(Of <<'(TPayload>)>>)(IEnumerable<(Of <<'(IntervalEvent<(Of <<'(TPayload>)>>)>)>>), Application, AdvanceTimeSettings, String)

• ToIntervalStream<(Of <<'(TInput, TPayload>)>>)(IEnumerable<(Of <<'(TInput>)>>), Application, Expression<(Of <<'(Func<(Of <<'(TInput, IntervalEvent<(Of <<'(TPayload>)>>)>)>>)>)>>), AdvanceTimeSettings, String)

• ToStream<(Of <<'(TPayload>)>>)(IEnumerable<(Of <<'(EdgeEvent<(Of <<'(TPayload>)>>)>)>>), Application, AdvanceTimeSettings, String)

• ToEdgeStream<(Of <<'(TInput, TPayload>)>>)(IEnumerable<(Of <<'(TInput>)>>), Application, Expression<(Of <<'(Func<(Of <<'(TInput, EdgeEvent<(Of <<'(TPayload>)>>)>)>>)>)>>), AdvanceTimeSettings, String)

임시 특성 설명

AdvanceTimeSettings 클래스에서 다음 도우미 중 하나를 사용하여 원본 데이터의 임시 특성을 설명합니다.

• IncreasingStartTime

• StrictlyIncreasingStartTime

• UnorderedStartTime(TimeSpan)

시점, 간격 및 가장자리 이벤트에 입력 매핑

ToStream 메서드의 오버로드에 전달된 식에서 다음 메서드를 사용하여 시점, 간격 또는 가장자리 이벤트에 입력 데이터를 매핑합니다.

시점 이벤트에 입력 매핑

ToStream 메서드의 오버로드에 전달된 식에서 PointEvent 또는 PointEvent<(Of <(<'TPayload>)>)> 클래스의 다음 메서드를 사용하여 시점 이벤트 및 해당 CTI 이벤트에 입력 데이터를 매핑합니다.

• CreateInsert<(Of <<'(TPayload>)>>)(DateTimeOffset, TPayload)

• CreateCti<(Of <<'(TPayload>)>>)(DateTimeOffset)

• CreateInsert(DateTimeOffset, TPayload)

• CreateCti(DateTimeOffset)

간격 이벤트에 입력 매핑

ToStream 메서드의 오버로드에 전달된 식에서 IntervalEvent 또는 IntervalEvent<(Of <(<'TPayload>)>)> 클래스의 다음 메서드를 사용하여 간격 이벤트 및 해당 CTI 이벤트에 입력 데이터를 매핑합니다.

• CreateInsert<(Of <<'(TPayload>)>>)(DateTimeOffset, DateTimeOffset, TPayload)

• CreateCti<(Of <<'(TPayload>)>>)(DateTimeOffset)

• CreateInsert(DateTimeOffset, DateTimeOffset, TPayload)

• CreateCti(DateTimeOffset)

가장자리 이벤트 만들기

ToStream 메서드의 오버로드에 전달된 식에서 EdgeEvent 또는 EdgeEvent<(Of <(<'TPayload>)>)> 클래스의 다음 메서드를 사용하여 가장자리 이벤트 및 해당 CTI 이벤트에 입력 데이터를 매핑합니다.

• CreateStart<(Of <<'(TPayload>)>>)(DateTimeOffset, TPayload)

• CreateEnd<(Of <<'(TPayload>)>>)(DateTimeOffset, DateTimeOffset, TPayload)

• CreateCti<(Of <<'(TPayload>)>>)(DateTimeOffset)

• CreateStart(DateTimeOffset, TPayload)

• CreateEnd(DateTimeOffset, DateTimeOffset, TPayload)

• CreateCti(DateTimeOffset)

Observable 및 열거 가능 출력에 대한 API 지원

다음 API 기능은 IObservable 또는 IEnumerable 인터페이스를 구현하는 이벤트 싱크를 지원합니다.

출력 만들기

ObservableCepStream 클래스의 다음 메서드 중 하나를 사용하여 이벤트 스트림을 특정 이벤트 셰이프에 대한 IObservable 출력으로 변환합니다.

• ToObservable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>))

• ToObservable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>), StreamEventOrder)

• ToPointObservable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>))

• ToPointObservable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>), StreamEventOrder)

• ToIntervalObservable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>))

• ToIntervalObservable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>), StreamEventOrder)

• ToEdgeObservable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>))

• ToEdgeObservable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>), StreamEventOrder)

CepStream 클래스의 다음 메서드 중 하나를 사용하여 이벤트 스트림을 특정 이벤트 셰이프에 대한 IEnumerable 출력으로 변환합니다.

• ToEnumerable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>))

• ToEnumerable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>), StreamEventOrder)

• ToPointEnumerable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>))

• ToPointEnumerable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>), StreamEventOrder)

• ToIntervalEnumerable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>))

• ToIntervalEnumerable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>), StreamEventOrder)

• ToEdgeEnumerable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>))

• ToEdgeEnumerable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>), StreamEventOrder)

출력 매핑

Observable 출력 매핑

ObservableCepStream의 다음 메서드를 사용하여 Observable 출력을 매핑합니다.

• Select<(Of <<'(TInput, TOutput>)>>)(ICepObservable<(Of <<'(TInput>)>>), Expression<(Of <<'(Func<(Of <<'(TInput, TOutput>)>>)>)>>))

• Where<(Of <<'(TInput>)>>)(ICepObservable<(Of <<'(TInput>)>>), Expression<(Of <<'(Func<(Of <<'(TInput, Boolean>)>>)>)>>))

열거 가능 출력 매핑

CepStream의 다음 메서드를 사용하여 열거 가능 출력을 매핑합니다.

• Select<(Of <<'(TInput, TOutput>)>>)(ICepEnumerable<(Of <<'(TInput>)>>), Expression<(Of <<'(Func<(Of <<'(TInput, TOutput>)>>)>)>>))

• Where<(Of <<'(TInput>)>>)(ICepEnumerable<(Of <<'(TInput>)>>), Expression<(Of <<'(Func<(Of <<'(TInput, Boolean>)>>)>)>>))

이벤트 싱크용 확장 인터페이스

출력을 만들고 필터링하기 위한 위에 설명된 메서드는 기본 IObservable 및 IEnumerable 인터페이스를 확장하는 인터페이스를 구현하는 이벤트 싱크를 반환합니다. 특히 확장 인터페이스를 사용하면 디버깅 목적을 위해 쿼리 이름을 제공할 수 있습니다.

• ICepObservable<(Of <(<'T>)>)>

• ICepEnumerable<(Of <(<'T>)>)>