ShardedStreamable<TKey,TPayload> Sınıf
Tanım
Önemli
Bazı bilgiler ürünün ön sürümüyle ilgilidir ve sürüm öncesinde önemli değişiklikler yapılmış olabilir. Burada verilen bilgilerle ilgili olarak Microsoft açık veya zımni hiçbir garanti vermez.
IShardedStreamable sınıfının somut örneklemesi
public class ShardedStreamable<TKey,TPayload> : Microsoft.StreamProcessing.Sharding.IShardedStreamable<TKey,TPayload>type ShardedStreamable<'Key, 'Payload> = class
interface IShardedStreamable<'Key, 'Payload>Public Class ShardedStreamable(Of TKey, TPayload)
Implements IShardedStreamable(Of TKey, TPayload)Tür Parametreleri
- TKey
Sorgudaki veriler için anahtar türünü gruplandırma
- TPayload
Sorgudaki veriler için olay yükü türü
- Devralma
-
ShardedStreamable<TKey,TPayload>
- Türetilmiş
- Uygulamalar
Oluşturucular
| ShardedStreamable<TKey,TPayload>(IShardedStreamable<TKey,TPayload>[]) |
Mevcut parçalı akışlanabilir öğeler kümesinden yeni bir parçalı akış yapılabilir örneği oluşturmak için oluşturucu |
| ShardedStreamable<TKey,TPayload>(IStreamable<TKey,TPayload>[]) |
Mevcut bir akışlanabilirler kümesinden yeni bir parçalı akışa alınabilen örnek oluşturmak için oluşturucu |
Alanlar
| _streamables |
Temel akış dizisi |
Yöntemler
| Broadcast(ILocationDescriptor) |
Parçalı akışla aktarılabilir bir yayın işlemi |
| Multicast(IDestinationDescriptor, ILocationDescriptor) |
Parçalı akışla aktarılabilir bir üzerinde çok noktaya yayın işlemi |
| Query<TOutput>(Expression<Func<IStreamable<TKey,TPayload>,IStreamable<TKey,TOutput>>>) |
Tüm parçalarda birli sorgu yürütme |
| Query<TPayload2,TOutput>(IShardedStreamable<TKey,TPayload2>, Expression<Func<IStreamable<TKey, TPayload>,IStreamable<TKey,TPayload2>,IStreamable<TKey,TOutput>>>) |
Tüm parçalarda ikili sorgu yürütme |
| ReDistribute(ILocationDescriptor) |
Verileri parçalar arasında yeniden dağıtma |
| ReKey<TNewKey>(Expression<Func<TPayload,TNewKey>>) |
Veri akışı parçalarını yeniden anahtarla |
| ReShard(ILocationDescriptor) |
Parçalı akış yapılabiliri yeniden parçala |
| SelectKey<TNewPayload>(Expression<Func<TKey,TPayload,TNewPayload>>) |
Eski yükleri ve parçalama anahtarlarını temel alarak yeni yükleri hesaplama |
| Split() |
Parçalı bir akışlanabiliri, her biri yalnızca bir parçadan oluşan parçalı akışlanabilir öğeler dizisine ayırma |
| Subscribe(IStreamObserver<TKey,TPayload>[]) |
Bir gözlemci dizisini temel alınan akışa bağlamak için zincirleme abone olma çağrısı |
Uzantı Metotları
| Shuffle<TKey,TNewKey,TPayload>(IShardedStreamable<TKey,TPayload>, Expression<Func<TPayload,TNewKey>>, ILocationDescriptor) |
Parçalı akışla aktarılabilir bir üzerinde karıştırma işlemi |
| Unshuffle<TKey,TPayload>(IShardedStreamable<TKey,TPayload>) |
Parçalı akışla aktarılabilir bir işlemde susturma işlemi (temel olarak, bir birim parçasına karıştırılan birleştirici karıştırma işlemidir) |
| WritePropertiesToStream<TKey,TPayload>(IShardedStreamable<TKey,TPayload>, Stream) |
Belirtilen .NET akışına akış özellikleri yazma |
| Cache<TKey,TPayload>(IShardedStreamable<TKey,TPayload>) |
Parçalı akışla aktarılabilir bir önbellek oluşturma |
| ToBinaryStream<TKey,TPayload>(IShardedStreamable<TKey,TPayload>, Stream[], Boolean, Boolean) |
Parçalı akıştan ikili akışlara veri akışı |