Aracılığıyla paylaş


IObservableIngressStreamable<TPayload> Arabirim

Tanım

Girişin sıra dışı olabileceği bir sorgunun giriş noktasında akışla aktarılabilir bir arabirim.

public interface IObservableIngressStreamable<TPayload> : Microsoft.StreamProcessing.IIngressStreamable<Microsoft.StreamProcessing.Empty,TPayload>, Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TPayload>
type IObservableIngressStreamable<'Payload> = interface
    interface IIngressStreamable<Empty, 'Payload>
    interface IStreamable<Empty, 'Payload>
Public Interface IObservableIngressStreamable(Of TPayload)
Implements IIngressStreamable(Of Empty, TPayload), IStreamable(Of Empty, TPayload)

Tür Parametreleri

TPayload

Giriş kaynağının yük nesnelerinin türü.

Uygulamalar

Özellikler

ErrorMessages

Kod oluşturma sırasında karşılaşılan hataları döndürür.

(Devralındığı yer: IStreamable<TKey,TPayload>)
IngressSiteIdentifier

Giriş sitesini çalışan bir sorguya göre benzersiz olarak tanımlayan tanımlayıcı.

(Devralındığı yer: IIngressStreamable<TKey,TPayload>)
Properties

Akışın sabit süreli bir akış olup olmadığı gibi akışın geçerli özelliklerini döndürür.

(Devralındığı yer: IStreamable<TKey,TPayload>)

Yöntemler

GetDroppedAdjustedEventsDiagnostic()

Sıra dışı varış nedeniyle bırakılması veya ayarlanması gereken akış olaylarının tanılama gözlemlenebilir bir değerini döndürür.

Subscribe(IStreamObserver<TKey,TPayload>)

Hemen akıştan gözlemciye olay göndermeye başlar.

(Devralındığı yer: IStreamable<TKey,TPayload>)

Uzantı Metotları

GetProperties<TKey,TPayload>(IStreamable<TKey,TPayload>, StreamProperties<TKey,TPayload>)

Out parametresini (özellikler) akışın geçerli özelliklerine ayarlar

SetProperties<TKey,TPayload>(IStreamable<TKey,TPayload>, StreamProperties<TKey,TPayload>)

Geçerli akış özelliklerini sağlanan bağımsız değişkene ayarlar (yeniÖzellikler)

SetProperty<TKey,TPayload>(IStreamable<TKey,TPayload>)

Akış için bir özellik ayarlayabileceğiniz bir moda girin.

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState4,TOutput4>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput>>)

Giriş akışındaki anlık görüntü pencerelerine birden çok toplama uygular.

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput>>)

Giriş akışındaki anlık görüntü pencerelerine birden çok toplama uygular.

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput6,TOutput>>)

Giriş akışındaki anlık görüntü pencerelerine birden çok toplama uygular.

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState7,TOutput7>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput>>)

Giriş akışındaki anlık görüntü pencerelerine birden çok toplama uygular.

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState8,TOutput8>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput>>)

Giriş akışındaki anlık görüntü pencerelerine birden çok toplama uygular.

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput6,TOutput7,TOutput8,TOutput9,TOutput>>)

Giriş akışındaki anlık görüntü pencerelerine birden çok toplama uygular.

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey,TInput>,IAggregate<TInput, TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState6,TOutput6>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState7,TOutput7>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState8,TOutput8>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState9,TOutput9>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState10,TOutput10>>, Expression<Func<TOutput1,TOutput2,TOutput3, TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10, TOutput>>)

Giriş akışındaki anlık görüntü pencerelerine birden çok toplama uygular.

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState11,TOutput11>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput11,TOutput>>)

Giriş akışındaki anlık görüntü pencerelerine birden çok toplama uygular.

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState12,TOutput12>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12, TOutput>>)

Giriş akışındaki anlık görüntü pencerelerine birden çok toplama uygular.

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TState13,TOutput13,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState13,TOutput13>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12, TOutput13,TOutput>>)

Giriş akışındaki anlık görüntü pencerelerine birden çok toplama uygular.

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TState13,TOutput13,TState14, TOutput14,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState14,TOutput14>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14,TOutput>>)

Giriş akışındaki anlık görüntü pencerelerine birden çok toplama uygular.

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TState13,TOutput13,TState14, TOutput14,TState15,TOutput15,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState14,TOutput14>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState15,TOutput15>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12, TOutput13,TOutput14,TOutput15,TOutput>>)

Giriş akışındaki anlık görüntü pencerelerine birden çok toplama uygular.

Aggregate<TKey,TInput,TState,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState,TOutput>>)

Giriş akışındaki anlık görüntü pencerelerine bir toplama uygular.

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Expression<Func<TOutput1,TOutput2,TOutput>>)

Giriş akışındaki anlık görüntü pencerelerine birden çok toplama uygular.

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput>>)

Giriş akışındaki anlık görüntü pencerelerine birden çok toplama uygular.

AlterEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)

Her olayın Ve'sini sağlanan süreye göre değiştirir

AlterEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64,Int64>>)

