Uses of Interface
org.apache.flink.table.runtime.operators.join.stream.keyselector.JoinKeyExtractor

Packages that use JoinKeyExtractor

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

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

Constructors in org.apache.flink.table.runtime.operators.join.stream with parameters of type JoinKeyExtractor

Constructor	Description
StreamingMultiJoinOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> parameters, List<org.apache.flink.table.types.logical.RowType> inputTypes, List<JoinInputSideSpec> inputSpecs, List<FlinkJoinType> joinTypes, MultiJoinCondition multiJoinCondition, long[] stateRetentionTime, GeneratedJoinCondition[] joinConditions, JoinKeyExtractor keyExtractor, Map<Integer,List<AttributeBasedJoinKeyExtractor.ConditionAttributeRef>> joinAttributeMap)
StreamingMultiJoinOperatorFactory(List<InternalTypeInfo<org.apache.flink.table.data.RowData>> inputTypeInfos, List<JoinInputSideSpec> inputSideSpecs, List<FlinkJoinType> joinTypes, MultiJoinCondition multiJoinCondition, long[] stateRetentionTime, GeneratedJoinCondition[] joinConditions, JoinKeyExtractor keyExtractor, Map<Integer,List<AttributeBasedJoinKeyExtractor.ConditionAttributeRef>> joinAttributeMap)

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

Classes in org.apache.flink.table.runtime.operators.join.stream.keyselector that implement JoinKeyExtractor

Modifier and Type	Class	Description
class	AttributeBasedJoinKeyExtractor	A JoinKeyExtractor that derives keys from AttributeBasedJoinKeyExtractor.AttributeRef mappings in joinAttributeMap.