![]() | Job |
public StageOperation Map<TInput, TOutput>( IOperationInput input, Action<TInput, RecordWriter<TOutput>> mapper, RecordReuseMode recordReuse = RecordReuseMode.Default )
![]() |
---|
There is no non-delegate version of this method. To use an existing map task class, simply use the Process(IOperationInput, Type) function. |
This method generates a class inheriting from PushTaskTInput, TOutput which calls the target method of the mapper delegate from the ProcessRecord(TInput, RecordWriterTOutput) method.
![]() |
---|
The task method will be called from a completely different process than the one that is using JobBuilder, so it should not really on any external state. |
If recordReuse is Default and the target method has the AllowRecordReuseAttribute attribute applied to it, that attribute will be copied to the task class. If the target method has the ProcessAllInputPartitionsAttribute attribute applied to it, that attribute will be copied to the task class.
The target method must be a public static method.