EventHubDataAdapter Klasse

Definition

Namespace:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Paket:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

Standardmäßiger Event Hub-Datenadapter. Benutzer können eine Unterklasse verwenden, um Ereignisdaten zum Streamen der Zuordnung außer Kraft zu setzen.

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)

Vererbung

Object

EventHubDataAdapter

Implementiert

ICacheDataAdapter IEventHubDataAdapter IQueueDataAdapter<EventData>

Konstruktoren

EventHubDataAdapter(Serializer)

Cachedatenadapter, der EventHubs EventData an CachedEventHubMessage anpasst, die im Cache verwendet wird

Methoden

EncodeMessageIntoSegment(EventData, Func<Int32,ArraySegment<Byte>>)	Standardmäßiger Event Hub-Datenadapter. Benutzer können eine Unterklasse verwenden, um Ereignisdaten zum Streamen der Zuordnung außer Kraft zu setzen.
FromQueueMessage(StreamPosition, EventData, DateTime, Func<Int32,ArraySegment<Byte>>)	Standardmäßiger Event Hub-Datenadapter. Benutzer können eine Unterklasse verwenden, um Ereignisdaten zum Streamen der Zuordnung außer Kraft zu setzen.
GetBatchContainer(CachedMessage)	Konvertiert eine zwischengespeicherte Nachricht für die Übermittlung in einen Batchcontainer
GetBatchContainer(EventHubMessage)	Konvertieren einer EventHubMessage in einen Batchcontainer
GetOffset(CachedMessage)	Abrufen des Offsets aus zwischengespeicherten Nachrichten. Bleibt der abgeleiteten Klasse überlassen, da nur sie weiß, wie dies aus der zwischengespeicherten Nachricht abgerufen werden kann.
GetPartitionKey(StreamId)	Rufen Sie den Event Hub-Partitionsschlüssel ab, der für einen Stream verwendet werden soll.
GetSequenceToken(CachedMessage)	Ruft das Streamsequenztoken aus einer zwischengespeicherten Nachricht ab.
GetStreamIdentity(EventData)	Rufen Sie die IStreamIdentity für eine Ereignismeldung ab.
GetStreamPosition(String, EventData)	Standardmäßiger Event Hub-Datenadapter. Benutzer können eine Unterklasse verwenden, um Ereignisdaten zum Streamen der Zuordnung außer Kraft zu setzen.
ToQueueMessage<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Standardmäßiger Event Hub-Datenadapter. Benutzer können eine Unterklasse verwenden, um Ereignisdaten zum Streamen der Zuordnung außer Kraft zu setzen.