JobBuilder Class

Provides methods for constructing Jumbo Jet jobs as a sequence of operations.

Inheritance Hierarchy

SystemObject
Ookii.Jumbo.Jet.Jobs.BuilderJobBuilder

Namespace: Ookii.Jumbo.Jet.Jobs.Builder
Assembly: Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 2.0.0

Syntax

C++

Copy

public sealed class JobBuilder

Public NotInheritable Class JobBuilder

public ref class JobBuilder sealed

[<SealedAttribute>]
type JobBuilder =  class end

The JobBuilder type exposes the following members.

Constructors

	Name	Description
	JobBuilder	Initializes a new instance of the JobBuilder class.

Top

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.

Top

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.

Top

Reference

Ookii.Jumbo.Jet.Jobs.Builder Namespace