EventHubDataAdapter 類別

定義

命名空間:

Orleans.Streaming.EventHubs

組件:

Orleans.Streaming.EventHubs.dll

套件:

Microsoft.Orleans.Streaming.EventHubs v8.1.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>)	預設事件中樞資料配接器。 使用者可以子類別覆寫事件資料至資料流程對應。