Her olayın Ve'sini, başlangıç ve bitiş saatlerinin işlevi olan durationSelector'a göre değiştirir

AlterEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>)

Her olayın Ve'sini başlangıç saatinin bir işlevi olan durationSelector'a göre değiştirir

AlterEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>, Int64)

Her olayın Vs ve Ve'sini değiştirir.

AlterEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>, Expression<Func<Int64,Int64,Int64>>)

Her olayın Vs ve Ve değerlerini startTimeSelector'a ve başlangıç ve bitiş saatlerinin işlevi olan durationSelector'a göre değiştirir

AlterEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>, Expression<Func<Int64,Int64>>)

Her olayın Vs ve Ve değerlerini startTimeSelector'a ve başlangıç saatinin işlevi olan durationSelector'a göre değiştirir

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak baytlar üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak ulong veri türü olduğunu unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak ondalık değerler üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak ondalık veri türü olduğunu unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak çiftler üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak çift veri türü olduğunu unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak kısa süreler üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak uzun bir veri türü olduğunu unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak int'ler üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak uzun bir veri türü olduğunu unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak uzun süreler boyunca zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak uzun bir veri türü olduğunu unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir baytlar üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak ulong veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir ondalıklar üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak ondalık veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir çiftler üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak bir çift veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak boş değer atanabilir kısalar üzerinden zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak uzun bir veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir int'ler üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak uzun bir veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir uzunlar üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak uzun bir veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak boş değer atanabilir BigInteger'lar üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak bigInteger veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir Karmaşıklar üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak karmaşık bir veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir sbaytlar üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak uzun bir veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir float'lar üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak bir float veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir ushortlar üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak ulong veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir uint'ler üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak ulong veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak boş değer atanabilir ulong'lar üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak ulong veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak BigInteger'lar üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak bir BigInteger veri türü olduğunu unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak Karmaşıklar üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak karmaşık bir veri türü olduğunu unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak sbaytlar üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak uzun bir veri türü olduğunu unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak float'lar üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak bir float veri türü olduğunu unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak ushort'lar üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak ulong veri türü olduğunu unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak uint'ler üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak ulong veri türü olduğunu unutmayın.

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak ulongs üzerinde zamana duyarlı ortalama toplamayı hesaplar. Akümülatörün dahili olarak ulong veri türü olduğunu unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak baytlar üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak ulong veri türü olduğunu unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak ondalıklar üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak ondalık veri türü olduğunu unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak çiftler üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak çift veri türü olduğunu unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak kısalar üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak uzun bir veri türü olduğunu unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak intler üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak uzun bir veri türü olduğunu unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak uzun süreler boyunca toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak uzun bir veri türü olduğunu unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak boş değer atanabilir baytlar üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak ulong veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir ondalıklar üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Biriktiricinin dahili olarak ondalık bir veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir çiftler üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. İç olarak biriktiricinin çift veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak boş değer atanabilir kısalar üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. İç olarak biriktiricinin uzun bir veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir int'ler üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. İç olarak biriktiricinin uzun bir veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null değer atanabilir uzunlar üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. İç olarak biriktiricinin uzun bir veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir BigInteger'lar üzerinde toplama karelerinin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak bir BigInteger veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir Karmaşıklar üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak Karmaşık bir veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir sbaytlar üzerinde toplanan karelerin zamana duyarlı ortalamasını hesaplar. İç olarak biriktiricinin uzun bir veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir float'lar üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak bir float veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir ushortlar üzerinde toplama karelerinin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak bir ulong veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir uint'ler üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak bir ulong veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir ulong'lar üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak bir ulong veri türü olduğunu ve null değerlerin ortalamayı etkilemediğini unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak BigIntegers üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak bir BigInteger veri türü olduğunu unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak Karmaşıklar üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak Karmaşık bir veri türü olduğunu unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak sbaytlar üzerinde toplanan karelerin zamana duyarlı ortalamasını hesaplar. Akümülatörün dahili olarak uzun bir veri türü olduğunu unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak kayanlar üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak float veri türü olduğunu unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak ushortlar üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak ulong veri türü olduğunu unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak uints üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak ulong veri türü olduğunu unutmayın.

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak ulongs üzerinde toplanan karelerin zamana duyarlı ortalamalarını hesaplar. Akümülatörün dahili olarak ulong veri türü olduğunu unutmayın.

Cache<TKey,TPayload>(IStreamable<TKey,TPayload>, UInt64, Boolean, Boolean)

Abone olmak için hemen yapılan bir çağrıda akışı yapılabilir tarafından hesaplanan tüm sonuçları önbelleğe alır. Bu
çağrısı, temel alınan sorgu tam olarak yürütülene ve sonuç önbelleğe alınana kadar engellenir.

