IConnectableStreamable<TKey,TPayload> Interfejs

Odwołanie

Definicja

Przestrzeń nazw:: Microsoft.StreamProcessing

Zestaw:: Microsoft.StreamProcessing.dll

Ważne

Niektóre informacje odnoszą się do produktu w wersji wstępnej, który może zostać znacząco zmodyfikowany przed wydaniem. Firma Microsoft nie udziela żadnych gwarancji, jawnych lub domniemanych, w odniesieniu do informacji podanych w tym miejscu.

Interfejs umożliwiający dynamiczne łączenie nowych strumieniowych danych wyjściowych z istniejącym strumieniem

public interface IConnectableStreamable<TKey,TPayload> : Microsoft.StreamProcessing.IStreamable<TKey,TPayload>

type IConnectableStreamable<'Key, 'Payload> = interface
    interface IStreamable<'Key, 'Payload>

Public Interface IConnectableStreamable(Of TKey, TPayload)
Implements IStreamable(Of TKey, TPayload)

Parametry typu

TKey

Grupowanie typu klucza dla danych przepływających przez system

TPayload

Typ ładunku zdarzenia dla danych przepływających przez system

Implementuje: IStreamable<TKey,TPayload>

Właściwości

ErrorMessages	Zwraca wszelkie błędy, które wystąpiły podczas generowania kodu. (Odziedziczone po IStreamable<TKey,TPayload>)
Properties	Zwraca bieżące właściwości strumienia, takie jak to, czy strumień jest strumieniem o stałym czasie trwania. (Odziedziczone po IStreamable<TKey,TPayload>)

Metody

Connect()	Połączenie ustanawia nadrzędne przetwarzanie strumienia.
Subscribe(IStreamObserver<TKey,TPayload>)	Natychmiast rozpoczyna wysyłanie zdarzeń ze strumienia do obserwatora. (Odziedziczone po IStreamable<TKey,TPayload>)

Metody rozszerzania

