org.apache.flink.table.runtime.operators.join

Class OuterJoinPaddingUtil

java.lang.Object

org.apache.flink.table.runtime.operators.join.OuterJoinPaddingUtil

All Implemented Interfaces:

Serializable

public class OuterJoinPaddingUtil
extends Object
implements Serializable

An utility to generate reusable padding results for outer joins.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
OuterJoinPaddingUtil(int leftArity, int rightArity)

Method Summary

Modifier and Type	Method and Description
BaseRow	padLeft(BaseRow leftRow) Returns a padding result with the given left row.
BaseRow	padRight(BaseRow rightRow) Returns a padding result with the given right row.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OuterJoinPaddingUtil

public OuterJoinPaddingUtil(int leftArity,
                            int rightArity)

Method Detail

padRight

public final BaseRow padRight(BaseRow rightRow)

Returns a padding result with the given right row.

Parameters:

rightRow - the right row to pad

Returns:

the reusable null padding result

padLeft

public final BaseRow padLeft(BaseRow leftRow)

Returns a padding result with the given left row.

Parameters:

leftRow - the left row to pad

Returns:

the reusable null padding result