Click or drag to resize

JobBuilder Methods

The JobBuilder type exposes the following members.

Methods
  NameDescription
Public methodAddAssembly
Adds an assembly and all its referenced assemblies to the list of required assemblies for this job.
Public methodAddOperation
Adds the specified operation.
Public methodCheckIfInputBelongsToJobBuilder
Checks if the specified input belongs to this job builder.
Public methodCreateJob
Creates the job configuration.
Public methodEquals
Determines whether the specified object is equal to the current object.
(Inherited from Object.)
Public methodGenerate(Int32, Type)
Generates records using a task that takes no input.
Public methodGenerateT(Int32, ActionRecordWriterT, TaskContext)
Generates records using a task that takes no input.
Public methodGenerateT(Int32, ActionRecordWriterT, ProgressContext)
Generates records using a task that takes no input.
Public methodGenerateT(Int32, ActionRecordWriterT)
Generates records using a task that takes no input.
Public methodGetHashCode
Serves as the default hash function.
(Inherited from Object.)
Public methodGetType
Gets the Type of the current instance.
(Inherited from Object.)
Public methodGroupAggregate(IOperationInput, Type, Type)
Groups the input records by key, then aggregates their values.
Public methodGroupAggregateTKey, TValue(IOperationInput, FuncTKey, TValue, TValue, TValue, Type, RecordReuseMode)
Groups the input records by key, then aggregates their values using the specified accumulator task function.
Public methodGroupAggregateTKey, 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.
Public methodInnerJoin
Performs an inner equi-join on two inputs.
Public methodMapTInput, TOutput(IOperationInput, ActionTInput, RecordWriterTOutput, TaskContext, RecordReuseMode)
Runs a map function on each record in the input.
Public methodMapTInput, TOutput(IOperationInput, ActionTInput, RecordWriterTOutput, RecordReuseMode)
Runs a map function on each record in the input.
Public methodMemorySort
Public methodProcess(IOperationInput, Type)
Processes the specified input using the specified task.
Public methodProcessTInput, TOutput(IOperationInput, ActionRecordReaderTInput, RecordWriterTOutput, TaskContext, RecordReuseMode)
Processes the specified input using the specified delegate.
Public methodProcessTInput, TOutput(IOperationInput, ActionRecordReaderTInput, RecordWriterTOutput, RecordReuseMode)
Processes the specified input using the specified delegate.
Public methodRead
Reads input records from the specified path on the DFS.
Public methodReduceTKey, TValue, TOutput(IOperationInput, ActionTKey, IEnumerableTValue, RecordWriterTOutput, TaskContext, RecordReuseMode)
Runs a reduce function on each key in the specified input.
Public methodReduceTKey, TValue, TOutput(IOperationInput, ActionTKey, IEnumerableTValue, RecordWriterTOutput, RecordReuseMode)
Runs a reduce function on each key in the specified input.
Public methodSpillSort
Sorts the specified input by using a file channel with an output type of SortSpill.
Public methodSpillSortCombine(IOperationInput, Type, Type)
Sorts the specified input by using a file channel with an output type of SortSpill.
Public methodSpillSortCombineTKey, 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.
Public methodSpillSortCombineTKey, 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.
Public methodToString
Returns a string that represents the current object.
(Inherited from Object.)
Public methodWrite
Writes the result of the specified operation to the DFS.
Top
See Also