 | Job |
Provides methods for constructing Jumbo Jet jobs as a sequence of operations.
Inheritance HierarchyNamespace: Ookii.Jumbo.Jet.Jobs.Builder
Assembly: Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 0.3.0+dc1307f20e065bb638e0b73a34cd216f57e486f1
SyntaxThe JobBuilder type exposes the following members.
Constructors| Name | Description | |
|---|---|---|
 | JobBuilder | Initializes a new instance of the JobBuilder class. |
Properties| Name | Description | |
|---|---|---|
 | AssemblyLocations | Gets the full paths of all the non-GAC and non-Jumbo assemblies used by this job. |
| JobName | Gets or sets the descriptive name of the job. |
| Settings | Gets the settings for the job. |
| TaskBuilder | Gets the DynamicTaskBuilder used to create task classes from methods. |
Methods| 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. |
See Also