Package org.apache.flink.table.runtime.operators.join.stream.utils

Class OuterRecord

java.lang.Object

org.apache.flink.table.runtime.operators.join.stream.utils.OuterRecord

public final class OuterRecord
extends Object

An OuterRecord is a composite of record and numOfAssociations. The numOfAssociations represents the number of associated records in the other side. It is used when the record is from outer side (e.g. left side in LEFT OUTER JOIN). When the numOfAssociations is ZERO, we need to send a null padding row. This is useful to avoid recompute the associated numbers every time.

When the record is from inner side (e.g. right side in LEFT OUTER JOIN), the numOfAssociations will always be -1.

Field Summary

Fields

Modifier and Type	Field	Description
int	numOfAssociations
org.apache.flink.table.data.RowData	record

Constructor Summary

Constructors

Constructor	Description
OuterRecord(org.apache.flink.table.data.RowData record)
OuterRecord(org.apache.flink.table.data.RowData record, int numOfAssociations)

Method Summary

Modifier and Type	Method	Description
int	getNumOfAssociations()
org.apache.flink.table.data.RowData	getRecord()

Methods inherited from class java.lang.Object

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

Field Detail

record

public final org.apache.flink.table.data.RowData record

numOfAssociations

public final int numOfAssociations

Constructor Detail

OuterRecord

public OuterRecord(org.apache.flink.table.data.RowData record,
                   int numOfAssociations)

OuterRecord

public OuterRecord(org.apache.flink.table.data.RowData record)

Method Detail

getRecord

public org.apache.flink.table.data.RowData getRecord()

getNumOfAssociations

public int getNumOfAssociations()