Afa<TInput,TRegister,TAccumulator>.AddMultiElementArc Method

Definition

Namespace:: Microsoft.StreamProcessing

Assembly:: Microsoft.StreamProcessing.dll

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

Adds a transition that handles multiple elements (events) at a given timestamp

public void AddMultiElementArc(int fromState, int toState, System.Linq.Expressions.Expression<Func<long,TRegister,TAccumulator>> initialize, System.Linq.Expressions.Expression<Func<long,TInput,TRegister,TAccumulator,TAccumulator>> accumulate, System.Linq.Expressions.Expression<Func<long,TInput,TAccumulator,bool>> skipToEnd = null, System.Linq.Expressions.Expression<Func<long,TAccumulator,TRegister,bool>> fence = null, System.Linq.Expressions.Expression<Func<long,TAccumulator,TRegister,TRegister>> transfer = null, System.Linq.Expressions.Expression<Action<TAccumulator>> dispose = null);

member this.AddMultiElementArc : int * int * System.Linq.Expressions.Expression<Func<int64, 'Register, 'Accumulator>> * System.Linq.Expressions.Expression<Func<int64, 'Input, 'Register, 'Accumulator, 'Accumulator>> * System.Linq.Expressions.Expression<Func<int64, 'Input, 'Accumulator, bool>> * System.Linq.Expressions.Expression<Func<int64, 'Accumulator, 'Register, bool>> * System.Linq.Expressions.Expression<Func<int64, 'Accumulator, 'Register, 'Register>> * System.Linq.Expressions.Expression<Action<'Accumulator>> -> unit

Public Sub AddMultiElementArc (fromState As Integer, toState As Integer, initialize As Expression(Of Func(Of Long, TRegister, TAccumulator)), accumulate As Expression(Of Func(Of Long, TInput, TRegister, TAccumulator, TAccumulator)), Optional skipToEnd As Expression(Of Func(Of Long, TInput, TAccumulator, Boolean)) = null, Optional fence As Expression(Of Func(Of Long, TAccumulator, TRegister, Boolean)) = null, Optional transfer As Expression(Of Func(Of Long, TAccumulator, TRegister, TRegister)) = null, Optional dispose As Expression(Of Action(Of TAccumulator)) = null)

Parameters

fromState: Int32

Starting state of the transition

toState: Int32

Ending state of the transition

initialize: Expression<Func<Int64,TRegister,TAccumulator>>

An initializer statement for the accumulator

accumulate: Expression<Func<Int64,TInput,TRegister,TAccumulator,TAccumulator>>

A description of how to update the accumulator on transition

skipToEnd: Expression<Func<Int64,TInput,TAccumulator,Boolean>>

A description of when to skip to the end as a part of the transition

fence: Expression<Func<Int64,TAccumulator,TRegister,Boolean>>

An added condition that must be met for the transition to occur

transfer: Expression<Func<Int64,TAccumulator,TRegister,TRegister>>

An expression to mutate the register value when the transition occurs

dispose: Expression<Action<TAccumulator>>

Dispose action on the accumulator

Applies to