| JobBuilderGenerateT Method (Int32, ActionRecordWriterT) |
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>> generator
)
Public Function Generate(Of T) (
taskCount As Integer,
generator As Action(Of RecordWriter(Of T))
) As StageOperation
public:
generic<typename T>
StageOperation^ Generate(
int taskCount,
Action<RecordWriter<T>^>^ generator
)
member Generate :
taskCount : int *
generator : Action<RecordWriter<'T>> -> StageOperation
Parameters
- taskCount
- Type: SystemInt32
The task count. - generator
- Type: SystemActionRecordWriterT
The generator function.
Type Parameters
- T
- The type of the records.
Return Value
Type:
StageOperationA
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 |
---|
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