Uses of Class
org.apache.flink.table.runtime.operators.join.stream.AbstractStreamingJoinOperator.AssociatedRecords

Packages that use AbstractStreamingJoinOperator.AssociatedRecords

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

Uses of AbstractStreamingJoinOperator.AssociatedRecords in org.apache.flink.table.runtime.operators.join.stream

Methods in org.apache.flink.table.runtime.operators.join.stream that return AbstractStreamingJoinOperator.AssociatedRecords

Modifier and Type	Method and Description
static AbstractStreamingJoinOperator.AssociatedRecords	AbstractStreamingJoinOperator.AssociatedRecords.of(RowData input, boolean inputIsLeft, JoinRecordStateView otherSideStateView, JoinCondition condition) Creates an AbstractStreamingJoinOperator.AssociatedRecords which represents the records associated to the input row.