Chop<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64)

Uzun süreli aralıkları ve kenarları beat sınırları boyunca kesmek (bölümlendirmek) için 'Chop' işlecini gerçekleştirir.

ClipEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)

Her olayın kesilmiş bir sürümünü geçirir; burada olay en fazla olay uzunluğu tarafından kesilir.

ClipEventDuration<TKey,TPayload,TClip>(IStreamable<TKey,TPayload>, IStreamable<TKey,TClip>)

Soldaki her olayın kesilmiş bir sürümünü geçirir; burada soldaki olay, soldan olaydan sonra Vs oluşan ilk olay tarafından kesilir. Birleştirme koşulunda kısıtlama yoktur.

ClipEventDuration<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey, TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,TJoinKey>>)

Soldaki her olayın kesilmiş bir sürümünü geçirir; burada soldaki olay, solda olaydan sonra Vs oluşan ilk olay tarafından kesilir, birleştirme koşulu karşılanır ve her iki akışın anahtarları da eşleşmektedir. Verimlilik için hızlı birleştirme anahtarı karşılaştırıcısı geçirilir.

ConsecutivePairs<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,TPayload,TResult>>)

Art arda tekrarlanan olay desenlerini bulur

Count<TKey,TPayload>(IStreamable<TKey,TPayload>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak zamana duyarlı bir sayı toplamını hesaplar.

CountNotNull<TKey,TPayload,TValue>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,TValue>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null olmayan değerlerin zamana duyarlı bir sayı toplamını hesaplar.

DefinePattern<TKey,TPayload>(IStreamable<TKey,TPayload>)

Giriş akışındaki verilerin eşleştirilebileceği bir desen tanımlama

DefinePattern<TKey,TPayload,TRegister,TAccumulator>(IStreamable<TKey,TPayload>, TRegister, TAccumulator)

Giriş akışındaki verilerin eşleştirilebileceği bir desen tanımlama

Detect<TKey,TPayload>(IStreamable<TKey,TPayload>, Func<IAbstractPatternRoot<TKey, TPayload,Empty,Boolean>,IPattern<TKey,TPayload,Empty,Boolean>>, Int64, Boolean, Boolean)

Gelen akış üzerinde bir desen algılama. Genişletilmiş normal ifadeyi giriş olarak alır. Regex.* API'sini veya doğrudan AFA belirtimini kullanarak AFA oluşturun.

Detect<TKey,TPayload,TRegister>(IStreamable<TKey,TPayload>, TRegister, Func<IAbstractPatternRoot<TKey,TPayload,TRegister,Boolean>,IPattern<TKey, TPayload,TRegister,Boolean>>, Int64, Boolean, Boolean)

Gelen akış üzerinde bir desen algılama. Genişletilmiş normal ifadeyi giriş olarak alır. Regex.* API'sini veya doğrudan AFA belirtimini kullanarak AFA oluşturun.

Detect<TKey,TPayload,TRegister,TAccumulator>(IStreamable<TKey, TPayload>, TRegister, TAccumulator, Func<IAbstractPatternRoot<TKey, TPayload,TRegister,TAccumulator>,IPattern<TKey,TPayload,TRegister, TAccumulator>>, Int64, Boolean, Boolean)

Gelen akış üzerinde bir desen algılama. Genişletilmiş normal ifadeyi giriş olarak alır. Regex.* API'sini veya doğrudan AFA belirtimini kullanarak AFA oluşturun.

Detect<TKey,TPayload,TRegister,TAccumulator>(IStreamable<TKey,TPayload>, Afa<TPayload,TRegister,TAccumulator>, Int64, Boolean, Boolean)

Gelen akış üzerinde bir desen algılama. Giriş olarak genişletilmiş sonlu otomatik makro (AFA) alır. Regex.* API'sini veya doğrudan AFA belirtimini kullanarak AFA oluşturun.

Distinct<TKey,TPayload>(IStreamable<TKey,TPayload>)

Her anlık görüntüde yinelenen girdileri filtreleme

Distinct<TKey,TInput,TResult>(IStreamable<TKey,TInput>, Expression<Func<TInput,TResult>>)

Zaman damgası başına kısmi yinelemeleri kaldırır. Verilen ifadeyle ve bunların zaman damgalarıyla eşleşen iki olay varsa, bunlar yinelenen olarak kabul edilir.

ExtendLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)

Tüm olay yaşam sürelerini sabit bir miktar genişleten bir akış oluşturun.

FollowedByImmediate<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Boolean>>, Expression<Func<TPayload, Boolean>>, Expression<Func<TPayload,TPayload,TResult>>, Int64)

Belirli bir süre içinde (kesinlikle daha az) gerçekleşen ve hemen ardından B (başka ara olaylar olmadan) gelen A desenlerini bulur

FollowedByImmediate<TKey,TPayload,TPayload2,TResult>(IStreamable<TKey, TPayload>, IStreamable<TKey,TPayload2>, Expression<Func<TPayload, Boolean>>, Expression<Func<TPayload2,Boolean>>, Expression<Func<TPayload, TPayload2,TResult>>, Int64)

