Click or drag to resize

JobBuilderGenerateT Method (Int32, ActionRecordWriterT, TaskContext)

Generates records using a task that takes no input.

Namespace:  Ookii.Jumbo.Jet.Jobs.Builder
Assembly:  Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 2.0.0
Syntax
public StageOperation Generate<T>(
	int taskCount,
	Action<RecordWriter<T>, TaskContext> generator
)

Parameters

taskCount
Type: SystemInt32
The task count.
generator
Type: SystemActionRecordWriterT, TaskContext
The generator function.

Type Parameters

T
The type of the records.

Return Value

Type: 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 generator 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 the target method is a public method, it will be called directly by the generated task class. Otherwise, the supplied delegate will be serialized to the task settings and used to call the method. If the target method is an instance method, the instance it belongs to will be serialized as well (this class must have the SerializableAttribute attribute).

See Also