Click or drag to resize

InnerJoinOperation Class

Represents an inner join operation.
Inheritance Hierarchy
SystemObject
  Ookii.Jumbo.Jet.Jobs.BuilderStageOperationBase
    Ookii.Jumbo.Jet.Jobs.BuilderInnerJoinOperation

Namespace: Ookii.Jumbo.Jet.Jobs.Builder
Assembly: Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 0.3.0+dc1307f20e065bb638e0b73a34cd216f57e486f1
Syntax
public class InnerJoinOperation : StageOperationBase

The InnerJoinOperation type exposes the following members.

Constructors
 NameDescription
Public methodInnerJoinOperation Initializes a new instance of the InnerJoinOperation class.
Top
Properties
 NameDescription
Protected propertyOutput Gets the output for this operation.
(Inherited from StageOperationBase)
Public propertySettings Gets the settings for the stage.
(Inherited from StageOperationBase)
Public propertyStageId Gets or sets the name of the stage that will be created from this operation.
(Inherited from StageOperationBase)
Public propertyTaskType Gets information about the type of the task.
(Inherited from StageOperationBase)
Top
Methods
 NameDescription
Public methodAddSchedulingDependency Adds a scheduling dependency on the specified stage to this stage.
(Inherited from StageOperationBase)
Protected methodCreateConfiguration Creates the configuration for this stage.
(Overrides StageOperationBaseCreateConfiguration(JobBuilderCompiler))
Public methodEqualsDetermines whether the specified object is equal to the current object.
(Inherited from Object)
Protected methodFinalizeAllows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection.
(Inherited from Object)
Public methodGetHashCodeServes as the default hash function.
(Inherited from Object)
Public methodGetTypeGets the Type of the current instance.
(Inherited from Object)
Protected methodMemberwiseCloneCreates a shallow copy of the current Object.
(Inherited from Object)
Public methodToStringReturns a string that represents the current object.
(Inherited from Object)
Top
Remarks

This operation joins two inputs by first sorting them (by using a spill sort on the input channel for each input) and then joining them using an inner equi-join using the InnerJoinRecordReaderTOuter, TInner, TResult.

In order for the join to be performed correctly, both the outer and inner input must be sorted on the join attribute. Please set the outer and inner comparer types accordingly.

If the join uses more than one task, both the outer and inner input must be partitioned on the join attribute. For this purpose, the outerComparerType or innerComparerType should also implement IEqualityComparerT, or you should manually set a different PartitionerType.

See Also