Belirli bir süre içinde (kesinlikle küçüktür) gerçekleşen, solda A desenlerini ve ardından hemen sağda B'yi bulur (başka ara olaylar olmadan)

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput>>)

Giriş olaylarını bir anahtar seçiciye göre gruplar ve her gruptaki "anlık görüntü pencereleri" (SI terminolojisi) için birden çok toplama uygular.

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput>>)

Giriş olaylarını bir anahtar seçiciye göre gruplar ve her gruptaki "anlık görüntü pencereleri" (SI terminolojisi) için birden çok toplama uygular.

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput>>)

Giriş olaylarını bir anahtar seçiciye göre gruplar ve her gruptaki "anlık görüntü pencereleri" (SI terminolojisi) için birden çok toplama uygular.

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput>>)

Giriş olaylarını bir anahtar seçiciye göre gruplar ve her gruptaki "anlık görüntü pencereleri" (SI terminolojisi) için birden çok toplama uygular.

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput>>)

Giriş olaylarını bir anahtar seçiciye göre gruplar ve her gruptaki "anlık görüntü pencereleri" (SI terminolojisi) için birden çok toplama uygular.

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput>>)

Giriş olaylarını bir anahtar seçiciye göre gruplar ve her gruptaki "anlık görüntü pencereleri" (SI terminolojisi) için birden çok toplama uygular.

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput>>)

Giriş olaylarını bir anahtar seçiciye göre gruplar ve her gruptaki "anlık görüntü pencereleri" (SI terminolojisi) için birden çok toplama uygular.

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput>>)

Giriş olaylarını bir anahtar seçiciye göre gruplar ve her gruptaki "anlık görüntü pencereleri" (SI terminolojisi) için birden çok toplama uygular.

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput>>)

Giriş olaylarını bir anahtar seçiciye göre gruplar ve her gruptaki "anlık görüntü pencereleri" (SI terminolojisi) için birden çok toplama uygular.

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TState12,TOutput12,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput>>)

Giriş olaylarını bir anahtar seçiciye göre gruplar ve her gruptaki "anlık görüntü pencereleri" (SI terminolojisi) için birden çok toplama uygular.

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TState12,TOutput12,TState13,TOutput13, TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput>>)

Giriş olaylarını bir anahtar seçiciye göre gruplar ve her gruptaki "anlık görüntü pencereleri" (SI terminolojisi) için birden çok toplama uygular.

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TState12,TOutput12,TState13,TOutput13, TState14,TOutput14,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState14,TOutput14>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14, TOutput>>)

Giriş olaylarını bir anahtar seçiciye göre gruplar ve her gruptaki "anlık görüntü pencereleri" (SI terminolojisi) için birden çok toplama uygular.

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TState12,TOutput12,TState13,TOutput13, TState14,TOutput14,TState15,TOutput15,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState14,TOutput14>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState15,TOutput15>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14, TOutput15,TOutput>>)

Giriş olaylarını bir anahtar seçiciye göre gruplar ve her gruptaki "anlık görüntü pencereleri" (SI terminolojisi) için birden çok toplama uygular.

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput>>)

Giriş olaylarını bir anahtar seçiciye göre gruplar ve her gruptaki "anlık görüntü pencereleri" (SI terminolojisi) için bir toplama uygular.

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput>>)

Giriş olaylarını bir anahtar seçiciye göre gruplar ve her gruptaki "anlık görüntü pencereleri" (SI terminolojisi) için birden çok toplama uygular.

GroupApply<TOuterKey,TPayload,TInnerKey,TResult>(IStreamable<TOuterKey, TPayload>, Expression<Func<TPayload,TInnerKey>>, Func<IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TPayload>,IStreamable<CompoundGroupKey<TOuterKey,TInnerKey>, TResult>>)

Akışta bir grup ve uygulama işlemi gerçekleştirir.

GroupApply<TOuterKey,TPayload,TInnerKey,TBind,TResult>(IStreamable<TOuterKey, TPayload>, Expression<Func<TPayload,TInnerKey>>, Func<IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TPayload>,IStreamable<CompoundGroupKey<TOuterKey,TInnerKey>, TBind>>, Expression<Func<GroupSelectorInput<TInnerKey>,TBind, TResult>>)

Akışta bir grup ve uygulama işlemi gerçekleştirir.

GroupBy<TOuterKey,TPayload,TInnerKey>(IStreamable<TOuterKey,TPayload>, Expression<Func<TPayload,TInnerKey>>)

Kavrama söz dizimini mutlu etmek için gereklidir. Bunun yerine GroupApply kullanmayı göz önünde bulundurun.

HoppingWindowLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64, Int64)

