Streamable.SelectBatch<TKey,TPayload,TResult> 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.
Performs a transformation over a streamable, grouping payloads into a batch to transform, and providing an output batch to populate. NOTE: The intended semantics of this method is equivalent to Select over individual rows. It is up to the caller of this method to ensure those semantics.
public static Microsoft.StreamProcessing.IStreamable<TKey,TResult> SelectBatch<TKey,TPayload,TResult> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, System.Linq.Expressions.Expression<Action<TPayload[],TResult[]>> selector);static member SelectBatch : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * System.Linq.Expressions.Expression<Action<'Payload[], 'Result[]>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Result><Extension()>
Public Function SelectBatch(Of TKey, TPayload, TResult) (source As IStreamable(Of TKey, TPayload), selector As Expression(Of Action(Of TPayload(), TResult()))) As IStreamable(Of TKey, TResult)Type Parameters
- TKey
- TPayload
- TResult
Parameters
- source
- IStreamable<TKey,TPayload>
The input stream to transform
- selector
- Expression<Action<TPayload[],TResult[]>>
The method used to give an input batch to transform and an output batch to populate
Returns
IStreamable<TKey,TResult>