EventHubBatchContainer 类

定义

批处理容器,它为 EventHub EventData 中的一组事件提供有效负载和流位置信息。

[System.Serializable]
public class EventHubBatchContainer : Orleans.Serialization.IOnDeserialized, Orleans.Streams.IBatchContainer
[<System.Serializable>]
type EventHubBatchContainer = class
    interface IBatchContainer
    interface IOnDeserialized
Public Class EventHubBatchContainer
Implements IBatchContainer, IOnDeserialized
继承
EventHubBatchContainer
属性
实现

构造函数

EventHubBatchContainer(EventHubMessage, SerializationManager)

批处理容器,从与 orleans 流关联的缓存 EventHub 数据传送事件

属性

SequenceToken

此批开始的流序列标记。

StreamGuid

此批所属流的流标识符。

StreamNamespace

此批所属的流的流命名空间。

方法

GetEvents<T>()

从批处理中获取特定类型的事件。

ImportRequestContext()

使 IBatchContainer 有机会在此 IBatchContainer 发送给使用者之前设置 RequestContext 中的任何数据。 它可以是在生成事件时设置的数据,并排入持久提供程序或其他任何数据。

ShouldDeliver(IStreamIdentity, Object, StreamFilterPredicate)

确定是否应将此批发送到指定目标。

ToEventData<T>(SerializationManager, Guid, String, IEnumerable<T>, Dictionary<String,Object>)

将事件列表及其上下文放入 EventData 对象中

显式接口实现

IOnDeserialized.OnDeserialized(ISerializerContext)

批处理容器,它为 EventHub EventData 中的一组事件提供有效负载和流位置信息。

适用于