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

Class AssociatedRecords

java.lang.Object

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

public class AssociatedRecords
extends Object

The AssociatedRecords is the records associated to the input row. It is a wrapper of List<OuterRecord> which provides two helpful methods getRecords() and getOuterRecords(). See the method Javadoc for more details.

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.api.common.state.v2.StateFuture<AssociatedRecords>	fromAsyncStateView(org.apache.flink.table.data.RowData input, boolean inputIsLeft, JoinRecordAsyncStateView otherSideAsyncStateView, JoinCondition joinCondition)	Creates an AssociatedRecords which represents the records associated to the input row.
static AssociatedRecords	fromSyncStateView(org.apache.flink.table.data.RowData input, boolean inputIsLeft, JoinRecordStateView otherSideStateView, JoinCondition condition)	Creates an AssociatedRecords which represents the records associated to the input row.
Iterable<OuterRecord>	getOuterRecords()	Gets the iterable of OuterRecord which composites record and numOfAssociations.
Iterable<org.apache.flink.table.data.RowData>	getRecords()	Gets the iterable of records.
boolean	isEmpty()
int	size()

Methods inherited from class java.lang.Object

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

Method Detail

isEmpty

public boolean isEmpty()

size

public int size()

getRecords

public Iterable<org.apache.flink.table.data.RowData> getRecords()

Gets the iterable of records. This is usually be called when the AssociatedRecords is from inner side.

getOuterRecords

public Iterable<OuterRecord> getOuterRecords()

Gets the iterable of OuterRecord which composites record and numOfAssociations. This is usually be called when the AssociatedRecords is from outer side.

fromSyncStateView

public static AssociatedRecords fromSyncStateView(org.apache.flink.table.data.RowData input,
                                                  boolean inputIsLeft,
                                                  JoinRecordStateView otherSideStateView,
                                                  JoinCondition condition)
                                           throws Exception

Creates an AssociatedRecords which represents the records associated to the input row.

This method is used in the sync state join operator.

Throws:

Exception

fromAsyncStateView

public static org.apache.flink.api.common.state.v2.StateFuture<AssociatedRecords> fromAsyncStateView(org.apache.flink.table.data.RowData input,
                                                                                                     boolean inputIsLeft,
                                                                                                     JoinRecordAsyncStateView otherSideAsyncStateView,
                                                                                                     JoinCondition joinCondition)
                                                                                              throws Exception

Creates an AssociatedRecords which represents the records associated to the input row.

This method is used in the async state join operator.

Throws:

Exception