| JobConfigurationAddStage Method (String, Type, Int32, IEnumerableInputStageInfo, Type) |
Adds a stage that takes input from other stages or no input.
Namespace:
Ookii.Jumbo.Jet.Jobs
Assembly:
Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 2.0.0
Syntax public StageConfiguration AddStage(
string stageId,
Type taskType,
int taskCount,
IEnumerable<InputStageInfo> inputStages,
Type stageMultiInputRecordReaderType
)
Public Function AddStage (
stageId As String,
taskType As Type,
taskCount As Integer,
inputStages As IEnumerable(Of InputStageInfo),
stageMultiInputRecordReaderType As Type
) As StageConfiguration
public:
StageConfiguration^ AddStage(
String^ stageId,
Type^ taskType,
int taskCount,
IEnumerable<InputStageInfo^>^ inputStages,
Type^ stageMultiInputRecordReaderType
)
member AddStage :
stageId : string *
taskType : Type *
taskCount : int *
inputStages : IEnumerable<InputStageInfo> *
stageMultiInputRecordReaderType : Type -> StageConfiguration
Parameters
- stageId
- Type: SystemString
The ID of the new stage. - taskType
- Type: SystemType
The type implementing the task's functionality; this type must implement ITaskTInput, TOutput. - taskCount
- Type: SystemInt32
The number of tasks in the new stage. - inputStages
- Type: System.Collections.GenericIEnumerableInputStageInfo
Information about the input stages for this stage, or if the stage has no inputs. - stageMultiInputRecordReaderType
- Type: SystemType
The type of the multi input record reader to use to combine records from multiple input stages. This type must
inherit from MultiInputRecordReaderT. This type is not used if the stage has zero or one inputs.
Return Value
Type:
StageConfiguration
A
StageConfiguration for the new stage.
See Also