JobBuilderGenerateT Method (Int32, ActionRecordWriterT, TaskContext) |
Namespace: Ookii.Jumbo.Jet.Jobs.Builder
public StageOperation Generate<T>( int taskCount, Action<RecordWriter<T>, TaskContext> generator )
This method generates a class implementing ITaskTInput, TOutput which calls the target method of the generator delegate from the Run(RecordReaderTInput, RecordWriterTOutput) method.
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).