|
GetProperties<TKey,TPayload>(IStreamable<TKey,TPayload>, StreamProperties<TKey,TPayload>)
|
Define o parâmetro out (propriedades) para as propriedades atuais do fluxo
|
|
SetProperties<TKey,TPayload>(IStreamable<TKey,TPayload>, StreamProperties<TKey,TPayload>)
|
Define as propriedades atuais do fluxo para o argumento fornecido (newProperties)
|
|
SetProperty<TKey,TPayload>(IStreamable<TKey,TPayload>)
|
Insira em um modo em que você pode definir uma propriedade para o fluxo.
|
|
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>>)
|
Aplica várias agregações a instantâneo janelas no fluxo de entrada.
|
|
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>>)
|
Aplica várias agregações a instantâneo janelas no fluxo de entrada.
|
|
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>>)
|
Aplica várias agregações a instantâneo janelas no fluxo de entrada.
|
|
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>>)
|
Aplica várias agregações a instantâneo janelas no fluxo de entrada.
|
|
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>>)
|
Aplica várias agregações a instantâneo janelas no fluxo de entrada.
|
|
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>>)
|
Aplica várias agregações a instantâneo janelas no fluxo de entrada.
|
|
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>>)
|
Aplica várias agregações a instantâneo janelas no fluxo de entrada.
|
|
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>>)
|
Aplica várias agregações a instantâneo janelas no fluxo de entrada.
|
|
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>>)
|
Aplica várias agregações a instantâneo janelas no fluxo de entrada.
|
|
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>>)
|
Aplica várias agregações a instantâneo janelas no fluxo de entrada.
|
|
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>>)
|
Aplica várias agregações a instantâneo janelas no fluxo de entrada.
|
|
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>>)
|
Aplica várias agregações a instantâneo janelas no fluxo de entrada.
|
|
Aggregate<TKey,TInput,TState,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState,TOutput>>)
|
Aplica uma agregação a janelas instantâneo no fluxo de entrada.
|
|
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>>)
|
Aplica várias agregações a instantâneo janelas no fluxo de entrada.
|
|
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>>)
|
Aplica várias agregações a instantâneo janelas no fluxo de entrada.
|
|
AlterEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)
|
Altera o Ve de cada evento de acordo com a duração fornecida
|
|
AlterEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64,Int64>>)
|
Altera o Ve de cada evento de acordo com o durationSelector, que é uma função dos horários de início e término
|
|
AlterEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>)
|
Altera o Ve de cada evento de acordo com o durationSelector, que é uma função da hora de início
|
|
AlterEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>, Int64)
|
Altera o Vs e Ve de cada evento.
|
|
AlterEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>, Expression<Func<Int64,Int64,Int64>>)
|
Altera o Vs e Ve de cada evento de acordo com o startTimeSelector e o durationSelector, que é uma função dos horários de início e término
|
|
AlterEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>, Expression<Func<Int64,Int64>>)
|
Altera o Vs e Ve de cada evento de acordo com o startTimeSelector e o durationSelector, que é uma função da hora de início
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)
|
Calcula uma agregação média sensível ao tempo em bytes usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados ulong.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)
|
Calcula uma agregação média sensível ao tempo em decimals usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados decimal.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)
|
Calcula uma agregação média de diferenciação de tempo em duplas usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados duplo.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)
|
Calcula uma agregação média sensível ao tempo em shorts usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados longo.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)
|
Calcula uma agregação média sensível ao tempo em ints usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados longo.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)
|
Calcula uma agregação média sensível ao tempo em longs usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados longo.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)
|
Calcula uma agregação média sensível ao tempo em bytes anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados ulong e que os nulos não têm nenhum efeito na média.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)
|
Calcula uma agregação média sensível ao tempo em decimals anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados decimal e que os nulos não afetam a média.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)
|
Calcula uma agregação média sensível ao tempo em duplas anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados duplo e que os nulos não afetam a média.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)
|
Calcula uma agregação média sensível ao tempo em shorts anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados longo e que os nulos não afetam a média.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)
|
Calcula uma agregação média sensível ao tempo em ints anuláveis usando "instantâneo janelas" (terminologia si). Observe que o acumulador internamente é um tipo de dados longo e que os nulos não afetam a média.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)
|
Calcula uma agregação média sensível ao tempo em longs anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados longo e que os nulos não afetam a média.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)
|
Calcula uma agregação média sensível ao tempo sobre BigIntegers anuláveis usando "janelas instantâneo" (terminologia SI). Observe que o acumulador internamente é um tipo de dados BigInteger e que os nulos não têm nenhum efeito na média.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)
|
Calcula uma agregação média sensível ao tempo em complexos anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados Complexo e que os nulos não têm nenhum efeito na média.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)
|
Calcula uma agregação média sensível ao tempo em relação a sbytes anuláveis usando "instantâneo janelas" (terminologia si). Observe que o acumulador internamente é um tipo de dados longo e que os nulos não afetam a média.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)
|
Calcula uma agregação média sensível ao tempo em floats anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados float e que os nulos não têm nenhum efeito na média.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)
|
Calcula uma agregação média sensível ao tempo em ushorts anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados ulong e que os nulos não têm nenhum efeito na média.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)
|
Calcula uma agregação média sensível ao tempo em relação a tonalidades anuláveis usando "janelas instantâneo" (terminologia SI). Observe que o acumulador internamente é um tipo de dados ulong e que os nulos não têm nenhum efeito na média.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)
|
Calcula uma agregação média sensível ao tempo em ulongs anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados ulong e que os nulos não têm nenhum efeito na média.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)
|
Calcula uma agregação média sensível ao tempo sobre BigIntegers usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados BigInteger.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)
|
Calcula uma agregação média sensível ao tempo em Complexos usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados Complexo.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)
|
Calcula uma agregação média sensível ao tempo em sbytes usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados longo.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)
|
Calcula uma agregação média sensível ao tempo em floats usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados float.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)
|
Calcula uma agregação média sensível ao tempo sobre ushorts usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados ulong.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)
|
Calcula uma agregação média sensível ao tempo em uints usando "instantâneo janelas" (terminologia si). Observe que o acumulador internamente é um tipo de dados ulong.
|
|
Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)
|
Calcula uma agregação média sensível ao tempo em ulongs usando "instantâneo janelas" (terminologia si). Observe que o acumulador internamente é um tipo de dados ulong.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em bytes usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados ulong.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados sobre decimais usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados decimal.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em duplas usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados duplo.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em shorts usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados longo.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados sobre ints usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados longo.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em longs usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados longo.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em bytes anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados ulong e que os nulos não têm nenhum efeito na média.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados sobre decimais anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados decimal e que os nulos não afetam a média.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em duplas anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados duplo e que os nulos não têm nenhum efeito na média.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em shorts anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados longo e que os nulos não têm nenhum efeito na média.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em ints anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados longo e que os nulos não têm nenhum efeito na média.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em longs anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados longo e que os nulos não têm nenhum efeito na média.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em bigIntegers anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados BigInteger e que os nulos não afetam a média.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em complexos anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados Complexo e que os nulos não têm nenhum efeito na média.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em sbytes anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados longo e que os nulos não têm nenhum efeito na média.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em floats anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados float e que os nulos não têm nenhum efeito na média.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em ushorts anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados ulong e que os nulos não têm nenhum efeito na média.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em uints anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados ulong e que os nulos não têm nenhum efeito na média.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em ulongs anuláveis usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados ulong e que os nulos não têm nenhum efeito na média.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados sobre BigIntegers usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados BigInteger.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em Complexos usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados Complexo.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em sbytes usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados longo.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em floats usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados float.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados sobre ushorts usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados ulong.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em uints usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados ulong.
|
|
AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)
|
Calcula uma média sensível ao tempo de agregação de quadrados em ulongs usando "janelas instantâneo" (terminologia si). Observe que o acumulador internamente é um tipo de dados ulong.
|
|
Cache<TKey,TPayload>(IStreamable<TKey,TPayload>, UInt64, Boolean, Boolean)
|
Armazena em cache os resultados completos calculados pelo streamable após uma chamada imediata para assinar. Esse
A chamada será bloqueada até que a consulta subjacente seja totalmente executada e o resultado seja armazenado em cache.
|
|
Chop<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64)
|
Executa o operador 'Chop' para cortar (partição) intervalos e bordas de longa duração entre limites de batida.
|
|
ClipEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)
|
Passa uma versão truncada de cada evento, em que o evento é truncado por um comprimento máximo de evento.
|
|
ClipEventDuration<TKey,TPayload,TClip>(IStreamable<TKey,TPayload>, IStreamable<TKey,TClip>)
|
Passa uma versão truncada de cada evento à esquerda, em que o evento à esquerda é truncado pelo primeiro evento à direita cujo Vs ocorre após o evento à esquerda. Não há restrição na condição de junção.
|
|
ClipEventDuration<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey,
TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>,
Expression<Func<TRight,TJoinKey>>)
|
Passa uma versão truncada de cada evento à esquerda, onde o evento à esquerda é truncado pelo primeiro evento à direita cujo Vs ocorre após o evento à esquerda, cuja condição de junção é atendida e onde as chaves de ambos os fluxos correspondem. Um comparador de chave de junção rápida é passado para eficiência.
|
|
ConsecutivePairs<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,TPayload,TResult>>)
|
Localiza padrões de eventos repetidos consecutivamente
|
|
Count<TKey,TPayload>(IStreamable<TKey,TPayload>)
|
Calcula uma agregação de contagem com diferenciação de tempo usando "janelas instantâneo" (terminologia si).
|
|
CountNotNull<TKey,TPayload,TValue>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,TValue>>)
|
Calcula uma agregação de contagem que diferencia o tempo dos valores não nulos usando "instantâneo janelas" (terminologia si).
|
|
DefinePattern<TKey,TPayload>(IStreamable<TKey,TPayload>)
|
Definir um padrão em relação ao qual os dados no fluxo de entrada podem ser correspondidos
|
|
DefinePattern<TKey,TPayload,TRegister,TAccumulator>(IStreamable<TKey,TPayload>, TRegister, TAccumulator)
|
Definir um padrão em relação ao qual os dados no fluxo de entrada podem ser correspondidos
|
|
Detect<TKey,TPayload>(IStreamable<TKey,TPayload>, Func<IAbstractPatternRoot<TKey,
TPayload,Empty,Boolean>,IPattern<TKey,TPayload,Empty,Boolean>>,
Int64, Boolean, Boolean)
|
Detecte um padrão no fluxo de entrada. Usa a expressão regular aumentada como entrada. Crie a AFA usando a API Regex.* ou a especificação direta da AFA.
|
|
Detect<TKey,TPayload,TRegister>(IStreamable<TKey,TPayload>, TRegister,
Func<IAbstractPatternRoot<TKey,TPayload,TRegister,Boolean>,IPattern<TKey,
TPayload,TRegister,Boolean>>, Int64, Boolean, Boolean)
|
Detecte um padrão no fluxo de entrada. Usa a expressão regular aumentada como entrada. Crie a AFA usando a API Regex.* ou a especificação direta da 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)
|
Detecte um padrão no fluxo de entrada. Usa a expressão regular aumentada como entrada. Crie a AFA usando a API Regex.* ou a especificação direta da AFA.
|
|
Detect<TKey,TPayload,TRegister,TAccumulator>(IStreamable<TKey,TPayload>, Afa<TPayload,TRegister,TAccumulator>, Int64, Boolean, Boolean)
|
Detecte um padrão no fluxo de entrada. Usa a AFA (automação finita aumentada) como entrada. Crie a AFA usando a API Regex.* ou a especificação direta da AFA.
|
|
Distinct<TKey,TPayload>(IStreamable<TKey,TPayload>)
|
Filtrar todas as entradas duplicadas em cada instantâneo
|
|
Distinct<TKey,TInput,TResult>(IStreamable<TKey,TInput>, Expression<Func<TInput,TResult>>)
|
Remove duplicatas parciais por carimbo de data/hora.
Se dois eventos corresponderem à expressão especificada e seus carimbos de data/hora, eles serão considerados duplicados.
|
|
ExtendLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)
|
Crie um fluxo que estenda todos os tempos de vida do evento por um valor fixo.
|
|
FollowedByImmediate<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>,
Expression<Func<TPayload,Boolean>>, Expression<Func<TPayload,
Boolean>>, Expression<Func<TPayload,TPayload,TResult>>, Int64)
|
Localiza padrões de A seguidos imediatamente por B (sem outros eventos intermediários), ocorrendo dentro (estritamente menor que) uma determinada duração de tempo
|
|
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)
|
Localiza padrões de A à esquerda seguidos imediatamente por B à direita (sem outros eventos intermediários), ocorrendo dentro (estritamente menor que) uma determinada duração de tempo
|
|
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>>)
|
Agrupa eventos de entrada por um seletor de chave e aplica várias agregações a "janelas instantâneo" (terminologia si) em cada grupo.
|
|
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>>)
|
Agrupa eventos de entrada por um seletor de chave e aplica várias agregações a "janelas instantâneo" (terminologia si) em cada grupo.
|
|
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>>)
|
Agrupa eventos de entrada por um seletor de chave e aplica várias agregações a "janelas instantâneo" (terminologia si) em cada grupo.
|
|
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>>)
|
Agrupa eventos de entrada por um seletor de chave e aplica várias agregações a "janelas instantâneo" (terminologia si) em cada grupo.
|
|
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>>)
|
Agrupa eventos de entrada por um seletor de chave e aplica várias agregações a "janelas instantâneo" (terminologia si) em cada grupo.
|
|
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>>)
|
Agrupa eventos de entrada por um seletor de chave e aplica várias agregações a "janelas instantâneo" (terminologia si) em cada grupo.
|
|
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>>)
|
Agrupa eventos de entrada por um seletor de chave e aplica várias agregações a "janelas instantâneo" (terminologia si) em cada grupo.
|
|
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>>)
|
Agrupa eventos de entrada por um seletor de chave e aplica várias agregações a "janelas instantâneo" (terminologia si) em cada grupo.
|
|
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>>)
|
Agrupa eventos de entrada por um seletor de chave e aplica várias agregações a "janelas instantâneo" (terminologia si) em cada grupo.
|
|
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>>)
|
Agrupa eventos de entrada por um seletor de chave e aplica várias agregações a "janelas instantâneo" (terminologia si) em cada grupo.
|
|
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>>)
|
Agrupa eventos de entrada por um seletor de chave e aplica várias agregações a "janelas instantâneo" (terminologia si) em cada grupo.
|
|
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>>)
|
Agrupa eventos de entrada por um seletor de chave e aplica várias agregações a "janelas instantâneo" (terminologia si) em cada grupo.
|
|
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>>)
|
Agrupa eventos de entrada por um seletor de chave e aplica várias agregações a "janelas instantâneo" (terminologia si) em cada grupo.
|
|
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>>)
|
Agrupa eventos de entrada por um seletor de chave e aplica uma agregação a "janelas instantâneo" (terminologia si) em cada grupo.
|
|
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>>)
|
Agrupa eventos de entrada por um seletor de chave e aplica várias agregações a "janelas instantâneo" (terminologia si) em cada grupo.
|
|
GroupApply<TOuterKey,TPayload,TInnerKey,TResult>(IStreamable<TOuterKey,
TPayload>, Expression<Func<TPayload,TInnerKey>>, Func<IStreamable<CompoundGroupKey<TOuterKey,
TInnerKey>,TPayload>,IStreamable<CompoundGroupKey<TOuterKey,TInnerKey>,
TResult>>)
|
Executa um grupo e aplica a operação no fluxo.
|
|
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>>)
|
Executa um grupo e aplica a operação no fluxo.
|
|
GroupBy<TOuterKey,TPayload,TInnerKey>(IStreamable<TOuterKey,TPayload>, Expression<Func<TPayload,TInnerKey>>)
|
Necessário para fazer a sintaxe de compreensão feliz. Em vez disso, considere usar GroupApply.
|
|
HoppingWindowLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64, Int64)
|
Ajusta o tempo de vida dos eventos de entrada a serem implementados, quando usados em combinação com agregações, pulando janelas. Nessa implementação, cada evento de entrada resulta em um único evento de saída, o que significa que as agregações subsequentes só produzem saída quando a entrada é alterada. Por exemplo, se um único evento de ponto for recebido e o windowSize, period e offset forem 100, 2 e 0, respectivamente, uma única saída de agregação será produzida com um tempo de vida de 100 tiques.
|
|
Join<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TRight,TResult>>)
|
Executa um produto cruzado entre dois fluxos
|
|
Join<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TRight,TResult>>, Int64)
|
Executa um produto cruzado entre dois fluxos
|
|
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>>)
|
Executa um equijoin entre dois fluxos em que a chave de junção é do tipo TJoinKey e os seletores são passados para extrair chaves de junção de cargas
|
|
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)
|
Executa um equijoin entre dois fluxos em que a chave de junção é do tipo TJoinKey e os seletores são passados para extrair chaves de junção de cargas
|
|
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)
|
Executa um equijoin entre dois fluxos em que a chave de junção é do tipo TJoinKey e os seletores são passados para extrair chaves de junção de cargas
|
|
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>>)
|
Interface para conectar dinamicamente novas saídas que podem ser transmitidas a um fluxo existente
|
|
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>>)
|
Macro para executar uma operação de junção externa esquerda.
|
|
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)
|
Macro para executar uma operação de junção externa esquerda.
|
|
Map<TOuterKey,TMapInput,TReduceInput>(IStreamable<TOuterKey,TMapInput>, Func<IStreamable<TOuterKey,TMapInput>,IStreamable<TOuterKey,TReduceInput>>)
|
A fase Mapa de uma única operação somente mapa de entrada. Permite a especificação da lógica de streaming no mapeador.
|
|
Map<TOuterKey,TMapInput,TInnerKey,TReduceInput>(IStreamable<TOuterKey,
TMapInput>, Func<IStreamable<TOuterKey,TMapInput>,IStreamable<TOuterKey,
TReduceInput>>, Expression<Func<TReduceInput,TInnerKey>>)
|
A fase mapa de uma única operação de mapeamento/redução de entrada. Permite a especificação da lógica de streaming no mapeador e um seletor de chave para o próximo estágio (reduzir).
|
|
Max<TKey,TPayload>(IStreamable<TKey,TPayload>)
|
Calcula uma agregação máxima com diferenciação de tempo usando "janelas instantâneo" (terminologia si).
|
|
Max<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Comparison<TPayload>>)
|
Calcula uma agregação máxima com diferenciação de tempo usando "janelas instantâneo" (terminologia si).
|
|
Max<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>)
|
Calcula uma agregação máxima com diferenciação de tempo usando "janelas instantâneo" (terminologia si).
|
|
Max<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Expression<Comparison<T>>)
|
Calcula uma agregação máxima sensível ao tempo usando "janelas instantâneo" (terminologia si) com o comparador de ordenação fornecido.
|
|
Min<TKey,TPayload>(IStreamable<TKey,TPayload>)
|
Calcula uma agregação mínima com diferenciação de tempo usando "janelas instantâneo" (terminologia si).
|
|
Min<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Comparison<TPayload>>)
|
Calcula uma agregação mínima com diferenciação de tempo usando "janelas instantâneo" (terminologia si).
|
|
Min<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>)
|
Calcula uma agregação mínima com diferenciação de tempo usando "janelas instantâneo" (terminologia si).
|
|
Min<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Expression<Comparison<T>>)
|
Calcula uma agregação mínima com diferenciação de tempo usando "janelas instantâneo" (terminologia si) com o comparador de ordenação fornecido.
|
|
Multicast<TKey,TPayload>(IStreamable<TKey,TPayload>, Int32)
|
Executa multicast em um streamable. Isso permite que os gravadores de consulta executem várias subconsultas no mesmo fluxo de entrada físico.
|
|
Multicast<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Func<IStreamable<TKey,TPayload>,IStreamable<TKey,TResult>>)
|
Executa multicast em um streamable. Isso permite que os gravadores de consulta executem várias subconsultas no mesmo fluxo de entrada físico.
|
|
Multicast<TKey,TPayloadLeft,TPayloadRight,TResult>(IStreamable<TKey,
TPayloadLeft>, IStreamable<TKey,TPayloadRight>, Func<IStreamable<TKey,
TPayloadLeft>,IStreamable<TKey,TPayloadRight>,IStreamable<TKey,
TResult>>)
|
Executa multicast em um streamable. Isso permite que os gravadores de consulta executem várias subconsultas no mesmo fluxo de entrada físico.
|
|
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>>)
|
Interface para conectar dinamicamente novas saídas que podem ser transmitidas a um fluxo existente
|
|
PointAtEnd<TKey,TPayload>(IStreamable<TKey,TPayload>)
|
Crie um fluxo que relata todas as desaccumulações como um fluxo de ponto somente inserção (converte todos os eventos em eventos de ponto no final).
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)
|
Calcula uma agregação de produto com diferenciação de tempo em bytes usando "janelas instantâneo" (terminologia si).
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)
|
Calcula uma agregação de produto sensível ao tempo em decimals usando "janelas instantâneo" (terminologia si).
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)
|
Calcula uma agregação de produto com diferenciação de tempo em duplas usando "janelas instantâneo" (terminologia si).
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)
|
Calcula uma agregação de produto sensível ao tempo em shorts usando "janelas instantâneo" (terminologia si).
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)
|
Calcula uma agregação de produto sensível ao tempo em ints usando "janelas instantâneo" (terminologia si).
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)
|
Calcula uma agregação de produto sensível ao tempo em longs usando "janelas instantâneo" (terminologia si).
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)
|
Calcula uma agregação de produto sensível ao tempo em bytes anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)
|
Calcula uma agregação de produto sensível ao tempo sobre decimais anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)
|
Calcula uma agregação de produto com diferenciação de tempo em duplas anuláveis usando "instantâneo janelas" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)
|
Calcula uma agregação de produto sensível ao tempo em shorts anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)
|
Calcula uma agregação de produto sensível ao tempo em ints anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)
|
Calcula uma agregação de produto sensível ao tempo em longs anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)
|
Calcula uma agregação de produto sensível ao tempo sobre BigIntegers anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)
|
Calcula uma agregação de produto sensível ao tempo em complexos anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)
|
Calcula uma agregação de produto sensível ao tempo em sbytes anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)
|
Calcula uma agregação de produto sensível ao tempo em floats anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)
|
Calcula uma agregação de produto sensível ao tempo em ushorts anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)
|
Calcula uma agregação de produto com diferenciação de tempo em uints anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)
|
Calcula uma agregação de produto sensível ao tempo em ulongs anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)
|
Calcula uma agregação de produto com diferenciação de tempo sobre BigIntegers usando "janelas instantâneo" (terminologia si).
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)
|
Calcula uma agregação de produto sensível ao tempo em Complexos usando "janelas instantâneo" (terminologia si).
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)
|
Calcula uma agregação de produto com diferenciação de tempo em sbytes usando "janelas instantâneo" (terminologia si).
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)
|
Calcula uma agregação de produto sensível ao tempo em floats usando "janelas instantâneo" (terminologia si).
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)
|
Calcula uma agregação de produto sensível ao tempo sobre ushorts usando "janelas instantâneo" (terminologia si).
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)
|
Calcula uma agregação de produto sensível ao tempo em uints usando "janelas instantâneo" (terminologia si).
|
|
Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)
|
Calcula uma agregação de produto sensível ao tempo em ulongs usando "janelas instantâneo" (terminologia si).
|
|
Publish<TKey,TPayload>(IStreamable<TKey,TPayload>)
|
Executa a versão dinâmica de multicast em um streamable. Isso permite que os gravadores de consulta executem várias subconsultas no mesmo fluxo de entrada físico . Os fluxos podem ser adicionados ou removidos. Cabe ao usuário garantir que o fluxo não tenha bordas finais, caso contrário, um assinante assinado dinamicamente poderá receber um fluxo malformado (borda final sem borda inicial correspondente).
Uso: fluxo. Publish(); Fluxo. Subscribe(...); Fluxo. Connect(); Fluxo. Subscribe(...);
|
|
QuantizeLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64, Int64)
|
Ajusta o tempo de vida dos eventos de entrada para ajustar a hora de início e término de cada evento para limites quantizados.
A função é semelhante a uma expressão de tempo de vida de salto, exceto que todas as bordas iniciais são movidas anteriormente ou permanecem as mesmas, e todas as bordas finais se movem mais tarde ou permanecem as mesmas.
|
|
RepetitiveHoppingWindowLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64, Int64)
|
Ajusta o tempo de vida dos eventos de entrada a serem implementados, quando usados em combinação com agregações, janelas de salto repetitivos. Nessa implementação, cada evento de entrada resulta em um número arbitrário de eventos de saída. Por exemplo, se um único evento de ponto for recebido e a janelaSize, ponto e deslocamento forem 100, 2 e 0, respectivamente, 50 saídas agregadas idênticas serão produzidas, cada uma com um tempo de vida de 2 tiques.
|
|
Select<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,TResult>>)
|
Executa um projeto em um streamable.
|
|
Select<TKey,TOld,TNew>(IStreamable<TKey,TOld>, Expression<Func<TNew>>, IDictionary<String,Expression<Func<TOld,Object>>>)
|
Interface para conectar dinamicamente novas saídas que podem ser transmitidas a um fluxo existente
|
|
Select<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TPayload,TResult>>)
|
Executa um projeto em um streamable.
|
|
Select<TKey,TOld,TNew,TField1>(IStreamable<TKey,TOld>, Expression<Func<TNew>>, Expression<Func<TNew,TField1>>, Expression<Func<TOld,TField1>>)
|
Interface para conectar dinamicamente novas saídas que podem ser transmitidas a um fluxo existente
|
|
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>>)
|
Interface para conectar dinamicamente novas saídas que podem ser transmitidas a um fluxo existente
|
|
SelectBatch<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Action<TPayload[],TResult[]>>)
|
Executa uma transformação em um fluxo, agrupando cargas em um lote a ser transformado e fornecendo um lote de saída para preencher.
OBSERVAÇÃO: a semântica pretendida desse método é equivalente a Selecionar em linhas individuais. Cabe ao chamador desse método garantir essa semântica.
|
|
SelectByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TKey,TPayload,TResult>>)
|
Executa um projeto em um streamable, em relação à chave de agrupamento.
|
|
SelectByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TKey,TPayload,TResult>>)
|
Executa um projeto em um streamable, em relação à chave de agrupamento.
|
|
SelectMany<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,IEnumerable<TResult>>>)
|
Essa seleção de muitos é usada para gerar muitos conteúdos de um
|
|
SelectMany<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TPayload,IEnumerable<TResult>>>)
|
Essa seleção de muitos é usada para gerar muitos conteúdos de um
|
|
SelectMany<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, Func<Empty,IStreamable<TKey,TRight>>, Expression<Func<TLeft,TRight,TResult>>)
|
Essa seleção de muitos é usada para junções derivadas da sintaxe de compreensão, bem como redutores não vazios em Grupo e Aplicar
|
|
SelectManyByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TKey,TPayload,IEnumerable<TResult>>>)
|
Essa seleção de muitos é usada para gerar muitos conteúdos de um
|
|
SelectManyByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TKey,TPayload,IEnumerable<TResult>>>)
|
Essa seleção de muitos é usada para gerar muitos conteúdos de um
|
|
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>>)
|
Converta um fluxo de sessões de início e término em um único fluxo por sessão, em que nos preocupamos com os dados na sessão final. As sessões são saída como eventos de ponto no carimbo de data/hora da sessão final.
|
|
SessionTimeoutWindow<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64)
|
O tipo de janela implementa sessões com tempo limite no Trill. A janela atual é estendida desde que novos eventos cheguem dentro de um período de tempo limite especificado. Depois que um período de tempo limite passa sem dados (para uma determinada chave de agrupamento), a janela é fechada.
|
|
ShiftEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)
|
Desloca o tempo de vida pela quantidade de tempo especificada
|
|
ShiftEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>)
|
Desloca o tempo de vida pelo shiftSelector, que é uma função da hora de início do evento
|
|
Stitch<TKey,TPayload>(IStreamable<TKey,TPayload>)
|
Stitch é o inverso do operador 'Chop': quando encontra uma carga END e uma carga BEGIN ao mesmo tempo, remove ambos do fluxo. O efeito líquido é que, se um valor em um sinal não for alterado, o fluxo não terá novos eventos. Isso é útil principalmente para os olhos humanos; mathemticamente, os dois devem ser idênticos
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)
|
Calcula uma agregação de soma sensível ao tempo em bytes usando "janelas instantâneo" (terminologia si).
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)
|
Calcula uma agregação de soma sensível ao tempo sobre decimais usando "janelas instantâneo" (terminologia si).
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)
|
Calcula uma agregação de soma sensível ao tempo em duplas usando "janelas instantâneo" (terminologia si).
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)
|
Calcula uma agregação de soma sensível ao tempo em shorts usando "janelas instantâneo" (terminologia si).
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)
|
Calcula uma agregação de soma sensível ao tempo sobre ints usando "janelas instantâneo" (terminologia si).
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)
|
Calcula uma agregação de soma sensível ao tempo em longs usando "janelas instantâneo" (terminologia si).
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)
|
Calcula uma agregação de soma que diferencia o tempo em bytes anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)
|
Calcula uma agregação de soma sensível ao tempo sobre decimais anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)
|
Calcula uma agregação de soma que diferencia o tempo em duplas anuláveis usando "instantâneo janelas" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)
|
Calcula uma agregação de soma sensível ao tempo em shorts anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)
|
Calcula uma agregação de soma sensível ao tempo em ints anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)
|
Calcula uma agregação de soma sensível ao tempo em longs anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)
|
Calcula uma agregação de soma sensível ao tempo sobre BigIntegers anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)
|
Calcula uma agregação de soma sensível ao tempo em complexos anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)
|
Calcula uma agregação de soma sensível ao tempo em sbytes anuláveis usando "instantâneo janelas" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)
|
Calcula uma agregação de soma sensível ao tempo em floats anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)
|
Calcula uma agregação de soma que diferencia o tempo em ushorts anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)
|
Calcula uma agregação de soma que diferencia o tempo em uints anuláveis usando "instantâneo janelas" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)
|
Calcula uma agregação de soma sensível ao tempo em ulongs anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)
|
Calcula uma agregação de soma sensível ao tempo sobre BigIntegers usando "janelas instantâneo" (terminologia si).
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)
|
Calcula uma agregação de soma sensível ao tempo em Complexos usando "janelas instantâneo" (terminologia si).
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)
|
Calcula uma agregação de soma sensível ao tempo em sbytes usando "janelas instantâneo" (terminologia si).
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)
|
Calcula uma agregação de soma sensível ao tempo em floats usando "janelas instantâneo" (terminologia si).
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)
|
Calcula uma agregação de soma sensível ao tempo sobre ushorts usando "instantâneo janelas" (terminologia si).
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)
|
Calcula uma agregação de soma com diferenciação de tempo em uints usando "janelas instantâneo" (terminologia si).
|
|
Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)
|
Calcula uma agregação de soma sensível ao tempo em ulongs usando "janelas instantâneo" (terminologia si).
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados em bytes usando "janelas instantâneo" (terminologia si).
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados sobre decimais usando "janelas instantâneo" (terminologia si).
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados em duplas usando "janelas instantâneo" (terminologia si).
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados em shorts usando "janelas instantâneo" (terminologia si).
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados sobre ints usando "janelas instantâneo" (terminologia si).
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados em longs usando "janelas instantâneo" (terminologia si).
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados em bytes anuláveis usando "instantâneo janelas" (terminologia si). Observe que os nulos não afetam a soma.
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados sobre decimais anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados em duplas anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados sobre shorts anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados em ints anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados em longs anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados sobre BigIntegers anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados em complexos anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados em sbytes anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados sobre floats anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados sobre ushorts anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados em uints anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados sobre ulongs anuláveis usando "janelas instantâneo" (terminologia si). Observe que os nulos não afetam a soma.
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados sobre BigIntegers usando "janelas instantâneo" (terminologia si).
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados em Complexos usando "janelas instantâneo" (terminologia si).
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados sobre sbytes usando "janelas instantâneo" (terminologia si).
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados sobre floats usando "janelas instantâneo" (terminologia si).
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados sobre ushorts usando "janelas instantâneo" (terminologia si).
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados sobre uints usando "instantâneo janelas" (terminologia si).
|
|
SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)
|
Calcula uma soma sensível ao tempo de agregação de quadrados em ulongs usando "janelas instantâneo" (terminologia si).
|
|
ToBinaryStream<TKey,TPayload>(IStreamable<TKey,TPayload>, Stream, Boolean)
|
Serializar o streamable em um fluxo binário
|
|
ToBinaryStream<TKey,TPayload>(IStreamable<TKey,TPayload>, String)
|
Serializar o streamble em um arquivo binário
|
|
TopK<TKey,TPayload>(IStreamable<TKey,TPayload>, Int32)
|
Calcula uma agregação top-k com diferenciação de tempo usando "janelas instantâneo" (terminologia si) com base em um seletor de chave.
|
|
TopK<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Comparison<TPayload>>, Int32)
|
Calcula uma agregação top-k com diferenciação de tempo usando "janelas instantâneo" (terminologia si) com base em um seletor de chave.
|
|
TopK<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Int32)
|
Calcula uma agregação top-k com diferenciação de tempo usando "janelas instantâneo" (terminologia si) com base em um seletor de chave.
|
|
TopK<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Expression<Comparison<T>>, Int32)
|
Calcula uma agregação top-k sensível ao tempo usando "instantâneo janelas" (terminologia si) com base em um seletor de chave com o comparador de ordenação fornecido.
|
|
TumblingWindowLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64)
|
Ajusta o tempo de vida dos eventos de entrada a serem implementados, quando usados em combinação com agregações, janelas em cascata. Nessa implementação, cada evento de entrada resulta em um único evento de saída, o que significa que as agregações subsequentes só produzem saída quando a entrada é alterada. Por exemplo, se um único evento de ponto for recebido e o tumbleDuration e o deslocamento forem 100 e 0, respectivamente, uma única saída de agregação será produzida com um tempo de vida de 100 tiques.
|
|
Union<TKey,TPayload>(IStreamable<TKey,TPayload>, IStreamable<TKey,TPayload>)
|
União é uma união temporal que combina dois fluxos de esquema semelhante
|
|
Unpivot<TKey,TInput,TPivotKey,TValue,TResult>(IStreamable<TKey,
TInput>, Expression<Func<TResult>>, Expression<Func<TInput,TPivotKey>>,
Expression<Func<TResult,String>>, Expression<Func<TResult,TValue>>)
|
Gira um fluxo de objetos de carga em um fluxo de triplos chave-atributo-valor correspondentes aos dados dos conteúdos de entrada.
|
|
Where<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Boolean>>)
|
Executa um filtro em um streamable, excluindo linhas para as quais o predicado é avaliado como false.
|
|
WhereNotExists<TKey,TLeft,TRight>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>)
|
Executa uma junção anti-semi esquerda sem nenhuma condição de junção (a condição de junção é verdadeira).
|
|
WhereNotExists<TKey,TLeft,TRight>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Int64)
|
Executa uma junção anti-semi esquerda sem nenhuma condição de junção (a condição de junção é verdadeira).
|
|
WhereNotExists<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey,TLeft>,
IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,
TJoinKey>>)
|
Executa uma junção anti-semi esquerda usando o predicado passado como condição de junção.
|
|
WhereNotExists<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey,TLeft>,
IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,
TJoinKey>>, Int64)
|
Executa uma junção anti-semi esquerda usando o predicado passado como condição de junção.
|
|
WhereNotExists<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey,TLeft>,
IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,
TJoinKey>>, Expression<Func<TLeft,TRight,Boolean>>)
|
Interface para conectar dinamicamente novas saídas que podem ser transmitidas a um fluxo existente
|