Streamable.Detect Method
Definition
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.
Overloads
Detect<TKey,TPayload,TRegister,TAccumulator>(IStreamable<TKey, TPayload>, TRegister, TAccumulator, Func<IAbstractPatternRoot<TKey, TPayload,TRegister,TAccumulator>,IPattern<TKey,TPayload,TRegister, TAccumulator>>, Int64, Boolean, Boolean)
Detect a pattern over the incoming stream. Takes augmented regular expression as input. Create AFA using the Regex.* API or direct AFA specification.
public static Microsoft.StreamProcessing.IStreamable<TKey,TRegister> Detect<TKey,TPayload,TRegister,TAccumulator> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, TRegister defaultRegister, TAccumulator defaultAccumulator, Func<Microsoft.StreamProcessing.IAbstractPatternRoot<TKey,TPayload,TRegister,TAccumulator>,Microsoft.StreamProcessing.IPattern<TKey,TPayload,TRegister,TAccumulator>> pattern, long maxDuration = 0, bool allowOverlappingInstances = true, bool isDeterministic = false);static member Detect : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * 'Register * 'Accumulator * Func<Microsoft.StreamProcessing.IAbstractPatternRoot<'Key, 'Payload, 'Register, 'Accumulator>, Microsoft.StreamProcessing.IPattern<'Key, 'Payload, 'Register, 'Accumulator>> * int64 * bool * bool -> Microsoft.StreamProcessing.IStreamable<'Key, 'Register><Extension()>
Public Function Detect(Of TKey, TPayload, TRegister, TAccumulator) (source As IStreamable(Of TKey, TPayload), defaultRegister As TRegister, defaultAccumulator As TAccumulator, pattern As Func(Of IAbstractPatternRoot(Of TKey, TPayload, TRegister, TAccumulator), IPattern(Of TKey, TPayload, TRegister, TAccumulator)), Optional maxDuration As Long = 0, Optional allowOverlappingInstances As Boolean = true, Optional isDeterministic As Boolean = false) As IStreamable(Of TKey, TRegister)Type Parameters
- TKey
Key type
- TPayload
Payload type
- TRegister
Result type (output of matcher is the register at an accepting state of the AFA)
- TAccumulator
Accumulator type
Parameters
- source
- IStreamable<TKey,TPayload>
Source stream
- defaultRegister
- TRegister
Default register value for the automata
- defaultAccumulator
- TAccumulator
Default accumulator value for the automata
- pattern
- Func<IAbstractPatternRoot<TKey,TPayload,TRegister,TAccumulator>,IPattern<TKey,TPayload,TRegister,TAccumulator>>
Regular expression pattern specification
- maxDuration
- Int64
Maximum duration (window) for the pattern
- allowOverlappingInstances
- Boolean
States whether to allow more than one state machine instance to be in effect at a time
- isDeterministic
- Boolean
States whether to consider the AFA as deterministic
Returns
A stream of the matched results
Applies to
Detect<TKey,TPayload,TRegister,TAccumulator>(IStreamable<TKey,TPayload>, Afa<TPayload,TRegister,TAccumulator>, Int64, Boolean, Boolean)
Detect a pattern over the incoming stream. Takes augmented finite automaton (AFA) as input. Create AFA using the Regex.* API or direct AFA specification.
public static Microsoft.StreamProcessing.IStreamable<TKey,TRegister> Detect<TKey,TPayload,TRegister,TAccumulator> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, Microsoft.StreamProcessing.Afa<TPayload,TRegister,TAccumulator> afa, long MaxDuration = 0, bool allowOverlappingInstances = true, bool isDeterministic = false);static member Detect : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * Microsoft.StreamProcessing.Afa<'Payload, 'Register, 'Accumulator> * int64 * bool * bool -> Microsoft.StreamProcessing.IStreamable<'Key, 'Register><Extension()>
Public Function Detect(Of TKey, TPayload, TRegister, TAccumulator) (source As IStreamable(Of TKey, TPayload), afa As Afa(Of TPayload, TRegister, TAccumulator), Optional MaxDuration As Long = 0, Optional allowOverlappingInstances As Boolean = true, Optional isDeterministic As Boolean = false) As IStreamable(Of TKey, TRegister)Type Parameters
- TKey
Key type
- TPayload
Payload type
- TRegister
Result type (output of matcher is the register at an accepting state of the AFA)
- TAccumulator
Accumulator type
Parameters
- source
- IStreamable<TKey,TPayload>
Source stream
- afa
- Afa<TPayload,TRegister,TAccumulator>
AFA specification
- MaxDuration
- Int64
Maximum duration (window) for the pattern
- allowOverlappingInstances
- Boolean
States whether to allow more than one state machine instance to be in effect at a time
- isDeterministic
- Boolean
States whether to consider the AFA as deterministic
Returns
A stream of the matched results
Applies to
Detect<TKey,TPayload,TRegister>(IStreamable<TKey,TPayload>, TRegister, Func<IAbstractPatternRoot<TKey,TPayload,TRegister,Boolean>,IPattern<TKey, TPayload,TRegister,Boolean>>, Int64, Boolean, Boolean)
Detect a pattern over the incoming stream. Takes augmented regular expression as input. Create AFA using the Regex.* API or direct AFA specification.
public static Microsoft.StreamProcessing.IStreamable<TKey,TRegister> Detect<TKey,TPayload,TRegister> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, TRegister defaultRegister, Func<Microsoft.StreamProcessing.IAbstractPatternRoot<TKey,TPayload,TRegister,bool>,Microsoft.StreamProcessing.IPattern<TKey,TPayload,TRegister,bool>> pattern, long maxDuration = 0, bool allowOverlappingInstances = true, bool isDeterministic = false);static member Detect : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * 'Register * Func<Microsoft.StreamProcessing.IAbstractPatternRoot<'Key, 'Payload, 'Register, bool>, Microsoft.StreamProcessing.IPattern<'Key, 'Payload, 'Register, bool>> * int64 * bool * bool -> Microsoft.StreamProcessing.IStreamable<'Key, 'Register><Extension()>
Public Function Detect(Of TKey, TPayload, TRegister) (source As IStreamable(Of TKey, TPayload), defaultRegister As TRegister, pattern As Func(Of IAbstractPatternRoot(Of TKey, TPayload, TRegister, Boolean), IPattern(Of TKey, TPayload, TRegister, Boolean)), Optional maxDuration As Long = 0, Optional allowOverlappingInstances As Boolean = true, Optional isDeterministic As Boolean = false) As IStreamable(Of TKey, TRegister)Type Parameters
- TKey
Key type
- TPayload
Payload type
- TRegister
Result type (output of matcher is the register at an accepting state of the AFA)
Parameters
- source
- IStreamable<TKey,TPayload>
Source stream
- defaultRegister
- TRegister
Default register value for the automata
- pattern
- Func<IAbstractPatternRoot<TKey,TPayload,TRegister,Boolean>,IPattern<TKey,TPayload,TRegister,Boolean>>
Regular expression pattern specification
- maxDuration
- Int64
Maximum duration (window) for the pattern
- allowOverlappingInstances
- Boolean
States whether to allow more than one state machine instance to be in effect at a time
- isDeterministic
- Boolean
States whether to consider the AFA as deterministic
Returns
A stream of the matched results
Applies to
Detect<TKey,TPayload>(IStreamable<TKey,TPayload>, Func<IAbstractPatternRoot<TKey, TPayload,Empty,Boolean>,IPattern<TKey,TPayload,Empty,Boolean>>, Int64, Boolean, Boolean)
Detect a pattern over the incoming stream. Takes augmented regular expression as input. Create AFA using the Regex.* API or direct AFA specification.
public static Microsoft.StreamProcessing.IStreamable<TKey,Microsoft.StreamProcessing.Empty> Detect<TKey,TPayload> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, Func<Microsoft.StreamProcessing.IAbstractPatternRoot<TKey,TPayload,Microsoft.StreamProcessing.Empty,bool>,Microsoft.StreamProcessing.IPattern<TKey,TPayload,Microsoft.StreamProcessing.Empty,bool>> pattern, long maxDuration = 0, bool allowOverlappingInstances = true, bool isDeterministic = false);static member Detect : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * Func<Microsoft.StreamProcessing.IAbstractPatternRoot<'Key, 'Payload, Microsoft.StreamProcessing.Empty, bool>, Microsoft.StreamProcessing.IPattern<'Key, 'Payload, Microsoft.StreamProcessing.Empty, bool>> * int64 * bool * bool -> Microsoft.StreamProcessing.IStreamable<'Key, Microsoft.StreamProcessing.Empty><Extension()>
Public Function Detect(Of TKey, TPayload) (source As IStreamable(Of TKey, TPayload), pattern As Func(Of IAbstractPatternRoot(Of TKey, TPayload, Empty, Boolean), IPattern(Of TKey, TPayload, Empty, Boolean)), Optional maxDuration As Long = 0, Optional allowOverlappingInstances As Boolean = true, Optional isDeterministic As Boolean = false) As IStreamable(Of TKey, Empty)Type Parameters
- TKey
Key type
- TPayload
Payload type
Parameters
- source
- IStreamable<TKey,TPayload>
Source stream
- pattern
- Func<IAbstractPatternRoot<TKey,TPayload,Empty,Boolean>,IPattern<TKey,TPayload,Empty,Boolean>>
Regular expression pattern specification
- maxDuration
- Int64
Maximum duration (window) for the pattern
- allowOverlappingInstances
- Boolean
States whether to allow more than one state machine instance to be in effect at a time
- isDeterministic
- Boolean
States whether to consider the AFA as deterministic
Returns
A stream of the matched results