EventHubDataAdapter Classe
Definizione
Importante
Alcune informazioni sono relative alla release non definitiva del prodotto, che potrebbe subire modifiche significative prima della release definitiva. Microsoft non riconosce alcuna garanzia, espressa o implicita, in merito alle informazioni qui fornite.
Scheda dati dell'hub eventi predefinita. Gli utenti possono sottoclasse per eseguire l'override dei dati degli eventi nel mapping di flusso.
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)- Ereditarietà
-
EventHubDataAdapter
- Implementazioni
Costruttori
| EventHubDataAdapter(Serializer) |
Scheda dati cache che adatta EventData di EventHub a CachedEventHubMessage usata nella cache |
Metodi
| EncodeMessageIntoSegment(EventData, Func<Int32,ArraySegment<Byte>>) |
Scheda dati dell'hub eventi predefinita. Gli utenti possono sottoclasse per eseguire l'override dei dati degli eventi nel mapping di flusso. |
| FromQueueMessage(StreamPosition, EventData, DateTime, Func<Int32,ArraySegment<Byte>>) |
Scheda dati dell'hub eventi predefinita. Gli utenti possono sottoclasse per eseguire l'override dei dati degli eventi nel mapping di flusso. |
| GetBatchContainer(CachedMessage) |
Converte un messaggio memorizzato nella cache in un contenitore batch per il recapito |
| GetBatchContainer(EventHubMessage) |
Convertire un EventHubMessage in un contenitore batch |
| GetOffset(CachedMessage) |
Ottenere l'offset dal messaggio memorizzato nella cache. Lasciato alla classe derivata, perché sa solo come ottenere questo dal messaggio memorizzato nella cache. |
| GetPartitionKey(StreamId) |
Ottenere la chiave di partizione dell'hub eventi da usare per un flusso. |
| GetSequenceToken(CachedMessage) |
Ottiene il token della sequenza di flusso da un messaggio memorizzato nella cache. |
| GetStreamIdentity(EventData) |
Ottenere l'oggetto IStreamIdentity per un messaggio di evento. |
| GetStreamPosition(String, EventData) |
Scheda dati dell'hub eventi predefinita. Gli utenti possono sottoclasse per eseguire l'override dei dati degli eventi nel mapping di flusso. |
| ToQueueMessage<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>) |
Scheda dati dell'hub eventi predefinita. Gli utenti possono sottoclasse per eseguire l'override dei dati degli eventi nel mapping di flusso. |