Click or drag to resize

InnerJoinOperation Class

Represents an inner join operation.
Inheritance Hierarchy

Namespace:  Ookii.Jumbo.Jet.Jobs.Builder
Assembly:  Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 2.0.0
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 methodEquals
Determines whether the specified object is equal to the current object.
(Inherited from Object.)
Protected methodFinalize
Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection.
(Inherited from Object.)
Public methodGetHashCode
Serves as the default hash function.
(Inherited from Object.)
Public methodGetType
Gets the Type of the current instance.
(Inherited from Object.)
Protected methodMemberwiseClone
Creates a shallow copy of the current Object.
(Inherited from Object.)
Public methodToString
Returns 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