Uses of Interface
org.apache.flink.table.runtime.operators.join.adaptive.AdaptiveJoin
-
Packages that use AdaptiveJoin Package Description org.apache.flink.table.runtime.operators.join.adaptive org.apache.flink.table.runtime.strategy -
-
Uses of AdaptiveJoin in org.apache.flink.table.runtime.operators.join.adaptive
Classes in org.apache.flink.table.runtime.operators.join.adaptive that implement AdaptiveJoin Modifier and Type Class Description classAdaptiveJoinOperatorFactory<OUT>Adaptive join factory. -
Uses of AdaptiveJoin in org.apache.flink.table.runtime.strategy
Methods in org.apache.flink.table.runtime.strategy with parameters of type AdaptiveJoin Modifier and Type Method Description protected voidAdaptiveBroadcastJoinOptimizationStrategy. tryOptimizeAdaptiveJoin(org.apache.flink.runtime.scheduler.adaptivebatch.OperatorsFinished operatorsFinished, org.apache.flink.streaming.api.graph.StreamGraphContext context, org.apache.flink.streaming.api.graph.util.ImmutableStreamNode adaptiveJoinNode, List<org.apache.flink.streaming.api.graph.util.ImmutableStreamEdge> upstreamStreamEdges, AdaptiveJoin adaptiveJoin)protected voidPostProcessAdaptiveJoinStrategy. tryOptimizeAdaptiveJoin(org.apache.flink.runtime.scheduler.adaptivebatch.OperatorsFinished operatorsFinished, org.apache.flink.streaming.api.graph.StreamGraphContext context, org.apache.flink.streaming.api.graph.util.ImmutableStreamNode adaptiveJoinNode, List<org.apache.flink.streaming.api.graph.util.ImmutableStreamEdge> upstreamStreamEdges, AdaptiveJoin adaptiveJoin)
-