git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Hashjoin implementation


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