EventHubDataAdapter Classe
Définition
Important
Certaines informations portent sur la préversion du produit qui est susceptible d’être en grande partie modifiée avant sa publication. Microsoft exclut toute garantie, expresse ou implicite, concernant les informations fournies ici.
Adaptateur de données event hub par défaut. Les utilisateurs peuvent sous-classer pour remplacer les données d’événement pour le mappage de flux.
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 ICacheDataAdapterPublic Class EventHubDataAdapter
Implements ICacheDataAdapter, IEventHubDataAdapter, IQueueDataAdapter(Of EventData)- Héritage
-
EventHubDataAdapter
- Implémente
Constructeurs
| EventHubDataAdapter(Serializer) |
Adaptateur de données de cache qui adapte EventData d’EventHub à CachedEventHubMessage utilisé dans le cache |
Méthodes
| EncodeMessageIntoSegment(EventData, Func<Int32,ArraySegment<Byte>>) |
Adaptateur de données event hub par défaut. Les utilisateurs peuvent sous-classer pour remplacer les données d’événement pour le mappage de flux. |
| FromQueueMessage(StreamPosition, EventData, DateTime, Func<Int32,ArraySegment<Byte>>) |
Adaptateur de données event hub par défaut. Les utilisateurs peuvent sous-classer pour remplacer les données d’événement pour le mappage de flux. |
| GetBatchContainer(CachedMessage) |
Convertit un message mis en cache en conteneur de lots pour la remise |
| GetBatchContainer(EventHubMessage) |
Convertir un EventHubMessage en conteneur de lots |
| GetOffset(CachedMessage) |
Obtenez un décalage à partir du message mis en cache. Laissé à la classe dérivée, car seul il sait comment l’obtenir à partir du message mis en cache. |
| GetPartitionKey(StreamId) |
Obtenez la clé de partition Event Hub à utiliser pour un flux. |
| GetSequenceToken(CachedMessage) |
Obtient le jeton de séquence de flux à partir d’un message mis en cache. |
| GetStreamIdentity(EventData) |
Obtenez le IStreamIdentity pour un message d’événement. |
| GetStreamPosition(String, EventData) |
Adaptateur de données event hub par défaut. Les utilisateurs peuvent sous-classer pour remplacer les données d’événement pour le mappage de flux. |
| ToQueueMessage<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>) |
Adaptateur de données event hub par défaut. Les utilisateurs peuvent sous-classer pour remplacer les données d’événement pour le mappage de flux. |