JobBuilderInnerJoin Method

public InnerJoinOperation InnerJoin(
	IOperationInput outerInput,
	IOperationInput innerInput,
	Type innerJoinRecordReaderType,
	Type outerComparerType,
	Type innerComparerType
)

Public Function InnerJoin ( 
	outerInput As IOperationInput,
	innerInput As IOperationInput,
	innerJoinRecordReaderType As Type,
	outerComparerType As Type,
	innerComparerType As Type
) As InnerJoinOperation

public:
InnerJoinOperation^ InnerJoin(
	IOperationInput^ outerInput, 
	IOperationInput^ innerInput, 
	Type^ innerJoinRecordReaderType, 
	Type^ outerComparerType, 
	Type^ innerComparerType
)

member InnerJoin : 
        outerInput : IOperationInput * 
        innerInput : IOperationInput * 
        innerJoinRecordReaderType : Type * 
        outerComparerType : Type * 
        innerComparerType : Type -> InnerJoinOperation 

Parameters

outerInput

Type: Ookii.Jumbo.Jet.Jobs.BuilderIOperationInput
The outer input for the join operation.

innerInput

Type: Ookii.Jumbo.Jet.Jobs.BuilderIOperationInput
The inner input for the join operation.

innerJoinRecordReaderType

Type: SystemType
Type of the inner join record reader.

outerComparerType

Type: SystemType
Type of the comparer used to sort the outer relation. May be . May be a generic type definition with a single type parameter. Both IComparerT and IRawComparerT are supported, but using IRawComparerT is strongly recommended.

innerComparerType

Type: SystemType
Type of the comparer used to sort the inner relation. May be . May be a generic type definition with a single type parameter. Both IComparerT and IRawComparerT are supported, but using IRawComparerT is strongly recommended.

Return Value

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 outerComparerType and innerComparerType 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.

Reference