EventHubDataAdapter 클래스

정의

네임스페이스:

Orleans.Streaming.EventHubs

어셈블리:

Orleans.Streaming.EventHubs.dll

패키지:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

기본 이벤트 허브 데이터 어댑터입니다. 사용자는 스트림 매핑에 대한 이벤트 데이터를 재정의하기 위해 서브클래스할 수 있습니다.

public class EventHubDataAdapter : Orleans.Providers.Streams.Common.ICacheDataAdapter, Orleans.Streaming.EventHubs.IEventHubDataAdapter, Orleans.Streams.IQueueDataAdapter<Azure.Messaging.EventHubs.EventData>

type EventHubDataAdapter = class
    interface IEventHubDataAdapter
    interface IQueueDataAdapter<EventData>
    interface ICacheDataAdapter

Public Class EventHubDataAdapter
Implements ICacheDataAdapter, IEventHubDataAdapter, IQueueDataAdapter(Of EventData)

상속

Object

EventHubDataAdapter

구현

ICacheDataAdapter IEventHubDataAdapter IQueueDataAdapter<EventData>

생성자

EventHubDataAdapter(Serializer)

EventHub의 EventData를 캐시에 사용되는 CachedEventHubMessage로 조정하는 캐시 데이터 어댑터

메서드

EncodeMessageIntoSegment(EventData, Func<Int32,ArraySegment<Byte>>)	기본 이벤트 허브 데이터 어댑터입니다. 사용자는 스트림 매핑에 대한 이벤트 데이터를 재정의하기 위해 서브클래스할 수 있습니다.
FromQueueMessage(StreamPosition, EventData, DateTime, Func<Int32,ArraySegment<Byte>>)	기본 이벤트 허브 데이터 어댑터입니다. 사용자는 스트림 매핑에 대한 이벤트 데이터를 재정의하기 위해 서브클래스할 수 있습니다.
GetBatchContainer(CachedMessage)	배달을 위해 캐시된 메시지를 일괄 처리 컨테이너로 변환합니다.
GetBatchContainer(EventHubMessage)	EventHubMessage를 일괄 처리 컨테이너로 변환
GetOffset(CachedMessage)	캐시된 메시지에서 오프셋을 가져옵니다. 캐시된 메시지에서 이 값을 가져오는 방법만 알고 있으므로 파생 클래스에 남아 있습니다.
GetPartitionKey(StreamId)	스트림에 사용할 이벤트 허브 파티션 키를 가져옵니다.
GetSequenceToken(CachedMessage)	캐시된 메시지에서 스트림 시퀀스 토큰을 가져옵니다.
GetStreamIdentity(EventData)	이벤트 메시지의 IStreamIdentity 를 가져옵니다.
GetStreamPosition(String, EventData)	기본 이벤트 허브 데이터 어댑터입니다. 사용자는 스트림 매핑에 대한 이벤트 데이터를 재정의하기 위해 서브클래스할 수 있습니다.
ToQueueMessage<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	기본 이벤트 허브 데이터 어댑터입니다. 사용자는 스트림 매핑에 대한 이벤트 데이터를 재정의하기 위해 서브클래스할 수 있습니다.