GetProperties<TKey,TPayload>(IStreamable<TKey,TPayload>, StreamProperties<TKey,TPayload>)	Ustawia parametr out (właściwości) na bieżące właściwości strumienia
SetProperties<TKey,TPayload>(IStreamable<TKey,TPayload>, StreamProperties<TKey,TPayload>)	Ustawia bieżące właściwości strumienia na podany argument (newProperties)
SetProperty<TKey,TPayload>(IStreamable<TKey,TPayload>)	Wprowadź tryb, w którym można ustawić właściwość strumienia.
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>>)	Stosuje wiele agregacji do okien migawek w strumieniu wejściowym.
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>>)	Stosuje wiele agregacji do okien migawek w strumieniu wejściowym.
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>>)	Stosuje wiele agregacji do okien migawek w strumieniu wejściowym.
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>>)	Stosuje wiele agregacji do okien migawek w strumieniu wejściowym.
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>>)	Stosuje wiele agregacji do okien migawek w strumieniu wejściowym.
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>>)	Stosuje wiele agregacji do okien migawek w strumieniu wejściowym.
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>>)	Stosuje wiele agregacji do okien migawek w strumieniu wejściowym.
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>>)	Stosuje wiele agregacji do okien migawek w strumieniu wejściowym.
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>>)	Stosuje wiele agregacji do okien migawek w strumieniu wejściowym.
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>>)	Stosuje wiele agregacji do okien migawek w strumieniu wejściowym.
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>>)	Stosuje wiele agregacji do okien migawek w strumieniu wejściowym.
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>>)	Stosuje wiele agregacji do okien migawek w strumieniu wejściowym.
Aggregate<TKey,TInput,TState,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState,TOutput>>)	Stosuje agregację do okien migawek w strumieniu wejściowym.
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>>)	Stosuje wiele agregacji do okien migawek w strumieniu wejściowym.
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>>)	Stosuje wiele agregacji do okien migawek w strumieniu wejściowym.
AlterEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)	Zmienia ve każdego zdarzenia zgodnie z podanym czasem trwania
AlterEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64,Int64>>)	Zmienia wartość Ve każdego zdarzenia zgodnie z czasem trwaniaSelector, który jest funkcją godzin rozpoczęcia i zakończenia
AlterEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>)	Zmienia wartość Ve każdego zdarzenia zgodnie z czasem trwaniaSelector, który jest funkcją czasu rozpoczęcia
AlterEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>, Int64)	Zmienia element Vs i Ve każdego zdarzenia.
AlterEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>, Expression<Func<Int64,Int64,Int64>>)	Zmienia wartość vs i ve każdego zdarzenia zgodnie z startTimeSelector i durationSelector, który jest funkcją godzin rozpoczęcia i zakończenia
AlterEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>, Expression<Func<Int64,Int64>>)	Zmienia element Vs i Ve każdego zdarzenia zgodnie z parametrem startTimeSelector i durationSelector, który jest funkcją czasu rozpoczęcia
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną w bajtach przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podłużnym typem danych.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)	Oblicza średnią wrażliwą na czas agregację na liczbach dziesiętnych przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest typem danych dziesiętnych.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)	Oblicza średnią średnią wrażliwą na czas w przypadku podwojeń przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podwójnym typem danych.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)	Oblicza średnią czasową agregację w krótkich skrótach przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest długim typem danych.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną na kropki przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest długim typem danych.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)	Oblicza średnią średnią wrażliwą na czas na długich przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest długim typem danych.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)	Oblicza średnią średnią wrażliwą na czas agregację ponad bajty dopuszczane do wartości null przy użyciu "okien migawek" (terminologia si). Należy pamiętać, że akumulator wewnętrznie jest podłużnym typem danych i że wartości null nie mają wpływu na średnią.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną przez liczbę dziesiętną z możliwością wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest typu danych dziesiętnych i że wartości null nie mają wpływu na średnią.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną przez wartość null dwukrotnie przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podwójnym typem danych i że wartości null nie mają wpływu na średnią.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną na wartości null skróty przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest długim typem danych i że wartości null nie mają wpływu na średnią.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną ponad wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest długim typem danych i że wartości null nie mają wpływu na średnią.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną przez długie wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest długim typem danych i że wartości null nie mają wpływu na średnią.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną za pośrednictwem wartości null BigIntegers przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest typu danych BigInteger i że wartości null nie mają wpływu na średnią.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną za pomocą złożonych wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest złożonym typem danych i że wartości null nie mają wpływu na średnią.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną na podstawie wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest długim typem danych i że wartości null nie mają wpływu na średnią.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną przez zmiennoprzecinkowe wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest zmiennoprzecinkowym typem danych i że wartości null nie mają wpływu na średnią.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną na podstawie wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podłużnym typem danych i że wartości null nie mają wpływu na średnią.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną na podstawie wartości null za pomocą "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podłużnym typem danych i że wartości null nie mają wpływu na średnią.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną przez wartości null za pomocą "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podłużnym typem danych i że wartości null nie mają wpływu na średnią.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)	Oblicza średnią wrażliwą na czas agregację w przypadku wartości BigIntegers przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest typu danych BigInteger.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)	Oblicza średnią wrażliwą na czas agregację w kompleksach przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest złożonym typem danych.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)	Oblicza średnią wrażliwą na czas agregację w bajtach przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest długim typem danych.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)	Oblicza średnią wrażliwą na czas agregację na zmiennoprzecinkach przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest zmiennoprzecinkowym typem danych.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną przez nashorty przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podłużnym typem danych.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną przez uints przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podłużnym typem danych.
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)	Oblicza średnią średnią wrażliwą na czas zagregowaną przez długie czasy przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podłużnym typem danych.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)	Oblicza średnią czasową kwadratów agregowanych w bajtach przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podłużnym typem danych.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)	Oblicza średnią czasową kwadratów agregowanych na liczbach dziesiętnych przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest typem danych dziesiętnych.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)	Oblicza średnią czasową kwadratów zagregowanych na dwukrotnie przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podwójnym typem danych.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)	Oblicza średnią czasową kwadratów agregowanych na krótkich przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest długim typem danych.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)	Oblicza średnią czasową kwadratów agregowanych na kropkach przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest długim typem danych.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)	Oblicza średnią czasową kwadratów agregowanych przez długi czas przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest długim typem danych.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)	Oblicza średnią czasową kwadratów agregowanych przez bajty dopuszczane do wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podłużnym typem danych i że wartości null nie mają wpływu na średnią.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)	Oblicza średnią czasową kwadratów agregowanych przez liczbę dziesiętną o wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest typu danych dziesiętnych i że wartości null nie mają wpływu na średnią.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)	Oblicza średnią czasową kwadratów agregowanych za pomocą podwójnych wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podwójnym typem danych i że wartości null nie mają wpływu na średnią.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)	Oblicza średnią czasową kwadratów agregowanych przez skróty dopuszczane do wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest długim typem danych i że wartości null nie mają wpływu na średnią.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)	Oblicza średnią czasową kwadratów agregowanych przez liczby zerowe przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest długim typem danych i że wartości null nie mają wpływu na średnią.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)	Oblicza średnią czasową kwadratów agregowanych przez długie wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest długim typem danych i że wartości null nie mają wpływu na średnią.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)	Oblicza średnią czasową kwadratów agregujących za pomocą wartości null BigIntegers przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest typu danych BigInteger i że wartości null nie mają wpływu na średnią.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)	Oblicza średnią czasową kwadratów agregowanych za pośrednictwem złożonych dopuszczalnych wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest złożonym typem danych i że wartości null nie mają wpływu na średnią.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)	Oblicza średnią czasową kwadratów agregowanych przez bajty dopuszczane do wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest długim typem danych i że wartości null nie mają wpływu na średnią.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)	Oblicza średnią czasową kwadratów agregowanych przez zmiennoprzecinkowe z możliwością wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest zmiennoprzecinkowym typem danych i że wartości null nie mają wpływu na średnią.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)	Oblicza średnią czasową kwadratów agregowanych na podstawie wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podłużnym typem danych i że wartości null nie mają wpływu na średnią.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)	Oblicza średnią czasową kwadratów agregowanych na podstawie wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podłużnym typem danych i że wartości null nie mają wpływu na średnią.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)	Oblicza średnią czasową kwadratów agregowanych przez długie z możliwością wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podłużnym typem danych i że wartości null nie mają wpływu na średnią.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)	Oblicza średnią czasową kwadratów agregujących za pomocą wartości BigIntegers przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest typu danych BigInteger.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)	Oblicza średnią czasową kwadratów agregowanych w kompleksach przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest złożonym typem danych.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)	Oblicza średnią czasową kwadratów agregowanych przez bajty przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest długim typem danych.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)	Oblicza średnią czasową kwadratów agregowanych na zmiennoprzecinkach przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest zmiennoprzecinkowym typem danych.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)	Oblicza średnią czasową kwadratów agregowanych za pomocą "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podłużnym typem danych.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)	Oblicza średnią czasową kwadratów agregowanych przez uints przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podłużnym typem danych.
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)	Oblicza średnią czasową kwadratów agregowanych przez długie przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że akumulator wewnętrznie jest podłużnym typem danych.
Cache<TKey,TPayload>(IStreamable<TKey,TPayload>, UInt64, Boolean, Boolean)	Buforuje pełne wyniki obliczane przez funkcję streamable po bezpośrednim wywołaniu subskrypcji. To wywołanie zostanie zablokowane, dopóki zapytanie bazowe nie zostanie w pełni wykonane, a wynik zostanie zapisany w pamięci podręcznej.
Chop<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64)	Wykonuje operator "Chop" do posiekania (partycji) długotrwałych interwałów i krawędzi po granicach.
ClipEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)	Przekazuje obciętą wersję każdego zdarzenia, w której zdarzenie jest obcięte przez maksymalną długość zdarzenia.
ClipEventDuration<TKey,TPayload,TClip>(IStreamable<TKey,TPayload>, IStreamable<TKey,TClip>)	Przekazuje obciętą wersję każdego zdarzenia po lewej stronie, gdzie zdarzenie po lewej stronie jest obcięte przez pierwsze zdarzenie po prawej stronie, którego program Vs występuje po zdarzeniu po lewej stronie. Nie ma żadnych ograniczeń dotyczących warunku sprzężenia.
ClipEventDuration<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey, TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,TJoinKey>>)	Przekazuje obciętą wersję każdego zdarzenia po lewej stronie, gdzie zdarzenie po lewej stronie jest obcięte przez pierwsze zdarzenie po prawej stronie, którego vs występuje po zdarzeniu po lewej stronie, którego warunek sprzężenia jest spełniony, i gdzie klucze dla obu strumieni są zgodne. Szybki moduł porównujący klucz sprzężenia jest przekazywany w celu zwiększenia wydajności.
ConsecutivePairs<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,TPayload,TResult>>)	Odnajduje wzorce zdarzeń, które są powtarzane kolejno
Count<TKey,TPayload>(IStreamable<TKey,TPayload>)	Oblicza agregację liczby z uwzględnieniem czasu przy użyciu "okien migawek" (terminologia SI).
CountNotNull<TKey,TPayload,TValue>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,TValue>>)	Oblicza zagregowaną liczbę czasową wartości innych niż null przy użyciu "okien migawek" (terminologia SI).
DefinePattern<TKey,TPayload>(IStreamable<TKey,TPayload>)	Definiowanie wzorca, względem którego dane w strumieniu wejściowym mogą być zgodne
DefinePattern<TKey,TPayload,TRegister,TAccumulator>(IStreamable<TKey,TPayload>, TRegister, TAccumulator)	Definiowanie wzorca, względem którego dane w strumieniu wejściowym mogą być zgodne
Detect<TKey,TPayload>(IStreamable<TKey,TPayload>, Func<IAbstractPatternRoot<TKey, TPayload,Empty,Boolean>,IPattern<TKey,TPayload,Empty,Boolean>>, Int64, Boolean, Boolean)	Wykryj wzorzec nad strumieniem przychodzącym. Przyjmuje rozszerzone wyrażenie regularne jako dane wejściowe. Utwórz usługę AFA przy użyciu interfejsu API regex.* lub bezpośredniej specyfikacji usługi AFA.
Detect<TKey,TPayload,TRegister>(IStreamable<TKey,TPayload>, TRegister, Func<IAbstractPatternRoot<TKey,TPayload,TRegister,Boolean>,IPattern<TKey, TPayload,TRegister,Boolean>>, Int64, Boolean, Boolean)	Wykryj wzorzec nad strumieniem przychodzącym. Przyjmuje rozszerzone wyrażenie regularne jako dane wejściowe. Utwórz usługę AFA przy użyciu interfejsu API regex.* lub bezpośredniej specyfikacji usługi AFA.
Detect<TKey,TPayload,TRegister,TAccumulator>(IStreamable<TKey, TPayload>, TRegister, TAccumulator, Func<IAbstractPatternRoot<TKey, TPayload,TRegister,TAccumulator>,IPattern<TKey,TPayload,TRegister, TAccumulator>>, Int64, Boolean, Boolean)	Wykryj wzorzec nad strumieniem przychodzącym. Przyjmuje rozszerzone wyrażenie regularne jako dane wejściowe. Utwórz usługę AFA przy użyciu interfejsu API regex.* lub bezpośredniej specyfikacji usługi AFA.
Detect<TKey,TPayload,TRegister,TAccumulator>(IStreamable<TKey,TPayload>, Afa<TPayload,TRegister,TAccumulator>, Int64, Boolean, Boolean)	Wykryj wzorzec nad strumieniem przychodzącym. Przyjmuje rozszerzony automat skończony (AFA) jako dane wejściowe. Utwórz usługę AFA przy użyciu interfejsu API regex.* lub bezpośredniej specyfikacji usługi AFA.
Distinct<TKey,TPayload>(IStreamable<TKey,TPayload>)	Odfiltruj wszystkie zduplikowane wpisy w każdej migawki
Distinct<TKey,TInput,TResult>(IStreamable<TKey,TInput>, Expression<Func<TInput,TResult>>)	Usuwa częściowe duplikaty na znacznik czasu. Jeśli dwa zdarzenia są zgodne z danym wyrażeniem i ich znacznikami czasu, są traktowane jako duplikaty.
ExtendLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)	Utwórz strumień, który wydłuża wszystkie okresy istnienia zdarzeń o stałą kwotę.
FollowedByImmediate<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Boolean>>, Expression<Func<TPayload, Boolean>>, Expression<Func<TPayload,TPayload,TResult>>, Int64)	Wyszukuje wzorce A, po których następuje natychmiast B (bez innych zdarzeń pośrednich), występują w ciągu (ściśle krótszym niż) danego czasu trwania
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)	Znajduje wzorce A po lewej stronie, a następnie natychmiast B po prawej stronie (bez innych zdarzeń pośrednich), występujące w ciągu (ściśle mniej niż) danego czasu trwania
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>>)	Grupuje zdarzenia wejściowe według selektora kluczy i stosuje wiele agregacji do "okien migawek" (terminologia SI) w każdej grupie.
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>>)	Grupuje zdarzenia wejściowe według selektora kluczy i stosuje wiele agregacji do "okien migawek" (terminologia SI) w każdej grupie.
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>>)	Grupuje zdarzenia wejściowe według selektora kluczy i stosuje wiele agregacji do "okien migawek" (terminologia SI) w każdej grupie.
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>>)	Grupuje zdarzenia wejściowe według selektora kluczy i stosuje wiele agregacji do "okien migawek" (terminologia SI) w każdej grupie.
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>>)	Grupuje zdarzenia wejściowe według selektora kluczy i stosuje wiele agregacji do "okien migawek" (terminologia SI) w każdej grupie.
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>>)	Grupuje zdarzenia wejściowe według selektora kluczy i stosuje wiele agregacji do "okien migawek" (terminologia SI) w każdej grupie.
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>>)	Grupuje zdarzenia wejściowe według selektora kluczy i stosuje wiele agregacji do "okien migawek" (terminologia SI) w każdej grupie.
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>>)	Grupuje zdarzenia wejściowe według selektora kluczy i stosuje wiele agregacji do "okien migawek" (terminologia SI) w każdej grupie.
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>>)	Grupuje zdarzenia wejściowe według selektora kluczy i stosuje wiele agregacji do "okien migawek" (terminologia SI) w każdej grupie.
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>>)	Grupuje zdarzenia wejściowe według selektora kluczy i stosuje wiele agregacji do "okien migawek" (terminologia SI) w każdej grupie.
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>>)	Grupuje zdarzenia wejściowe według selektora kluczy i stosuje wiele agregacji do "okien migawek" (terminologia SI) w każdej grupie.
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>>)	Grupuje zdarzenia wejściowe według selektora kluczy i stosuje wiele agregacji do "okien migawek" (terminologia SI) w każdej grupie.
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>>)	Grupuje zdarzenia wejściowe według selektora kluczy i stosuje wiele agregacji do "okien migawek" (terminologia SI) w każdej grupie.
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>>)	Grupuje zdarzenia wejściowe według selektora kluczy i stosuje agregację do "okien migawek" (terminologia SI) w każdej grupie.
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>>)	Grupuje zdarzenia wejściowe według selektora kluczy i stosuje wiele agregacji do "okien migawek" (terminologia SI) w każdej grupie.
GroupApply<TOuterKey,TPayload,TInnerKey,TResult>(IStreamable<TOuterKey, TPayload>, Expression<Func<TPayload,TInnerKey>>, Func<IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TPayload>,IStreamable<CompoundGroupKey<TOuterKey,TInnerKey>, TResult>>)	Wykonuje grupę i stosuje operację w strumieniu.
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>>)	Wykonuje grupę i stosuje operację w strumieniu.
GroupBy<TOuterKey,TPayload,TInnerKey>(IStreamable<TOuterKey,TPayload>, Expression<Func<TPayload,TInnerKey>>)	Potrzebne, aby składnia zrozumienia była szczęśliwa. Zamiast tego rozważ użycie usługi GroupApply.
HoppingWindowLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64, Int64)	Dostosowuje okres istnienia zdarzeń przychodzących do implementacji, gdy jest używany w połączeniu z agregacjami, oknami przeskoku. W tej implementacji każde zdarzenie przychodzące powoduje pojedyncze zdarzenie wychodzące, co oznacza, że kolejne agregacje generują dane wyjściowe tylko po zmianie danych wejściowych. Na przykład jeśli odebrano zdarzenie pojedynczego punktu, a rozmiar okna, okres i przesunięcie to odpowiednio 100, 2 i 0, pojedyncze zagregowane dane wyjściowe są generowane z okresem istnienia 100 kleszczy.
Join<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TRight,TResult>>)	Wykonuje między produktami między 2 strumieniami
Join<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TRight,TResult>>, Int64)	Wykonuje między produktami między 2 strumieniami
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>>)	Wykonuje równoczesność między 2 strumieniami, w których klucz sprzężenia jest typu TJoinKey, a selektory są przekazywane w celu wyodrębniania kluczy sprzężenia z ładunków
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)	Wykonuje równoczesność między 2 strumieniami, w których klucz sprzężenia jest typu TJoinKey, a selektory są przekazywane w celu wyodrębniania kluczy sprzężenia z ładunków
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)	Wykonuje równoczesność między 2 strumieniami, w których klucz sprzężenia jest typu TJoinKey, a selektory są przekazywane w celu wyodrębniania kluczy sprzężenia z ładunków
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>>)	Interfejs umożliwiający dynamiczne łączenie nowych strumieniowych danych wyjściowych z istniejącym strumieniem
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>>)	Makro do wykonania operacji sprzężenia lewego zewnętrznego.
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)	Makro do wykonania operacji sprzężenia lewego zewnętrznego.
Map<TOuterKey,TMapInput,TReduceInput>(IStreamable<TOuterKey,TMapInput>, Func<IStreamable<TOuterKey,TMapInput>,IStreamable<TOuterKey,TReduceInput>>)	Faza mapy pojedynczej operacji tylko mapy wejściowej. Umożliwia określenie logiki przesyłania strumieniowego na mapie.
Map<TOuterKey,TMapInput,TInnerKey,TReduceInput>(IStreamable<TOuterKey, TMapInput>, Func<IStreamable<TOuterKey,TMapInput>,IStreamable<TOuterKey, TReduceInput>>, Expression<Func<TReduceInput,TInnerKey>>)	Faza mapy pojedynczej operacji mapy/redukcji danych wejściowych. Umożliwia specyfikację logiki przesyłania strumieniowego na mapie i selektor klucza na następnym etapie (redukcji).
Max<TKey,TPayload>(IStreamable<TKey,TPayload>)	Oblicza maksymalną agregację wrażliwą na czas przy użyciu "okien migawek" (terminologia SI).
Max<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Comparison<TPayload>>)	Oblicza maksymalną agregację wrażliwą na czas przy użyciu "okien migawek" (terminologia SI).
Max<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>)	Oblicza maksymalną agregację wrażliwą na czas przy użyciu "okien migawek" (terminologia SI).
Max<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Expression<Comparison<T>>)	Oblicza maksymalną agregację wrażliwą na czas przy użyciu "okien migawek" (terminologia SI) z dostarczonym narzędziem do porównywania kolejności.
Min<TKey,TPayload>(IStreamable<TKey,TPayload>)	Oblicza minimalną agregację wrażliwą na czas przy użyciu "okien migawek" (terminologia si).
Min<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Comparison<TPayload>>)	Oblicza minimalną agregację wrażliwą na czas przy użyciu "okien migawek" (terminologia si).
Min<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>)	Oblicza minimalną agregację wrażliwą na czas przy użyciu "okien migawek" (terminologia si).
Min<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Expression<Comparison<T>>)	Oblicza minimalną agregację wrażliwą na czas przy użyciu "okien migawek" (terminologia SI) z dostarczonym narzędziem do porównywania kolejności.
Multicast<TKey,TPayload>(IStreamable<TKey,TPayload>, Int32)	Wykonuje multiemisję za pośrednictwem strumienia. Dzięki temu autorzy zapytań mogą wykonywać wiele podzapytania w tym samym strumieniu danych wejściowych fizycznych.
Multicast<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Func<IStreamable<TKey,TPayload>,IStreamable<TKey,TResult>>)	Wykonuje multiemisję za pośrednictwem strumienia. Dzięki temu autorzy zapytań mogą wykonywać wiele podzapytania w tym samym strumieniu danych wejściowych fizycznych.
Multicast<TKey,TPayloadLeft,TPayloadRight,TResult>(IStreamable<TKey, TPayloadLeft>, IStreamable<TKey,TPayloadRight>, Func<IStreamable<TKey, TPayloadLeft>,IStreamable<TKey,TPayloadRight>,IStreamable<TKey, TResult>>)	Wykonuje multiemisję za pośrednictwem strumienia. Dzięki temu autorzy zapytań mogą wykonywać wiele podzapytania w tym samym strumieniu danych wejściowych fizycznych.
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>>)	Interfejs umożliwiający dynamiczne łączenie nowych strumieniowych danych wyjściowych z istniejącym strumieniem
PointAtEnd<TKey,TPayload>(IStreamable<TKey,TPayload>)	Utwórz strumień, który zgłasza wszystkie deakumulacje jako strumień punktów tylko do wstawiania (konwertuje wszystkie zdarzenia na zdarzenia punktowe na końcu).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)	Oblicza agregację produktu wrażliwego na czas w bajtach przy użyciu "okien migawek" (terminologia SI).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)	Oblicza agregację produktu wrażliwego na czas w liczbach dziesiętnych przy użyciu "okien migawek" (terminologia SI).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)	Oblicza agregację produktu wrażliwego na czas w przypadku podwójnej wartości przy użyciu "okien migawek" (terminologia SI).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)	Oblicza agregację produktu wrażliwego na czas na skróty przy użyciu "okien migawek" (terminologia SI).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)	Oblicza agregację produktu wrażliwego na czas za pomocą kropek przy użyciu "okien migawek" (terminologia SI).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)	Oblicza agregację produktu wrażliwego na czas przez długi czas przy użyciu "okien migawek" (terminologia SI).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)	Oblicza agregację produktu poufnego czasowo za pośrednictwem bajtów dopuszczanych do wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)	Oblicza agregację produktu poufnego czasowo za pomocą wartości null dziesiętnych przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)	Oblicza agregację produktu poufnego czasowo za pomocą dubletów dopuszczanych do wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)	Oblicza agregację produktu poufnego czasowo za pomocą skrótów dopuszczanych do wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)	Oblicza agregację produktu poufnego czasowo za pomocą kropek dopuszczanych do wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)	Oblicza agregację produktu poufnego czasowo za pośrednictwem długich dopuszczalnych wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)	Oblicza agregację produktu poufnego czasowo za pośrednictwem wartości null BigIntegers przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)	Oblicza agregację produktu wrażliwego na czas za pośrednictwem kompleksów dopuszczanych do wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)	Oblicza agregację produktu poufnego czasowo przez bajty dopuszczane do wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)	Oblicza agregację produktu poufnego czasowo za pośrednictwem zmiennoprzecinkowych dopuszczanych wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)	Oblicza agregację produktu wrażliwego na czas za pomocą ushortów dopuszczanych do wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)	Oblicza agregację produktu wrażliwego na czas za pośrednictwem wartości null uints przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)	Oblicza agregację produktu poufnego czasowo za pośrednictwem wartości null za pomocą "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)	Oblicza agregację produktu wrażliwego na czas za pomocą funkcji BigIntegers przy użyciu "okien migawek" (terminologia SI).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)	Oblicza agregację produktu wrażliwego na czas w kompleksach przy użyciu "okien migawek" (terminologia SI).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)	Oblicza agregację produktu wrażliwego na czas na bajty przy użyciu "okien migawek" (terminologia SI).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)	Oblicza agregację produktu wrażliwego na czas na liczbach zmiennoprzecinkowych przy użyciu "okien migawek" (terminologia SI).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)	Oblicza agregację produktu wrażliwego na czas na ushorts przy użyciu "okien migawek" (terminologia SI).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)	Oblicza agregację produktu wrażliwego na czas za pośrednictwem uints przy użyciu "okien migawek" (terminologia SI).
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)	Oblicza agregację produktu wrażliwego na czas przez całe czasy przy użyciu "okien migawek" (terminologia SI).
Publish<TKey,TPayload>(IStreamable<TKey,TPayload>)	Wykonuje dynamiczną wersję multiemisji za pośrednictwem strumienia. Dzięki temu autorzy zapytań mogą wykonywać wiele podzapytań w tym samym strumieniu danych wejściowych fizycznych — strumienie można dodawać lub usuwać. Do użytkownika należy upewnienie się, że strumień nie ma krawędzi końcowych. W przeciwnym razie subskrybent dynamicznie subskrybowany może otrzymać źle sformułowany strumień (krawędź końcowa bez odpowiedniej krawędzi początkowej). Użycie: strumień. Publish(); Strumienia. Subskrybuj(...); Strumienia. Connect(); Strumienia. Subskrybuj(...);
QuantizeLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64, Int64)	Dostosowuje okres istnienia zdarzeń przychodzących, aby przyciągać czas rozpoczęcia i zakończenia każdego zdarzenia do kwantyzowanych granic. Funkcja jest podobna do wyrażenia okresu istnienia przeskoku, z tą różnicą, że wszystkie krawędzie początkowe są przenoszone wcześniej lub pozostają takie same, a wszystkie krawędzie końcowe przenoszą się później lub pozostają takie same.
RepetitiveHoppingWindowLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64, Int64)	Dostosowuje okres istnienia zdarzeń przychodzących, aby zaimplementować, gdy jest używany w połączeniu z agregacjami, powtarzalne okna przeskoków. W tej implementacji każde zdarzenie przychodzące powoduje dowolną liczbę zdarzeń wychodzących. Jeśli na przykład zostanie odebrane zdarzenie pojedynczego punktu, a wartość windowSize, period i offset wynosi odpowiednio 100, 2 i 0, generowane są 50 identycznych danych wyjściowych agregacji, z których każdy ma okres istnienia 2 kleszczy.
Select<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,TResult>>)	Wykonuje projekt za pośrednictwem możliwości przesyłania strumieniowego.
Select<TKey,TOld,TNew>(IStreamable<TKey,TOld>, Expression<Func<TNew>>, IDictionary<String,Expression<Func<TOld,Object>>>)	Interfejs umożliwiający dynamiczne łączenie nowych strumieniowych danych wyjściowych z istniejącym strumieniem
Select<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TPayload,TResult>>)	Wykonuje projekt za pośrednictwem możliwości przesyłania strumieniowego.
Select<TKey,TOld,TNew,TField1>(IStreamable<TKey,TOld>, Expression<Func<TNew>>, Expression<Func<TNew,TField1>>, Expression<Func<TOld,TField1>>)	Interfejs umożliwiający dynamiczne łączenie nowych strumieniowych danych wyjściowych z istniejącym strumieniem
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>>)	Interfejs umożliwiający dynamiczne łączenie nowych strumieniowych danych wyjściowych z istniejącym strumieniem
SelectBatch<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Action<TPayload[],TResult[]>>)	Wykonuje transformację nad możliwością przesyłania strumieniowego, grupując ładunki w partii w celu przekształcenia i dostarczając partię danych wyjściowych do wypełnienia. UWAGA: Zamierzony semantyka tej metody jest równoważna zaznaczeniu poszczególnych wierszy. Należy do obiektu wywołującego tę metodę, aby zapewnić te semantyki.
SelectByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TKey,TPayload,TResult>>)	Wykonuje projekt za pośrednictwem strumienia względem klucza grupowania.
SelectByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TKey,TPayload,TResult>>)	Wykonuje projekt za pośrednictwem strumienia względem klucza grupowania.
SelectMany<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,IEnumerable<TResult>>>)	Ten wybór wielu jest używany do generowania wielu ładunków z jednego
SelectMany<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TPayload,IEnumerable<TResult>>>)	Ten wybór wielu jest używany do generowania wielu ładunków z jednego
SelectMany<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, Func<Empty,IStreamable<TKey,TRight>>, Expression<Func<TLeft,TRight,TResult>>)	Ten wybór wielu jest używany w przypadku sprzężeń pochodzących ze składni zrozumienia, a także niepustych reduktorów w grupach i zastosuj
SelectManyByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TKey,TPayload,IEnumerable<TResult>>>)	Ten wybór wielu jest używany do generowania wielu ładunków z jednego
SelectManyByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TKey,TPayload,IEnumerable<TResult>>>)	Ten wybór wielu jest używany do generowania wielu ładunków z jednego
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>>)	Przekonwertuj strumień sesji początkowych i końcowych na pojedynczy strumień sesji, w którym zależy nam na danych w sesji końcowej. Sesje są danymi wyjściowymi jako zdarzenia punktów w sygnaturze czasowej sesji końcowej.
SessionTimeoutWindow<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64)	Typ okna implementuje sesje z limitem czasu w usłudze Trill. Bieżące okno jest rozszerzone, o ile nowe zdarzenia docierają w określonym przedziale czasu. Po upłynięciu limitu czasu bez danych (dla danego klucza grupowania) okno zostanie zamknięte.
ShiftEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)	Zmienia okres istnienia o określoną ilość czasu
ShiftEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>)	Przesuwa okres istnienia przez funkcję shiftSelector, która jest funkcją czasu rozpoczęcia zdarzenia
Stitch<TKey,TPayload>(IStreamable<TKey,TPayload>)	Ścieg jest odwrotnym operatorem "Chop": gdy znajdzie ładunek END i ładunek BEGIN w tym samym czasie, usuwa oba z strumienia. Efekt netto polega na tym, że jeśli wartość sygnału nie ulegnie zmianie, strumień nie będzie miał nowych zdarzeń. Jest to w większości przydatne dla ludzkich oczu; matematycznie, oba powinny być identyczne
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)	Oblicza agregację sumy wrażliwej na czas w bajtach przy użyciu "okien migawek" (terminologia SI).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)	Oblicza sumę wrażliwą na czas zagregowaną na liczbach dziesiętnych przy użyciu "okien migawek" (terminologia SI).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)	Oblicza sumę wrażliwą na czas zagregowaną na podwojenie przy użyciu "okien migawek" (terminologia SI).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)	Oblicza agregację sumy wrażliwej na czas na skróty przy użyciu "okien migawek" (terminologia SI).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)	Oblicza agregację sumy wrażliwej na czas za pomocą kropek przy użyciu "okien migawek" (terminologia SI).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)	Oblicza agregację sumy wrażliwej na czas na długich przy użyciu "okien migawek" (terminologia SI).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)	Oblicza sumę wrażliwą na czas agregację ponad bajty dopuszczane do wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)	Oblicza sumę wrażliwą na czas zagregowaną za pośrednictwem wartości null dziesiętnych przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)	Oblicza sumę wrażliwą na czas zagregowaną za pomocą dubletów dopuszczanych do wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)	Oblicza sumę wrażliwą na czas zagregowaną za pomocą skrótów dopuszczanych do wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)	Oblicza sumę wrażliwą na czas agregację ponad wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)	Oblicza sumę wrażliwą na czas agregację przez długie wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)	Oblicza sumę wrażliwą na czas agregację za pomocą wartości null BigIntegers przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)	Oblicza sumę wrażliwą na czas agregację w przypadku złożonych z możliwością wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)	Oblicza sumę wrażliwą na czas agregację za pośrednictwem bajtów z możliwością wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)	Oblicza sumę wrażliwą na czas agregację ponad zmiennoprzecinkowe z możliwością wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)	Oblicza sumę wrażliwą na czas agregację na podstawie wartości null za pomocą "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)	Oblicza sumę wrażliwą na czas agregację na podstawie wartości null za pomocą "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)	Oblicza sumę wrażliwą na czas agregację przez długie wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)	Oblicza sumę wrażliwą na czas zagregowaną na wartość BigIntegers przy użyciu "okien migawek" (terminologia SI).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)	Oblicza sumę wrażliwą na czas zagregowaną na złożone przy użyciu "okien migawek" (terminologia SI).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)	Oblicza sumę z uwzględnieniem czasu agregację na podstawie bajtów przy użyciu "okien migawek" (terminologia SI).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)	Oblicza sumę wrażliwą na czas agregację na zmiennoprzecinkach przy użyciu "okien migawek" (terminologia SI).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)	Oblicza sumę czasową agregacji na podstawie ushortów przy użyciu "okien migawek" (terminologia SI).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)	Oblicza sumę wrażliwą na czas zagregowaną przez uints przy użyciu "okien migawek" (terminologia SI).
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)	Oblicza sumę wrażliwą na czas agregację przez długie czasy przy użyciu "okien migawek" (terminologia SI).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych w bajtach przy użyciu "okien migawek" (terminologia SI).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych na liczbach dziesiętnych przy użyciu "okien migawek" (terminologia SI).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych na podwójne przy użyciu "okien migawek" (terminologia SI).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych w krótkich skrótach przy użyciu "okien migawek" (terminologia SI).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych na kropki przy użyciu "okien migawek" (terminologia SI).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych przez długi czas przy użyciu "okien migawek" (terminologia SI).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych przez bajty dopuszczane do wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych przez liczbę dziesiętną z możliwością wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)	Oblicza wrażliwą na czas sumę kwadratów zagregowanych przez podwójne wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)	Oblicza wrażliwą na czas sumę kwadratów zagregowanych przez skróty dopuszczane do wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)	Oblicza wrażliwą na czas sumę kwadratów zagregowanych przez liczby zerowe przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych przez długie wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)	Oblicza wrażliwą na czas sumę kwadratów agregujących za pomocą wartości null BigIntegers przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)	Oblicza wrażliwą na czas sumę kwadratów zagregowanych w przypadku złożonych z możliwością wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych przez bajty z możliwością wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych przez zmiennoprzecinkowe z możliwością wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych na podstawie wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)	Oblicza wrażliwą na czas sumę kwadratów zagregowanych przez wartości null za pomocą "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)	Oblicza wrażliwą na czas sumę kwadratów zagregowanych przez długie wartości null przy użyciu "okien migawek" (terminologia SI). Należy pamiętać, że wartości null nie mają wpływu na sumę.
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)	Oblicza wrażliwą na czas sumę kwadratów zagregowanych na wartość BigIntegers przy użyciu "okien migawek" (terminologia SI).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych w kompleksach przy użyciu "okien migawek" (terminologia SI).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych przez bajty przy użyciu "okien migawek" (terminologia SI).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych na zmiennoprzecinkach przy użyciu "okien migawek" (terminologia SI).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych przez nashorty przy użyciu "okien migawek" (terminologia SI).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych przez uints przy użyciu "okien migawek" (terminologia SI).
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)	Oblicza wrażliwą na czas sumę kwadratów agregowanych przez długie przy użyciu "okien migawek" (terminologia SI).
ToBinaryStream<TKey,TPayload>(IStreamable<TKey,TPayload>, Stream, Boolean)	Serializowanie strumienia do strumienia binarnego
ToBinaryStream<TKey,TPayload>(IStreamable<TKey,TPayload>, String)	Serializowanie strumienia do pliku binarnego
TopK<TKey,TPayload>(IStreamable<TKey,TPayload>, Int32)	Oblicza czasową agregację top-k przy użyciu "okien migawek" (terminologia SI) na podstawie selektora klucza.
TopK<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Comparison<TPayload>>, Int32)	Oblicza czasową agregację top-k przy użyciu "okien migawek" (terminologia SI) na podstawie selektora klucza.
TopK<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Int32)	Oblicza czasową agregację top-k przy użyciu "okien migawek" (terminologia SI) na podstawie selektora klucza.
TopK<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Expression<Comparison<T>>, Int32)	Oblicza czasową agregację top-k przy użyciu "okien migawek" (terminologia SI) na podstawie selektora klucza z podanym modułem porównawczym zamawiania.
TumblingWindowLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64)	Dostosowuje okres istnienia zdarzeń przychodzących do implementacji, gdy jest używany w połączeniu z agregacjami, oknami wirowania. W tej implementacji każde zdarzenie przychodzące powoduje pojedyncze zdarzenie wychodzące, co oznacza, że kolejne agregacje generują dane wyjściowe tylko po zmianie danych wejściowych. Na przykład, jeśli odebrano zdarzenie pojedynczego punktu, a tumbleDuration i przesunięcie wynosi odpowiednio 100 i 0, pojedyncze zagregowane dane wyjściowe są generowane z okresem istnienia 100 kleszczy.
Union<TKey,TPayload>(IStreamable<TKey,TPayload>, IStreamable<TKey,TPayload>)	Unia jest unii czasowej, która łączy dwa strumienie podobne do schematu
Unpivot<TKey,TInput,TPivotKey,TValue,TResult>(IStreamable<TKey, TInput>, Expression<Func<TResult>>, Expression<Func<TInput,TPivotKey>>, Expression<Func<TResult,String>>, Expression<Func<TResult,TValue>>)	Obraca strumień obiektów ładunku do strumienia key-attribute-value potrójnie odpowiadającym danym z ładunków wejściowych.
Where<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Boolean>>)	Wykonuje filtr przesyłany strumieniowo, wykluczając wiersze, dla których predykat daje wartość false.
WhereNotExists<TKey,TLeft,TRight>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>)	Wykonuje lewe sprzężenia antysemickie bez żadnego warunku sprzężenia (warunek sprzężenia jest spełniony).
WhereNotExists<TKey,TLeft,TRight>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Int64)	Wykonuje lewe sprzężenia antysemickie bez żadnego warunku sprzężenia (warunek sprzężenia jest spełniony).
WhereNotExists<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>)	Wykonuje lewe sprzężenia anty-semi przy użyciu przekazanego predykatu jako warunku sprzężenia.
WhereNotExists<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Int64)	Wykonuje lewe sprzężenia anty-semi przy użyciu przekazanego predykatu jako warunku sprzężenia.
WhereNotExists<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,Boolean>>)	Interfejs umożliwiający dynamiczne łączenie nowych strumieniowych danych wyjściowych z istniejącym strumieniem

Dotyczy

Udostępnij za pośrednictwem