Streamable.RegisterInput Yöntem
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.
Aşırı Yüklemeler
| RegisterInput<TPartitionKey,TPayload>(QueryContainer, IObservable<PartitionedStreamEvent<TPartitionKey, TPayload>>, OnCompletedPolicy, PartitionedDisorderPolicy, PartitionedPeriodicPunctuationPolicy, String) |
PartitionedStreamEvents dizisini IStreamable'a dönüştürür.
Tamamlanma ilkesi, sonuçta elde edilen akış tamamlandığında ne yapacağını belirtir.
Bozukluk ilkesi, sıra dışı olaylarla ne yapılması gerekenleri belirtir.
Noktalama ilkesi, noktalama işaretlerinin oluşturulup oluşturulmadığını ve nasıl eklendiğini belirtir |
| RegisterInput<TPartitionKey,TPayload>(QueryContainer, IObservable<PartitionedStreamEvent<TPartitionKey, TPayload>>, OnCompletedPolicy, PartitionedPeriodicPunctuationPolicy, String) |
PartitionedStreamEvents dizisini IStreamable'a dönüştürür.
Tamamlanma ilkesi, sonuçta elde edilen akış tamamlandığında ne yapacağını belirtir.
Bozukluk ilkesi, sıra dışı olaylarla ne yapılması gerekenleri belirtir.
Noktalama ilkesi, noktalama işaretlerinin oluşturulup oluşturulmadığını ve nasıl eklendiğini belirtir |
| RegisterInput<TPartitionKey,TPayload>(QueryContainer, IObservable<ArraySegment<PartitionedStreamEvent<TPartitionKey, TPayload>>>, OnCompletedPolicy, String) |
PartitionedStreamEvents dizisini IStreamable'a dönüştürür.
Tamamlanma ilkesi, sonuçta elde edilen akış tamamlandığında ne yapacağını belirtir.
Bozukluk ilkesi, sıra dışı olaylarla ne yapılması gerekenleri belirtir.
Noktalama ilkesi, noktalama işaretlerinin oluşturulup oluşturulmadığını ve nasıl eklendiğini belirtir |
| RegisterInput<TPayload>(QueryContainer, IObservable<StreamEvent<TPayload>>, OnCompletedPolicy, PeriodicPunctuationPolicy, String) |
StreamEvents dizisini IStreamable'a dönüştürür.
Tamamlanma ilkesi, sonuçta elde edilen akış tamamlandığında ne yapacağını belirtir.
Bozukluk ilkesi, sıra dışı olaylarla ne yapılması gerekenleri belirtir.
Noktalama ilkesi, noktalama işaretlerinin oluşturulup oluşturulmadığını ve nasıl eklendiğini belirtir |
| RegisterInput<TPayload>(QueryContainer, IObservable<ArraySegment<StreamEvent<TPayload>>>, OnCompletedPolicy, String) |
StreamEvents dizisini IStreamable'a dönüştürür.
Tamamlanma ilkesi, sonuçta elde edilen akış tamamlandığında ne yapacağını belirtir.
Bozukluk ilkesi, sıra dışı olaylarla ne yapılması gerekenleri belirtir.
Noktalama ilkesi, noktalama işaretlerinin oluşturulup oluşturulmadığını ve nasıl eklendiğini belirtir |
| RegisterInput<TPayload>(QueryContainer, IObservable<StreamEvent<TPayload>>, OnCompletedPolicy, DisorderPolicy, PeriodicPunctuationPolicy, String) |
StreamEvents dizisini IStreamable'a dönüştürür.
Tamamlanma ilkesi, sonuçta elde edilen akış tamamlandığında ne yapacağını belirtir.
Bozukluk ilkesi, sıra dışı olaylarla ne yapılması gerekenleri belirtir.
Noktalama ilkesi, noktalama işaretlerinin oluşturulup oluşturulmadığını ve nasıl eklendiğini belirtir |
RegisterInput<TPartitionKey,TPayload>(QueryContainer, IObservable<PartitionedStreamEvent<TPartitionKey, TPayload>>, OnCompletedPolicy, PartitionedDisorderPolicy, PartitionedPeriodicPunctuationPolicy, String)
PartitionedStreamEvents dizisini IStreamable'a dönüştürür.
Tamamlanma ilkesi, sonuçta elde edilen akış tamamlandığında ne yapacağını belirtir.
Bozukluk ilkesi, sıra dışı olaylarla ne yapılması gerekenleri belirtir.
Noktalama ilkesi, noktalama işaretlerinin oluşturulup oluşturulmadığını ve nasıl eklendiğini belirtir
öğesini seçerek elde edilen akışa aktarın. Noktalama işaretleri çıkışı zorladığından, bu bir aktarım hızı/gecikme süresi dengesini ortaya çıkarır.
public static Microsoft.StreamProcessing.IPartitionedIngressStreamable<TPartitionKey,TPayload> RegisterInput<TPartitionKey,TPayload>(this Microsoft.StreamProcessing.QueryContainer container, IObservable<Microsoft.StreamProcessing.PartitionedStreamEvent<TPartitionKey,TPayload>> streamEvents, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy, Microsoft.StreamProcessing.PartitionedDisorderPolicy disorderPolicy = null, Microsoft.StreamProcessing.PartitionedPeriodicPunctuationPolicy periodicPunctuationPolicy = null, string identifier = null);static member RegisterInput : Microsoft.StreamProcessing.QueryContainer * IObservable<Microsoft.StreamProcessing.PartitionedStreamEvent<'PartitionKey, 'Payload>> * Microsoft.StreamProcessing.OnCompletedPolicy * Microsoft.StreamProcessing.PartitionedDisorderPolicy * Microsoft.StreamProcessing.PartitionedPeriodicPunctuationPolicy * string -> Microsoft.StreamProcessing.IPartitionedIngressStreamable<'PartitionKey, 'Payload>Tür Parametreleri
- TPartitionKey
Akış için bölüm anahtarının türü.
- TPayload
Akışın veri türü.
Parametreler
- container
- QueryContainer
Giriş noktasının kaydedildiği sorgu kapsayıcısı.
- streamEvents
- IObservable<PartitionedStreamEvent<TPartitionKey,TPayload>>
İstemci tarafından oluşturulan akış olayları dizisi.
- onCompletedPolicy
- OnCompletedPolicy
Akışın tamamlanmasını işleme.
- disorderPolicy
- PartitionedDisorderPolicy
Zaman sırasına göre olmayan olayları işleme.
- periodicPunctuationPolicy
- PartitionedPeriodicPunctuationPolicy
Sonuçta elde edilen akışa düzenli noktalama işaretleri eklenip eklenmeyeceği.
- identifier
- String
Sağlanırsa, sorguda girişi işaret etmek için tanımlanacak benzersiz bir ad.
Döndürülenler
Sorgularda kullanılabilecek bir IStreamable.
Özel durumlar
bir özel durum oluşturur ve disorderPolicy bir sıra dışı akış olayıyla karşılaşılırsa.
Ayrıca, herhangi bir yük null olduğunda bir özel durum oluşturulur.
Şunlara uygulanır
RegisterInput<TPartitionKey,TPayload>(QueryContainer, IObservable<PartitionedStreamEvent<TPartitionKey, TPayload>>, OnCompletedPolicy, PartitionedPeriodicPunctuationPolicy, String)
PartitionedStreamEvents dizisini IStreamable'a dönüştürür.
Tamamlanma ilkesi, sonuçta elde edilen akış tamamlandığında ne yapacağını belirtir.
Bozukluk ilkesi, sıra dışı olaylarla ne yapılması gerekenleri belirtir.
Noktalama ilkesi, noktalama işaretlerinin oluşturulup oluşturulmadığını ve nasıl eklendiğini belirtir
öğesini seçerek elde edilen akışa aktarın. Noktalama işaretleri çıkışı zorladığından, bu bir aktarım hızı/gecikme süresi dengesini ortaya çıkarır.
public static Microsoft.StreamProcessing.IPartitionedIngressStreamable<TPartitionKey,TPayload> RegisterInput<TPartitionKey,TPayload>(this Microsoft.StreamProcessing.QueryContainer container, IObservable<Microsoft.StreamProcessing.PartitionedStreamEvent<TPartitionKey,TPayload>> streamEvents, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy, Microsoft.StreamProcessing.PartitionedPeriodicPunctuationPolicy periodicPunctuationPolicy, string identifier = null);static member RegisterInput : Microsoft.StreamProcessing.QueryContainer * IObservable<Microsoft.StreamProcessing.PartitionedStreamEvent<'PartitionKey, 'Payload>> * Microsoft.StreamProcessing.OnCompletedPolicy * Microsoft.StreamProcessing.PartitionedPeriodicPunctuationPolicy * string -> Microsoft.StreamProcessing.IPartitionedIngressStreamable<'PartitionKey, 'Payload>Tür Parametreleri
- TPartitionKey
Akış için bölüm anahtarının türü.
- TPayload
Akışın veri türü.
Parametreler
- container
- QueryContainer
Giriş noktasının kaydedildiği sorgu kapsayıcısı.
- streamEvents
- IObservable<PartitionedStreamEvent<TPartitionKey,TPayload>>
İstemci tarafından oluşturulan akış olayları dizisi.
- onCompletedPolicy
- OnCompletedPolicy
Akışın tamamlanmasını işleme.
- periodicPunctuationPolicy
- PartitionedPeriodicPunctuationPolicy
Sonuçta elde edilen akışa düzenli noktalama işaretleri eklenip eklenmeyeceği.
- identifier
- String
Sağlanırsa, sorguda girişi işaret etmek için tanımlanacak benzersiz bir ad.
Döndürülenler
Sorgularda kullanılabilecek bir IStreamable.
Özel durumlar
Sıra dışı bir akış olayıyla karşılaşılırsa bir özel durum oluşturur. Ayrıca, herhangi bir yük null olduğunda bir özel durum oluşturulur.
Şunlara uygulanır
RegisterInput<TPartitionKey,TPayload>(QueryContainer, IObservable<ArraySegment<PartitionedStreamEvent<TPartitionKey, TPayload>>>, OnCompletedPolicy, String)
PartitionedStreamEvents dizisini IStreamable'a dönüştürür.
Tamamlanma ilkesi, sonuçta elde edilen akış tamamlandığında ne yapacağını belirtir.
Bozukluk ilkesi, sıra dışı olaylarla ne yapılması gerekenleri belirtir.
Noktalama ilkesi, noktalama işaretlerinin oluşturulup oluşturulmadığını ve nasıl eklendiğini belirtir
öğesini seçerek elde edilen akışa aktarın. Noktalama işaretleri çıkışı zorladığından, bu bir aktarım hızı/gecikme süresi dengesini ortaya çıkarır.
public static Microsoft.StreamProcessing.IPartitionedIngressStreamable<TPartitionKey,TPayload> RegisterInput<TPartitionKey,TPayload>(this Microsoft.StreamProcessing.QueryContainer container, IObservable<ArraySegment<Microsoft.StreamProcessing.PartitionedStreamEvent<TPartitionKey,TPayload>>> streamEvents, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy, string identifier = null);static member RegisterInput : Microsoft.StreamProcessing.QueryContainer * IObservable<ArraySegment<Microsoft.StreamProcessing.PartitionedStreamEvent<'PartitionKey, 'Payload>>> * Microsoft.StreamProcessing.OnCompletedPolicy * string -> Microsoft.StreamProcessing.IPartitionedIngressStreamable<'PartitionKey, 'Payload>Tür Parametreleri
- TPartitionKey
Akış için bölüm anahtarının türü.
- TPayload
Akışın veri türü.
Parametreler
- container
- QueryContainer
Giriş noktasının kaydedildiği sorgu kapsayıcısı.
- streamEvents
- IObservable<ArraySegment<PartitionedStreamEvent<TPartitionKey,TPayload>>>
İstemci tarafından oluşturulan akış olayları dizisi.
- onCompletedPolicy
- OnCompletedPolicy
Akışın tamamlanmasını işleme.
- identifier
- String
Sağlanırsa, sorguda girişi işaret etmek için tanımlanacak benzersiz bir ad.
Döndürülenler
Sorgularda kullanılabilecek bir IStreamable.
Özel durumlar
Sıra dışı bir akış olayıyla karşılaşılırsa bir özel durum oluşturur. Ayrıca, herhangi bir yük null olduğunda bir özel durum oluşturulur.
Şunlara uygulanır
RegisterInput<TPayload>(QueryContainer, IObservable<StreamEvent<TPayload>>, OnCompletedPolicy, PeriodicPunctuationPolicy, String)
StreamEvents dizisini IStreamable'a dönüştürür.
Tamamlanma ilkesi, sonuçta elde edilen akış tamamlandığında ne yapacağını belirtir.
Bozukluk ilkesi, sıra dışı olaylarla ne yapılması gerekenleri belirtir.
Noktalama ilkesi, noktalama işaretlerinin oluşturulup oluşturulmadığını ve nasıl eklendiğini belirtir
öğesini seçerek elde edilen akışa aktarın. Noktalama işaretleri çıkışı zorladığından, bu bir aktarım hızı/gecikme süresi dengesini ortaya çıkarır.
public static Microsoft.StreamProcessing.IObservableIngressStreamable<TPayload> RegisterInput<TPayload>(this Microsoft.StreamProcessing.QueryContainer container, IObservable<Microsoft.StreamProcessing.StreamEvent<TPayload>> streamEvents, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy, Microsoft.StreamProcessing.PeriodicPunctuationPolicy periodicPunctuationPolicy, string identifier = null);static member RegisterInput : Microsoft.StreamProcessing.QueryContainer * IObservable<Microsoft.StreamProcessing.StreamEvent<'Payload>> * Microsoft.StreamProcessing.OnCompletedPolicy * Microsoft.StreamProcessing.PeriodicPunctuationPolicy * string -> Microsoft.StreamProcessing.IObservableIngressStreamable<'Payload>Tür Parametreleri
- TPayload
Akışın veri türü.
Parametreler
- container
- QueryContainer
Giriş noktasının kaydedildiği sorgu kapsayıcısı.
- streamEvents
- IObservable<StreamEvent<TPayload>>
İstemci tarafından oluşturulan akış olayları dizisi.
- onCompletedPolicy
- OnCompletedPolicy
Akışın tamamlanmasını işleme.
- periodicPunctuationPolicy
- PeriodicPunctuationPolicy
Sonuçta elde edilen akışa düzenli noktalama işaretleri eklenip eklenmeyeceği.
- identifier
- String
Sağlanırsa, sorguda girişi işaret etmek için tanımlanacak benzersiz bir ad.
Döndürülenler
Sorgularda kullanılabilecek bir IStreamable.
Özel durumlar
Sıra dışı bir akış olayıyla karşılaşılırsa bir özel durum oluşturur. Ayrıca, herhangi bir yük null olduğunda bir özel durum oluşturulur.
Şunlara uygulanır
RegisterInput<TPayload>(QueryContainer, IObservable<ArraySegment<StreamEvent<TPayload>>>, OnCompletedPolicy, String)
StreamEvents dizisini IStreamable'a dönüştürür.
Tamamlanma ilkesi, sonuçta elde edilen akış tamamlandığında ne yapacağını belirtir.
Bozukluk ilkesi, sıra dışı olaylarla ne yapılması gerekenleri belirtir.
Noktalama ilkesi, noktalama işaretlerinin oluşturulup oluşturulmadığını ve nasıl eklendiğini belirtir
öğesini seçerek elde edilen akışa aktarın. Noktalama işaretleri çıkışı zorladığından, bu bir aktarım hızı/gecikme süresi dengesini ortaya çıkarır.
public static Microsoft.StreamProcessing.IObservableIngressStreamable<TPayload> RegisterInput<TPayload>(this Microsoft.StreamProcessing.QueryContainer container, IObservable<ArraySegment<Microsoft.StreamProcessing.StreamEvent<TPayload>>> streamEvents, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy, string identifier = null);static member RegisterInput : Microsoft.StreamProcessing.QueryContainer * IObservable<ArraySegment<Microsoft.StreamProcessing.StreamEvent<'Payload>>> * Microsoft.StreamProcessing.OnCompletedPolicy * string -> Microsoft.StreamProcessing.IObservableIngressStreamable<'Payload>Tür Parametreleri
- TPayload
Akışın veri türü.
Parametreler
- container
- QueryContainer
Giriş noktasının kaydedildiği sorgu kapsayıcısı.
- streamEvents
- IObservable<ArraySegment<StreamEvent<TPayload>>>
İstemci tarafından oluşturulan akış olayları dizisi.
- onCompletedPolicy
- OnCompletedPolicy
Akışın tamamlanmasını işleme.
- identifier
- String
Sağlanırsa, sorguda girişi işaret etmek için tanımlanacak benzersiz bir ad.
Döndürülenler
Sorgularda kullanılabilecek bir IStreamable.
Özel durumlar
Sıra dışı bir akış olayıyla karşılaşılırsa bir özel durum oluşturur. Ayrıca, herhangi bir yük null olduğunda bir özel durum oluşturulur.
Şunlara uygulanır
RegisterInput<TPayload>(QueryContainer, IObservable<StreamEvent<TPayload>>, OnCompletedPolicy, DisorderPolicy, PeriodicPunctuationPolicy, String)
StreamEvents dizisini IStreamable'a dönüştürür.
Tamamlanma ilkesi, sonuçta elde edilen akış tamamlandığında ne yapacağını belirtir.
Bozukluk ilkesi, sıra dışı olaylarla ne yapılması gerekenleri belirtir.
Noktalama ilkesi, noktalama işaretlerinin oluşturulup oluşturulmadığını ve nasıl eklendiğini belirtir
öğesini seçerek elde edilen akışa aktarın. Noktalama işaretleri çıkışı zorladığından, bu bir aktarım hızı/gecikme süresi dengesini ortaya çıkarır.
public static Microsoft.StreamProcessing.IObservableIngressStreamable<TPayload> RegisterInput<TPayload>(this Microsoft.StreamProcessing.QueryContainer container, IObservable<Microsoft.StreamProcessing.StreamEvent<TPayload>> streamEvents, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy, Microsoft.StreamProcessing.DisorderPolicy disorderPolicy = null, Microsoft.StreamProcessing.PeriodicPunctuationPolicy periodicPunctuationPolicy = null, string identifier = null);static member RegisterInput : Microsoft.StreamProcessing.QueryContainer * IObservable<Microsoft.StreamProcessing.StreamEvent<'Payload>> * Microsoft.StreamProcessing.OnCompletedPolicy * Microsoft.StreamProcessing.DisorderPolicy * Microsoft.StreamProcessing.PeriodicPunctuationPolicy * string -> Microsoft.StreamProcessing.IObservableIngressStreamable<'Payload>Tür Parametreleri
- TPayload
Akışın veri türü.
Parametreler
- container
- QueryContainer
Giriş noktasının kaydedildiği sorgu kapsayıcısı.
- streamEvents
- IObservable<StreamEvent<TPayload>>
İstemci tarafından oluşturulan akış olayları dizisi.
- onCompletedPolicy
- OnCompletedPolicy
Akışın tamamlanmasını işleme.
- disorderPolicy
- DisorderPolicy
Zaman sırasına göre olmayan olayları işleme.
- periodicPunctuationPolicy
- PeriodicPunctuationPolicy
Sonuçta elde edilen akışa düzenli noktalama işaretleri eklenip eklenmeyeceği.
- identifier
- String
Sağlanırsa, sorguda girişi işaret etmek için tanımlanacak benzersiz bir ad.
Döndürülenler
Sorgularda kullanılabilecek bir IStreamable.
Özel durumlar
bir özel durum oluşturur ve disorderPolicy bir sıra dışı akış olayıyla karşılaşılırsa.
Ayrıca, herhangi bir yük null olduğunda bir özel durum oluşturulur.