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)	ストリームに使用する Event Hub パーティション キーを取得します。
GetSequenceToken(CachedMessage)	キャッシュされたメッセージからストリーム シーケンス トークンを取得します。
GetStreamIdentity(EventData)	イベント メッセージの を IStreamIdentity 取得します。
GetStreamPosition(String, EventData)	既定のイベント ハブ データ アダプター。 ユーザーは、イベント データをストリーム マッピングにオーバーライドするためにサブクラス化できます。
ToQueueMessage<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	既定のイベント ハブ データ アダプター。 ユーザーは、イベント データをストリーム マッピングにオーバーライドするためにサブクラス化できます。