# EventHubDataAdapter

Package: [Microsoft.Orleans.Streaming.EventHubs](/orleans/docs/api/csharp/microsoft.orleans.streaming.eventhubs/) 10.0.0

[NuGet package](https://www.nuget.org/packages/Microsoft.Orleans.Streaming.EventHubs) | [Source](https://github.com/dotnet/orleans/blob/e4e752cedecc2976811db49802c7a999b1f1c704/src/Azure/Orleans.Streaming.EventHubs/Providers/Streams/EventHub/EventHubDataAdapter.cs#L13)

```csharp
public class EventHubDataAdapter : ICacheDataAdapter, IEventHubDataAdapter, IQueueDataAdapter<EventData>
```

Default event hub data adapter. Users may subclass to override event data to stream mapping.

## Constructors

- [EventHubDataAdapter(Serializer)](/orleans/docs/api/csharp/microsoft.orleans.streaming.eventhubs/orleans.streaming.eventhubs.eventhubdataadapter/constructors/constructor-orleans-serialization-serializer-17e3401d/)

## Methods

- [FromQueueMessage(StreamPosition, EventData, DateTime, Func&lt;int, ArraySegment&lt;byte&gt;&gt;)](/orleans/docs/api/csharp/microsoft.orleans.streaming.eventhubs/orleans.streaming.eventhubs.eventhubdataadapter/methods/fromqueuemessage-orleans-streams-streamposition-azure-messaging-eventhubs-eventd-a8577bd7/)
- [GetBatchContainer(CachedMessage)](/orleans/docs/api/csharp/microsoft.orleans.streaming.eventhubs/orleans.streaming.eventhubs.eventhubdataadapter/methods/getbatchcontainer-ref-orleans-providers-streams-common-cachedmessage-3f60472c/)
- [GetOffset(CachedMessage)](/orleans/docs/api/csharp/microsoft.orleans.streaming.eventhubs/orleans.streaming.eventhubs.eventhubdataadapter/methods/getoffset-orleans-providers-streams-common-cachedmessage-b95b37fb/)
- [GetPartitionKey(StreamId)](/orleans/docs/api/csharp/microsoft.orleans.streaming.eventhubs/orleans.streaming.eventhubs.eventhubdataadapter/methods/getpartitionkey-orleans-runtime-streamid-414bf1ee/)
- [GetSequenceToken(CachedMessage)](/orleans/docs/api/csharp/microsoft.orleans.streaming.eventhubs/orleans.streaming.eventhubs.eventhubdataadapter/methods/getsequencetoken-ref-orleans-providers-streams-common-cachedmessage-ca40482b/)
- [GetStreamIdentity(EventData)](/orleans/docs/api/csharp/microsoft.orleans.streaming.eventhubs/orleans.streaming.eventhubs.eventhubdataadapter/methods/getstreamidentity-azure-messaging-eventhubs-eventdata-0edd6ee3/)
- [GetStreamPosition(string, EventData)](/orleans/docs/api/csharp/microsoft.orleans.streaming.eventhubs/orleans.streaming.eventhubs.eventhubdataadapter/methods/getstreamposition-string-azure-messaging-eventhubs-eventdata-5e650845/)
- [ToQueueMessage(StreamId, IEnumerable&lt;T&gt;, StreamSequenceToken, Dictionary&lt;string, object&gt;)](/orleans/docs/api/csharp/microsoft.orleans.streaming.eventhubs/orleans.streaming.eventhubs.eventhubdataadapter/methods/toqueuemessage-1-orleans-runtime-streamid-system-collections-generic-ienumerable-02117f74/)
