Click or drag to resize

JobBuilderProcessTInput, TOutput(IOperationInput, ActionRecordReaderTInput, RecordWriterTOutput, RecordReuseMode) Method

Processes the specified input using the specified delegate.

Namespace: Ookii.Jumbo.Jet.Jobs.Builder
Assembly: Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 0.3.0+dc1307f20e065bb638e0b73a34cd216f57e486f1
Syntax
public StageOperation Process<TInput, TOutput>(
	IOperationInput input,
	Action<RecordReader<TInput>, RecordWriter<TOutput>> processor,
	RecordReuseMode recordReuse = RecordReuseMode.Default
)

Parameters

input  IOperationInput
The input.
processor  ActionRecordReaderTInput, RecordWriterTOutput
The processing function to use to create the task.
recordReuse  RecordReuseMode  (Optional)
The record reuse mode.

Type Parameters

TInput
The type of the input.
TOutput
The type of the output.

Return Value

StageOperation
A StageOperation instance that can be used to further customize the operation.
Remarks

This method generates a class implementing ITaskTInput, TOutput which calls the target method of the processor delegate from the Run(RecordReaderTInput, RecordWriterTOutput) method.

Note  Note
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.

See Also