InnerJoinOperation Class |
Namespace: Ookii.Jumbo.Jet.Jobs.Builder
The InnerJoinOperation type exposes the following members.
Name | Description | |
---|---|---|
InnerJoinOperation |
Initializes a new instance of the InnerJoinOperation class.
|
Name | Description | |
---|---|---|
Output |
Gets the output for this operation.
(Inherited from StageOperationBase.) | |
Settings |
Gets the settings for the stage.
(Inherited from StageOperationBase.) | |
StageId |
Gets or sets the name of the stage that will be created from this operation.
(Inherited from StageOperationBase.) | |
TaskType |
Gets information about the type of the task.
(Inherited from StageOperationBase.) |
Name | Description | |
---|---|---|
AddSchedulingDependency |
Adds a scheduling dependency on the specified stage to this stage.
(Inherited from StageOperationBase.) | |
CreateConfiguration |
Creates the configuration for this stage.
(Overrides StageOperationBaseCreateConfiguration(JobBuilderCompiler).) | |
Equals | Determines whether the specified object is equal to the current object. (Inherited from Object.) | |
Finalize | Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection. (Inherited from Object.) | |
GetHashCode | Serves as the default hash function. (Inherited from Object.) | |
GetType | Gets the Type of the current instance. (Inherited from Object.) | |
MemberwiseClone | Creates a shallow copy of the current Object. (Inherited from Object.) | |
ToString | Returns a string that represents the current object. (Inherited from Object.) |
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.