![]() | Job |
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. |