Package org.apache.flink.table.runtime.operators.join.stream.keyselector
-
Interface Summary Interface Description JoinKeyExtractor Defines the strategy for extracting keys used for state management within theStreamingMultiJoinOperator. -
Class Summary Class Description AttributeBasedJoinKeyExtractor AJoinKeyExtractorthat derives keys fromAttributeBasedJoinKeyExtractor.AttributeRefmappings injoinAttributeMap.AttributeBasedJoinKeyExtractor.AttributeRef Reference to a specific field (fieldIndex) within a specific input stream (inputId).AttributeBasedJoinKeyExtractor.ConditionAttributeRef Reference to a specific field (fieldIndex) within a specific input stream (inputId).