JobBuilder Methods |
The JobBuilder type exposes the following members.
Name | Description | |
---|---|---|
AddAssembly |
Adds an assembly and all its referenced assemblies to the list of required assemblies for this job.
| |
AddOperation |
Adds the specified operation.
| |
CheckIfInputBelongsToJobBuilder |
Checks if the specified input belongs to this job builder.
| |
CreateJob |
Creates the job configuration.
| |
Equals | Determines whether the specified object is equal to the current object. (Inherited from Object.) | |
Generate(Int32, Type) |
Generates records using a task that takes no input.
| |
GenerateT(Int32, ActionRecordWriterT, TaskContext) |
Generates records using a task that takes no input.
| |
GenerateT(Int32, ActionRecordWriterT, ProgressContext) |
Generates records using a task that takes no input.
| |
GenerateT(Int32, ActionRecordWriterT) |
Generates records using a task that takes no input.
| |
GetHashCode | Serves as the default hash function. (Inherited from Object.) | |
GetType | Gets the Type of the current instance. (Inherited from Object.) | |
GroupAggregate(IOperationInput, Type, Type) |
Groups the input records by key, then aggregates their values.
| |
GroupAggregateTKey, TValue(IOperationInput, FuncTKey, TValue, TValue, TValue, Type, RecordReuseMode) |
Groups the input records by key, then aggregates their values using the specified accumulator task function.
| |
GroupAggregateTKey, TValue(IOperationInput, FuncTKey, TValue, TValue, TaskContext, TValue, Type, RecordReuseMode) |
Groups the input records by key, then aggregates their values using the specified accumulator task function.
| |
InnerJoin |
Performs an inner equi-join on two inputs.
| |
MapTInput, TOutput(IOperationInput, ActionTInput, RecordWriterTOutput, TaskContext, RecordReuseMode) |
Runs a map function on each record in the input.
| |
MapTInput, TOutput(IOperationInput, ActionTInput, RecordWriterTOutput, RecordReuseMode) |
Runs a map function on each record in the input.
| |
MemorySort |
Sorts the specified input in memory using SortTaskT.
| |
Process(IOperationInput, Type) |
Processes the specified input using the specified task.
| |
ProcessTInput, TOutput(IOperationInput, ActionRecordReaderTInput, RecordWriterTOutput, TaskContext, RecordReuseMode) |
Processes the specified input using the specified delegate.
| |
ProcessTInput, TOutput(IOperationInput, ActionRecordReaderTInput, RecordWriterTOutput, RecordReuseMode) |
Processes the specified input using the specified delegate.
| |
Read |
Reads input records from the specified path on the DFS.
| |
ReduceTKey, TValue, TOutput(IOperationInput, ActionTKey, IEnumerableTValue, RecordWriterTOutput, TaskContext, RecordReuseMode) |
Runs a reduce function on each key in the specified input.
| |
ReduceTKey, TValue, TOutput(IOperationInput, ActionTKey, IEnumerableTValue, RecordWriterTOutput, RecordReuseMode) |
Runs a reduce function on each key in the specified input.
| |
SpillSort |
Sorts the specified input by using a file channel with an output type of SortSpill.
| |
SpillSortCombine(IOperationInput, Type, Type) |
Sorts the specified input by using a file channel with an output type of SortSpill.
| |
SpillSortCombineTKey, TValue(IOperationInput, ActionTKey, IEnumerableTValue, RecordWriterPairTKey, TValue, TaskContext, Type, RecordReuseMode) |
Sorts the specified input by using a file channel with an output type of SortSpill and using
the specified reduce-style combiner function.
| |
SpillSortCombineTKey, TValue(IOperationInput, ActionTKey, IEnumerableTValue, RecordWriterPairTKey, TValue, Type, RecordReuseMode) |
Sorts the specified input by using a file channel with an output type of SortSpill and using
the specified reduce-style combiner function.
| |
ToString | Returns a string that represents the current object. (Inherited from Object.) | |
Write |
Writes the result of the specified operation to the DFS.
|