Toplamalar, atlama pencereleri ile birlikte kullanıldığında uygulanacak gelen olayların ömrünü ayarlar. Bu uygulamada her gelen olay tek bir giden olayla sonuçlandığından sonraki toplamalar yalnızca giriş değiştiğinde çıkış üretir. Örneğin, tek bir nokta olayı alınırsa ve windowSize, period ve offset sırasıyla 100, 2 ve 0 ise, yaşam süresi 100 değer çizgisi olan tek bir toplama çıkışı oluşturulur.

Join<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TRight,TResult>>)

2 akış arasında çapraz ürün gerçekleştirir

Join<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TRight,TResult>>, Int64)

2 akış arasında çapraz ürün gerçekleştirir

Join<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,TResult>>)

Birleştirme anahtarının TJoinKey türünde olduğu ve birleştirme anahtarlarını yüklerden ayıklamak için seçicilerin geçirildiği 2 akış arasında bir eş birleşim gerçekleştirir

Join<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,TResult>>, OperationalHint)

Birleştirme anahtarının TJoinKey türünde olduğu ve birleştirme anahtarlarını yüklerden ayıklamak için seçicilerin geçirildiği 2 akış arasında bir eş birleşim gerçekleştirir

Join<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,TResult>>, Int64, OperationalHint)

Birleştirme anahtarının TJoinKey türünde olduğu ve birleştirme anahtarlarını yüklerden ayıklamak için seçicilerin geçirildiği 2 akış arasında bir eş birleşim gerçekleştirir

LeftOuterJoin<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey, TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,TJoinKey>>, Expression<Func<TLeft,TRight, Boolean>>, Expression<Func<TLeft,TResult>>, Expression<Func<TLeft, TRight,TResult>>)

Girişin sıra dışı olabileceği bir sorgunun giriş noktasında akışla aktarılabilir bir arabirim.

LeftOuterJoin<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey, TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,TJoinKey>>, Expression<Func<TLeft,TResult>>, Expression<Func<TLeft,TRight,TResult>>)

Sol dış birleştirme işlemi gerçekleştirmek için makro.

LeftOuterJoin<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey, TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,TJoinKey>>, Expression<Func<TLeft,TResult>>, Expression<Func<TLeft,TRight,TResult>>, Int64)

Sol dış birleştirme işlemi gerçekleştirmek için makro.

Map<TOuterKey,TMapInput,TReduceInput>(IStreamable<TOuterKey,TMapInput>, Func<IStreamable<TOuterKey,TMapInput>,IStreamable<TOuterKey,TReduceInput>>)

Tek bir giriş yalnızca eşleme işleminin Eşleme aşaması. Eşleyicide akış mantığının belirtimine izin verir.

Map<TOuterKey,TMapInput,TInnerKey,TReduceInput>(IStreamable<TOuterKey, TMapInput>, Func<IStreamable<TOuterKey,TMapInput>,IStreamable<TOuterKey, TReduceInput>>, Expression<Func<TReduceInput,TInnerKey>>)

Tek bir giriş eşleme/azaltma işleminin Eşleme aşaması. Eşleyicide akış mantığının belirtimine ve sonraki (azaltma) aşama için bir anahtar seçiciye izin verir.

Max<TKey,TPayload>(IStreamable<TKey,TPayload>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak zamana duyarlı maksimum toplamayı hesaplar.

Max<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Comparison<TPayload>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak zamana duyarlı maksimum toplamayı hesaplar.

Max<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak zamana duyarlı maksimum toplamayı hesaplar.

Max<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Expression<Comparison<T>>)

Sağlanan sıralama karşılaştırıcısıyla "anlık görüntü pencereleri" (SI terminolojisi) kullanarak zamana duyarlı maksimum toplamayı hesaplar.

Min<TKey,TPayload>(IStreamable<TKey,TPayload>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak zamana duyarlı minimum toplamayı hesaplar.

Min<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Comparison<TPayload>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak zamana duyarlı minimum toplamayı hesaplar.

Min<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak zamana duyarlı minimum toplamayı hesaplar.

Min<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Expression<Comparison<T>>)

Sağlanan sıralama karşılaştırıcısıyla "anlık görüntü pencereleri" (SI terminolojisi) kullanarak zamana duyarlı minimum toplamayı hesaplar.

Multicast<TKey,TPayload>(IStreamable<TKey,TPayload>, Int32)

Bir akış üzerinden çok noktaya yayın gerçekleştirir. Bu, sorgu yazıcılarının aynı fiziksel giriş akışı üzerinde birden çok alt sorgu yürütmesine olanak tanır.

Multicast<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Func<IStreamable<TKey,TPayload>,IStreamable<TKey,TResult>>)

Bir akış üzerinden çok noktaya yayın gerçekleştirir. Bu, sorgu yazıcılarının aynı fiziksel giriş akışı üzerinde birden çok alt sorgu yürütmesine olanak tanır.

Multicast<TKey,TPayloadLeft,TPayloadRight,TResult>(IStreamable<TKey, TPayloadLeft>, IStreamable<TKey,TPayloadRight>, Func<IStreamable<TKey, TPayloadLeft>,IStreamable<TKey,TPayloadRight>,IStreamable<TKey, TResult>>)

