Streamable.SelectByKey 方法
定義
重要
部分資訊涉及發行前產品,在發行之前可能會有大幅修改。 Microsoft 對此處提供的資訊,不做任何明確或隱含的瑕疵擔保。
多載
SelectByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TKey,TPayload,TResult>>)
透過可串流方式執行專案,相對於群組索引鍵。
public static Microsoft.StreamProcessing.IStreamable<TKey,TResult> SelectByKey<TKey,TPayload,TResult>(this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, System.Linq.Expressions.Expression<Func<long,TKey,TPayload,TResult>> selector);
static member SelectByKey : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * System.Linq.Expressions.Expression<Func<int64, 'Key, 'Payload, 'Result>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Result>
<Extension()>
Public Function SelectByKey(Of TKey, TPayload, TResult) (source As IStreamable(Of TKey, TPayload), selector As Expression(Of Func(Of Long, TKey, TPayload, TResult))) As IStreamable(Of TKey, TResult)
類型參數
- TKey
- TPayload
- TResult
參數
- source
- IStreamable<TKey,TPayload>
作業的來源可串流處理。
- selector
- Expression<Func<Int64,TKey,TPayload,TResult>>
在 StartTime、Key 和 Payload 上傳回新承載的運算式。
傳回
IStreamable<TKey,TResult>
適用於
SelectByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TKey,TPayload,TResult>>)
透過可串流方式執行專案,相對於群組索引鍵。
public static Microsoft.StreamProcessing.IStreamable<TKey,TResult> SelectByKey<TKey,TPayload,TResult>(this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, System.Linq.Expressions.Expression<Func<TKey,TPayload,TResult>> selector);
static member SelectByKey : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * System.Linq.Expressions.Expression<Func<'Key, 'Payload, 'Result>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Result>
<Extension()>
Public Function SelectByKey(Of TKey, TPayload, TResult) (source As IStreamable(Of TKey, TPayload), selector As Expression(Of Func(Of TKey, TPayload, TResult))) As IStreamable(Of TKey, TResult)
類型參數
- TKey
- TPayload
- TResult
參數
- source
- IStreamable<TKey,TPayload>
作業的來源可串流處理。
- selector
- Expression<Func<TKey,TPayload,TResult>>
傳回新承載的索引鍵和承載上的運算式。
傳回
IStreamable<TKey,TResult>