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
RowData	padLeft(RowData leftRow) Returns a padding result with the given left row.
RowData	padRight(RowData 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 RowData padRight(RowData 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 RowData padLeft(RowData leftRow)

Returns a padding result with the given left row.

Parameters:

leftRow - the left row to pad

Returns:

the reusable null padding result