Bir akış üzerinden çok noktaya yayın gerçekleştirir. Bu, sorgu yazıcılarının aynı fiziksel giriş akışı üzerinde birden çok alt sorgu yürütmesine olanak tanır.

Pivot<TKey,TInput,TOutput,TGroupKey,TValue,TAggValue,TState>(IStreamable<TKey, TInput>, Expression<Func<TOutput>>, Expression<Func<TInput,TGroupKey>>, Expression<Func<TInput,String>>, Expression<Func<TInput,TValue>>, Func<Window<CompoundGroupKey<TKey,TGroupKey>,TValue>,IAggregate<TValue, TState,TAggValue>>)

Girişin sıra dışı olabileceği bir sorgunun giriş noktasında akışla aktarılabilir bir arabirim.

PointAtEnd<TKey,TPayload>(IStreamable<TKey,TPayload>)

Tüm deaccumulations'ı yalnızca ekleme noktası akışı olarak bildiren bir akış oluşturun (tüm olayları sonunda nokta olaylarına dönüştürür).

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak baytlar üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak ondalık değerler üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak çiftler üzerinde zamana duyarlı ürün toplamayı hesaplar.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak kısa devreler üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak int'ler üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak uzun süreler boyunca zamana duyarlı bir ürün toplama işlemi hesaplar.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir baytlar üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir ondalıklar üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir çiftler üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir kısa değerler üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir int'ler üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir süreler üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir BigInteger'lar üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir Karmaşıklar üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir sbaytlar üzerinde zamana duyarlı ürün toplamasını hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir float'lar üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir ushortlar üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir uint'ler üzerinde zamana duyarlı ürün toplamayı hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir ulongs üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak BigIntegers üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak Karmaşıklar üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak sbaytlar üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak float'lar üzerinde zamana duyarlı bir ürün toplama işlemi hesaplar.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak ushorts üzerinden zamana duyarlı bir ürün toplama işlemi hesaplar.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak uint'ler üzerinde zamana duyarlı ürün toplamayı hesaplar.

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak ulongs üzerinde zamana duyarlı ürün toplamayı hesaplar.

Publish<TKey,TPayload>(IStreamable<TKey,TPayload>)

Çok noktaya yayının dinamik sürümünü akışla aktarılabilir bir sürüm üzerinden gerçekleştirir. Bu, sorgu yazıcılarının aynı fiziksel giriş akışı üzerinde birden çok alt sorgu yürütmesine olanak tanır. Akışlar eklenebilir veya kaldırılabilir. Akışın uç kenarları olmadığından emin olmak kullanıcıya bağlıdır, aksi takdirde dinamik olarak abone olunan abone yanlış biçimlendirilmiş bir akış alabilir (buna karşılık gelen başlangıç kenarı olmadan uç uç). Kullanım: akış. Yayımla(); Akışı. Abone Ol(...); Akışı. Bağlan(); Akışı. Abone Ol(...);

QuantizeLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64, Int64)

Gelen olayların yaşam süresini ayarlayarak her olayın başlangıç ve bitiş saatini niceli sınırlara uydurır. İşlev, atlamalı yaşam süresi ifadelerine benzer, ancak tüm başlangıç kenarları daha önce taşınır veya aynı kalır ve tüm uç kenarlar daha sonra hareket eder veya aynı kalır.

RepetitiveHoppingWindowLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64, Int64)

Toplamalar, yinelenen atlamalı pencerelerle birlikte kullanıldığında uygulanacak gelen olayların ömrünü ayarlar. Bu uygulamada her gelen olay rastgele sayıda giden olayla sonuçlanabilir. Örneğin, tek bir nokta olayı alınırsa ve windowSize, period ve offset sırasıyla 100, 2 ve 0 ise, her biri yaşam süresi 2 değer çizgisi olan 50 özdeş toplama çıkışı oluşturulur.

Select<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,TResult>>)

Bir akışı yapılabilir üzerinden bir proje gerçekleştirir.

Select<TKey,TOld,TNew>(IStreamable<TKey,TOld>, Expression<Func<TNew>>, IDictionary<String,Expression<Func<TOld,Object>>>)

Girişin sıra dışı olabileceği bir sorgunun giriş noktasında akışla aktarılabilir bir arabirim.

Select<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TPayload,TResult>>)

Bir akışı yapılabilir üzerinden bir proje gerçekleştirir.

Select<TKey,TOld,TNew,TField1>(IStreamable<TKey,TOld>, Expression<Func<TNew>>, Expression<Func<TNew,TField1>>, Expression<Func<TOld,TField1>>)

Girişin sıra dışı olabileceği bir sorgunun giriş noktasında akışla aktarılabilir bir arabirim.

Select<TKey,TOld,TNew,TField1,TField2>(IStreamable<TKey,TOld>, Expression<Func<TNew>>, Expression<Func<TNew,TField1>>, Expression<Func<TOld, TField1>>, Expression<Func<TNew,TField2>>, Expression<Func<TOld, TField2>>)

