Uses of Class
org.apache.flink.table.runtime.operators.join.stream.keyselector.AttributeBasedJoinKeyExtractor.ConditionAttributeRef
-
-
Uses of AttributeBasedJoinKeyExtractor.ConditionAttributeRef in org.apache.flink.table.runtime.operators.join.stream
Constructor parameters in org.apache.flink.table.runtime.operators.join.stream with type arguments of type AttributeBasedJoinKeyExtractor.ConditionAttributeRef 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 AttributeBasedJoinKeyExtractor.ConditionAttributeRef in org.apache.flink.table.runtime.operators.join.stream.keyselector
Constructor parameters in org.apache.flink.table.runtime.operators.join.stream.keyselector with type arguments of type AttributeBasedJoinKeyExtractor.ConditionAttributeRef Constructor Description AttributeBasedJoinKeyExtractor(Map<Integer,List<AttributeBasedJoinKeyExtractor.ConditionAttributeRef>> joinAttributeMap, List<org.apache.flink.table.types.logical.RowType> inputTypes)Creates an AttributeBasedJoinKeyExtractor.
-