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>)	默认事件中心数据适配器。 用户可以将事件数据重写为流映射的子类。