Streamable.Distinct 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
| Distinct<TKey,TInput,TResult>(IStreamable<TKey,TInput>, Expression<Func<TInput,TResult>>) |
Removes partial duplicates per timestamp. If two events match by the given expression and their timestamps, they are considered duplicates. |
| Distinct<TKey,TPayload>(IStreamable<TKey,TPayload>) |
Filter out any duplicate entries at each snapshot |
Distinct<TKey,TInput,TResult>(IStreamable<TKey,TInput>, Expression<Func<TInput,TResult>>)
Removes partial duplicates per timestamp. If two events match by the given expression and their timestamps, they are considered duplicates.
public static Microsoft.StreamProcessing.IStreamable<TKey,TResult> Distinct<TKey,TInput,TResult> (this Microsoft.StreamProcessing.IStreamable<TKey,TInput> source, System.Linq.Expressions.Expression<Func<TInput,TResult>> selector);static member Distinct : Microsoft.StreamProcessing.IStreamable<'Key, 'Input> * System.Linq.Expressions.Expression<Func<'Input, 'Result>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Result><Extension()>
Public Function Distinct(Of TKey, TInput, TResult) (source As IStreamable(Of TKey, TInput), selector As Expression(Of Func(Of TInput, TResult))) As IStreamable(Of TKey, TResult)Type Parameters
- TKey
Type of (mapping) key in the stream
- TInput
Type of input stream
- TResult
Type of result stream
Parameters
- source
- IStreamable<TKey,TInput>
Input stream.
- selector
- Expression<Func<TInput,TResult>>
Expression that defines when two events are considered duplicates. If the expression evaluates to different values for two events, they are considered to be distinct.
Returns
For each distinct input timestamp, one result event with a payload based on the given expression.
Applies to
Distinct<TKey,TPayload>(IStreamable<TKey,TPayload>)
Filter out any duplicate entries at each snapshot
public static Microsoft.StreamProcessing.IStreamable<TKey,TPayload> Distinct<TKey,TPayload> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source);static member Distinct : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Payload><Extension()>
Public Function Distinct(Of TKey, TPayload) (source As IStreamable(Of TKey, TPayload)) As IStreamable(Of TKey, TPayload)Type Parameters
- TKey
Type of (mapping) key in the stream
- TPayload
Type of result stream
Parameters
- source
- IStreamable<TKey,TPayload>
Returns
A stream where all elements within each timestamp have only distinct payloads returned