Girişin sıra dışı olabileceği bir sorgunun giriş noktasında akışla aktarılabilir bir arabirim.

SelectBatch<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Action<TPayload[],TResult[]>>)

Akışa alınabilen bir dönüştürme gerçekleştirir, yükleri dönüştürülecek toplu iş olarak gruplandırır ve doldurulacak bir çıkış toplu işlemi sağlar. NOT: Bu yöntemin hedeflenen semantiği, Tek tek satırlar üzerinde Select ile eşdeğerdir. Bu semantiğin sağlandığından emin olmak bu yöntemi çağırana bağlıdır.

SelectByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TKey,TPayload,TResult>>)

Gruplandırma anahtarına göre akışla aktarılabilir bir proje gerçekleştirir.

SelectByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TKey,TPayload,TResult>>)

Gruplandırma anahtarına göre akışla aktarılabilir bir proje gerçekleştirir.

SelectMany<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,IEnumerable<TResult>>>)

Bu seçim çok, birden çok yük oluşturmak için kullanılır

SelectMany<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TPayload,IEnumerable<TResult>>>)

Bu seçim çok, birden çok yük oluşturmak için kullanılır

SelectMany<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, Func<Empty,IStreamable<TKey,TRight>>, Expression<Func<TLeft,TRight,TResult>>)

Bu select many, kavrama söz diziminden türetilen birleşimlerin yanı sıra Grup ve Uygula'daki boş olmayan azaltıcılar için kullanılır

SelectManyByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TKey,TPayload,IEnumerable<TResult>>>)

Bu seçim çok, birden çok yük oluşturmak için kullanılır

SelectManyByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TKey,TPayload,IEnumerable<TResult>>>)

Bu seçim çok, birden çok yük oluşturmak için kullanılır

Sessionize<TKey,TPayload,TSessionKey,TResult>(IStreamable<TKey, TPayload>, Expression<Func<TPayload,Boolean>>, Expression<Func<TPayload, Boolean>>, Expression<Func<TPayload,TSessionKey>>, Expression<Func<TPayload, TPayload,TResult>>)

Başlangıç ve bitiş oturumlarının akışını, son oturumdaki verileri önemsediğimiz tek bir oturum başına akışa dönüştürün. Oturumlar, bitiş oturumunun zaman damgasında nokta olayları olarak çıkış olarak görüntülenir.

SessionTimeoutWindow<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64)

Pencere türü, Trill'de zaman aşımı olan oturumları uygular. Belirtilen zaman aşımı süresi içinde yeni olaylar geldiği sürece geçerli pencere genişletilir. Zaman aşımı süresi veri olmadan geçtikten sonra (belirli bir gruplandırma anahtarı için) pencere kapatılır.

ShiftEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)

Yaşam süresini belirtilen süreye göre değiştirir

ShiftEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>)

Etkinlik başlangıç saatinin bir işlevi olan shiftSelector tarafından yaşam süresini kaydırır

Stitch<TKey,TPayload>(IStreamable<TKey,TPayload>)

Stitch, 'Chop' işlecinin tersidir: aynı anda bir END yükü ve BEGIN yükü bulduğunda, her ikisini de akıştan kaldırır. Bunun net etkisi, sinyaldeki bir değerin değişmemesi durumunda akışın yeni olaylara sahip olmamasıdır. Bu çoğunlukla insan gözleri için yararlıdır; mathemtik olarak ikisi aynı olmalıdır

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak baytlar üzerinde zamana duyarlı toplam toplamını hesaplar.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak ondalık basamaklar üzerinde zamana duyarlı bir toplama hesaplar.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak çiftler üzerinde zamana duyarlı bir toplama işlemi hesaplar.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak kısalar üzerinde zamana duyarlı bir toplama hesaplar.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak int'ler üzerinde zamana duyarlı bir toplama işlemi hesaplar.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak uzun süreler boyunca zamana duyarlı toplam toplamayı hesaplar.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir baytlar üzerinde zamana duyarlı bir toplama hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir ondalıklar üzerinde zamana duyarlı bir toplama hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir çiftler üzerinde zamana duyarlı bir toplama hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null değer atanabilir kısalar üzerinde zamana duyarlı bir toplama işlemi hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir int'ler üzerinde zamana duyarlı bir toplam hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null değer atanabilir uzunlar üzerinde zamana duyarlı bir toplama işlemi hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir BigInteger'lar üzerinde zamana duyarlı bir toplama hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir Karmaşıklar üzerinde zamana duyarlı bir toplama hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir sbaytlar üzerinde zamana duyarlı bir toplama hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir float'lar üzerinde zamana duyarlı toplam toplamayı hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir ushortlar üzerinde zamana duyarlı bir toplam hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir uint'ler üzerinde zamana duyarlı bir toplama hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir ulong'lar üzerinde zamana duyarlı toplam toplamayı hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak BigInteger'lar üzerinde zamana duyarlı bir toplama işlemi hesaplar.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak Karmaşıklar üzerinde zamana duyarlı bir toplama işlemi hesaplar.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak sbaytlar üzerinde zamana duyarlı bir toplam hesaplar.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak float'lar üzerinde zamana duyarlı bir toplama işlemi hesaplar.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak ushorts üzerinden zamana duyarlı bir toplama hesaplar.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak uints üzerinde zamana duyarlı bir toplama işlemi hesaplar.

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak ulongs üzerinde zamana duyarlı bir toplama işlemi hesaplar.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak baytlar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak ondalıklar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak çiftler üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak kısalar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak int'ler üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak uzun süreler boyunca toplanan karelerin zamana duyarlı toplamını hesaplar.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir baytlar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir ondalıklar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir çiftler üzerinde toplama karelerinin zamana duyarlı toplamını hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak boş değer atanabilir kısalar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir intler üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null değer atanabilir uzunlar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir BigInteger'lar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir Karmaşıklar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir sbaytlar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir float'lar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir ushortlar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir uint'ler üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak null atanabilir ulong'lar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar. Null değerlerin toplamı etkilemediğini unutmayın.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak BigIntegers üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak Karmaşıklar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak sbaytlar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak kayanlar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak ushortlar üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak uints üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar.

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)

