Hi Benjamin, The approximate location is this package, the more accurate location is here.[1]
Specifically, Hash Join is divided into two steps: 1) build side 2) probe side Thanks ,vino. [1]: https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/HashPartition.java Benjamin Burkhardt <benjamin.burkha...@cs.tu-darmstadt.de> 于2018年9月10日周一 下午10:09写道： > Hi, > > can anyone tell me where the default hybrid hash join function for > partitioning (shuffle phase) is implemented? > Even after deeper dinning I was not able to figure out where it is located. > > Might be somewhere here? > —> > https://github.com/apache/flink/tree/master/flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash > > Thanks in advance. > > Benjamin
