Package | Description |
---|---|
org.apache.flink.runtime.operators.sort |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMergeInnerJoinIterator<T1,T2,O>
An implementation of the
JoinTaskIterator that
realizes the joining through a sort-merge join strategy. |
class |
AbstractMergeOuterJoinIterator<T1,T2,O>
An implementation of the
JoinTaskIterator that
realizes the outer join through a sort-merge join strategy. |
class |
NonReusingMergeInnerJoinIterator<T1,T2,O> |
class |
NonReusingMergeOuterJoinIterator<T1,T2,O> |
class |
ReusingMergeInnerJoinIterator<T1,T2,O> |
class |
ReusingMergeOuterJoinIterator<T1,T2,O> |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.