"Anlık görüntü pencereleri" (SI terminolojisi) kullanarak ulongs üzerinde toplanan karelerin zamana duyarlı toplamını hesaplar.

ToBinaryStream<TKey,TPayload>(IStreamable<TKey,TPayload>, Stream, Boolean)

Akışı ikili akışa seri hale getirme

ToBinaryStream<TKey,TPayload>(IStreamable<TKey,TPayload>, String)

Streamble'i ikili dosyada seri hale getirme

TopK<TKey,TPayload>(IStreamable<TKey,TPayload>, Int32)

Anahtar seçiciyi temel alan "anlık görüntü pencereleri" (SI terminolojisi) kullanarak zamana duyarlı top-k toplamayı hesaplar.

TopK<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Comparison<TPayload>>, Int32)

Anahtar seçiciyi temel alan "anlık görüntü pencereleri" (SI terminolojisi) kullanarak zamana duyarlı top-k toplamayı hesaplar.

TopK<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Int32)

Anahtar seçiciyi temel alan "anlık görüntü pencereleri" (SI terminolojisi) kullanarak zamana duyarlı top-k toplamayı hesaplar.

TopK<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Expression<Comparison<T>>, Int32)

Sağlanan sıralama karşılaştırıcısıyla bir anahtar seçiciyi temel alarak "anlık görüntü pencereleri" (SI terminolojisi) kullanarak zamana duyarlı üst k toplamayı hesaplar.

TumblingWindowLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64)

Toplamalar, atlayan pencerelerle birlikte kullanıldığında uygulanacak gelen olayların ömrünü ayarlar. Bu uygulamada her gelen olay tek bir giden olayla sonuçlandığından sonraki toplamalar yalnızca giriş değiştiğinde çıkış üretir. Örneğin, tek bir nokta olayı alınırsa ve tumbleDuration ve ofset sırasıyla 100 ve 0 ise, yaşam süresi 100 değer çizgisi olan tek bir toplama çıkışı oluşturulur.

Union<TKey,TPayload>(IStreamable<TKey,TPayload>, IStreamable<TKey,TPayload>)

Birleşim, like şemasının iki akışını birleştiren zamana bağlı bir birleşimdir

Unpivot<TKey,TInput,TPivotKey,TValue,TResult>(IStreamable<TKey, TInput>, Expression<Func<TResult>>, Expression<Func<TInput,TPivotKey>>, Expression<Func<TResult,String>>, Expression<Func<TResult,TValue>>)

Bir yük nesneleri akışını, giriş yüklerindeki verilere karşılık gelen anahtar-öznitelik-değer üçlü akışına döndürür.

Where<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Boolean>>)

Koşulun false olarak değerlendirildiği satırları hariç tutarak akış yapılabilir bir filtre gerçekleştirir.

WhereNotExists<TKey,TLeft,TRight>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>)

Herhangi bir birleştirme koşulu olmadan sol yarıya karşı birleştirme gerçekleştirir (birleştirme koşulu doğrudur).

WhereNotExists<TKey,TLeft,TRight>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Int64)

Herhangi bir birleştirme koşulu olmadan sol yarıya karşı birleştirme gerçekleştirir (birleştirme koşulu doğrudur).

WhereNotExists<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>)

Birleştirme koşulu olarak geçirilen koşulunu kullanarak sol yarıya karşı birleştirme gerçekleştirir.

WhereNotExists<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Int64)

Birleştirme koşulu olarak geçirilen koşulunu kullanarak sol yarıya karşı birleştirme gerçekleştirir.

WhereNotExists<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,Boolean>>)

Girişin sıra dışı olabileceği bir sorgunun giriş noktasında akışla aktarılabilir bir arabirim.

Şunlara uygulanır