Uses of Interface
org.apache.flink.table.runtime.generated.JoinCondition

Packages that use JoinCondition

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

Uses of JoinCondition in org.apache.flink.table.runtime.hashtable

Constructors in org.apache.flink.table.runtime.hashtable with parameters of type JoinCondition

Constructor and Description

BinaryHashTable(Configuration conf, Object owner, AbstractRowDataSerializer buildSideSerializer, AbstractRowDataSerializer probeSideSerializer, Projection<RowData,BinaryRowData> buildSideProjection, Projection<RowData,BinaryRowData> probeSideProjection, MemoryManager memManager, long reservedMemorySize, IOManager ioManager, int avgRecordLen, long buildRowCount, boolean useBloomFilters, HashJoinType type, JoinCondition condFunc, boolean reverseJoin, boolean[] filterNulls, boolean tryDistinctBuildRow)

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

Methods in org.apache.flink.table.runtime.operators.join.stream with parameters of type JoinCondition

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.