IMapDefinition<TOuterKey,TMapInputLeft,TMapInputRight,TInnerKey,TReduceInput> Interface

  • Reference

Definition

Namespace:
Microsoft.StreamProcessing
Assembly:
Microsoft.StreamProcessing.dll

Placeholder interface for an operation that represents a map-reduce function

public interface IMapDefinition<TOuterKey,TMapInputLeft,TMapInputRight,TInnerKey,TReduceInput>
type IMapDefinition<'OuterKey, 'MapInputLeft, 'MapInputRight, 'InnerKey, 'ReduceInput> = interface
Public Interface IMapDefinition(Of TOuterKey, TMapInputLeft, TMapInputRight, TInnerKey, TReduceInput)

Type Parameters

TOuterKey

Type of the outer grouping key

TMapInputLeft

Type of the left input to the map-reduce

TMapInputRight

Type of the right input to the map-reduce

TInnerKey

Type of the inner grouping key

TReduceInput

Type of the data fed to the reducer

Extension Methods

Reduce<TOuterKey,TMapInputLeft1,TMapInputRight1,TMapInputLeft2, TMapInputRight2,TInnerKey,TReduceInput1,TReduceInput2,TSelectorInput, TOutput>(IMapDefinition<TOuterKey,TMapInputLeft1,TMapInputRight1, TInnerKey,TReduceInput1>, IMapDefinition<TOuterKey,TMapInputLeft2, TMapInputRight2,TInnerKey,TReduceInput2>, Func<IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TReduceInput1>,IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TReduceInput2>,IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TSelectorInput>>, Expression<Func<GroupSelectorInput<TInnerKey>, TSelectorInput,TOutput>>, OperationalHint)

Two-input reducer. This reducer takes the result of 2 map operators (one can be implicit by using . ) and applies a 2 input stream valued function (reducer) to each partitioned stream pair. Note that the two mapped input stream must have the same mapping type. The result selector allows the reintroduction of the grouping key to the output in case it has been lost in the apply function. Additional parameter allows specifying whether reduce is asymmetric (multicast left side, spray right side)
Reduce<TOuterKey,TMapInputLeft,TMapInputRight,TInnerKey,TReduceInput>(IMapDefinition<TOuterKey,TMapInputLeft,TMapInputRight,TInnerKey,TReduceInput>)

Empty reducer. Follows a map operator in situations where the mapper is being used to parallelize a stateless query. It simply unmaps the input
Reduce<TOuterKey,TMapInputLeft,TMapInputRight,TInnerKey,TReduceInput, TSelectorInput,TOutput>(IMapDefinition<TOuterKey,TMapInputLeft, TMapInputRight,TInnerKey,TReduceInput>, Func<IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TReduceInput>,IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TSelectorInput>>, Expression<Func<GroupSelectorInput<TInnerKey>, TSelectorInput,TOutput>>)

Single-input reducer. Takes a mapped stream and applies a stream valued function (reducer) to each of the partitions. The result selector allows the reintroduction of the grouping key to the output in case it has been lost in the apply function.
SelectMany<TOuterKey,TInnerKey,TPayload,TResult,TBind,TOutput>(IMapDefinition<TOuterKey, TPayload,TPayload,TInnerKey,TResult>, Func<IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TResult>,IStreamable<CompoundGroupKey<TOuterKey,TInnerKey>, TBind>>, Expression<Func<GroupSelectorInput<TInnerKey>,TBind, TOutput>>)

This is here to make the comprehension syntax happy. Consider using GroupApply instead.

Applies to